(ctx context.Context, req proto.Message, onPage func(proto.Message) error)
| 25 | } |
| 26 | |
| 27 | func (qe *EvmQueryExecutor) Execute(ctx context.Context, req proto.Message, onPage func(proto.Message) error) error { |
| 28 | switch r := req.(type) { |
| 29 | case *evm.QueryBlocksRequest: |
| 30 | return qe.queryBlocks(ctx, r, onPage) |
| 31 | case *evm.QueryTransactionsRequest: |
| 32 | return qe.queryTransactions(ctx, r, onPage) |
| 33 | case *evm.QueryLogsRequest: |
| 34 | return qe.queryLogs(ctx, r, onPage) |
| 35 | case *evm.QueryTracesRequest: |
| 36 | return qe.queryTraces(ctx, r, onPage) |
| 37 | case *evm.QueryTransfersRequest: |
| 38 | return qe.queryTransfers(ctx, r, onPage) |
| 39 | default: |
| 40 | return status.Error(codes.InvalidArgument, "unknown query request type") |
| 41 | } |
| 42 | } |
| 43 | |
| 44 | func (qe *EvmQueryExecutor) queryBlocks(ctx context.Context, req *evm.QueryBlocksRequest, onPage func(proto.Message) error) error { |
| 45 | ctx, span := common.StartDetailSpan(ctx, "Query.Execute", |
no test coverage detected