MCPcopy
hub / github.com/grafana/tempo / Next

Method Next

modules/frontend/pipeline/responses.go:15–15  ·  view source on GitHub ↗

Next returns the next response or an error if one is available. It always prefers an error over a response.

(context.Context)

Source from the content-addressed store, hash-verified

13type Responses[T any] interface {
14 // Next returns the next response or an error if one is available. It always prefers an error over a response.
15 Next(context.Context) (T, bool, error) // bool = done
16}
17
18var _ Responses[combiner.PipelineResponse] = syncResponse{}

Callers 15

consumePartitionMethod · 0.65
readKafkaMethod · 0.65
processJobsMethod · 0.65
DoWeightedRequestFunction · 0.65
TestQueryValidatorFunction · 0.65

Implementers 15

rawIteratortempodb/encoding/vparquet4/block_itera
bridgeIteratortempodb/encoding/vparquet4/block_trace
rebatchIteratortempodb/encoding/vparquet4/block_trace
spansetIteratortempodb/encoding/vparquet4/block_trace
mergeSpansetIteratortempodb/encoding/vparquet4/block_trace
testIteratortempodb/encoding/vparquet4/create_test
pageFileClosingIteratortempodb/encoding/vparquet4/wal_block.g
rowIteratortempodb/encoding/vparquet4/wal_block.g
commonIteratortempodb/encoding/vparquet4/wal_block.g
rowNumberIteratortempodb/encoding/vparquet4/block_searc
rawIteratortempodb/encoding/vparquet5/block_itera
bridgeIteratortempodb/encoding/vparquet5/block_trace

Calls

no outgoing calls