()
| 570 | } |
| 571 | |
| 572 | func querierAll[V Value, Q interface { |
| 573 | sqlAll(context.Context, ...queryHook) (V, error) |
| 574 | }]() Querier { |
| 575 | return QuerierFunc(func(ctx context.Context, q Query) (Value, error) { |
| 576 | query, ok := q.(Q) |
| 577 | if !ok { |
| 578 | return nil, fmt.Errorf("unexpected query type %T", q) |
| 579 | } |
| 580 | return query.sqlAll(ctx) |
| 581 | }) |
| 582 | } |
| 583 | |
| 584 | func querierCount[Q interface { |
| 585 | sqlCount(context.Context) (int, error) |