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

Method Recv

integration/operations/operational_metrics_test.go:189–189  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

187
188type streamingClient[T any] interface {
189 Recv() (*T, error)
190}
191
192func drainStreamingClient[T any](stream streamingClient[T]) error {

Callers 9

TestQueryRateLimitsFunction · 0.65
callQueryRangeFunction · 0.65
TestStreamingSearch_badRequestFunction · 0.65
TestSearchTagValuesV2_badRequestFunction · 0.65
TestSearchTags_maxConditionGroupsExceededFunction · 0.65
callSearchTagValuesV2AndAssertFunction · 0.65
callSearchTagsV2AndAssertFunction · 0.65
drainStreamingClientFunction · 0.65
SearchStreamAndAssertTraceFunction · 0.65

Implementers 13

frontendProcessClientmodules/frontend/v1/frontendv1pb/front
frontendProcessServermodules/frontend/v1/frontendv1pb/front
streamingQuerierSearchClientpkg/tempopb/tempo.pb.go
streamingQuerierSearchTagsClientpkg/tempopb/tempo.pb.go
streamingQuerierSearchTagsV2Clientpkg/tempopb/tempo.pb.go
streamingQuerierSearchTagValuesClientpkg/tempopb/tempo.pb.go
streamingQuerierSearchTagValuesV2Clientpkg/tempopb/tempo.pb.go
streamingQuerierMetricsQueryRangeClientpkg/tempopb/tempo.pb.go
streamingQuerierMetricsQueryInstantClientpkg/tempopb/tempo.pb.go
streamingSpanWriterPluginWriteSpanStreamServercmd/tempo-query/jaeger/storage_v1/stor
spanReaderPluginGetTraceClientcmd/tempo-query/jaeger/storage_v1/stor
spanReaderPluginFindTracesClientcmd/tempo-query/jaeger/storage_v1/stor

Calls

no outgoing calls

Tested by 8

TestQueryRateLimitsFunction · 0.52
callQueryRangeFunction · 0.52
TestStreamingSearch_badRequestFunction · 0.52
TestSearchTagValuesV2_badRequestFunction · 0.52
TestSearchTags_maxConditionGroupsExceededFunction · 0.52
callSearchTagValuesV2AndAssertFunction · 0.52
callSearchTagsV2AndAssertFunction · 0.52
drainStreamingClientFunction · 0.52