()
| 532 | } |
| 533 | |
| 534 | func querierAll[V Value, Q interface { |
| 535 | sqlAll(context.Context, ...queryHook) (V, error) |
| 536 | }]() Querier { |
| 537 | return QuerierFunc(func(ctx context.Context, q Query) (Value, error) { |
| 538 | query, ok := q.(Q) |
| 539 | if !ok { |
| 540 | return nil, fmt.Errorf("unexpected query type %T", q) |
| 541 | } |
| 542 | return query.sqlAll(ctx) |
| 543 | }) |
| 544 | } |
| 545 | |
| 546 | func querierCount[Q interface { |
| 547 | sqlCount(context.Context) (int, error) |