MCPcopy Index your code
hub / github.com/cortexproject/cortex / Recv

Method Recv

pkg/ingester/client/ingester.pb.go:2871–2871  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

2869type Ingester_PushStreamClient interface {
2870 Send(*cortexpb.StreamWriteRequest) error
2871 Recv() (*cortexpb.WriteResponse, error)
2872 grpc.ClientStream
2873}
2874

Callers 12

PushStreamMethod · 0.65
BenchmarkGrpcCallsFunction · 0.65
TestConcurrentGrpcCallsFunction · 0.65
Test_newStoreGatewayClientFactoryFunction · 0.65
fetchSeriesFromStoresMethod · 0.65
querierLoopMethod · 0.65
processMethod · 0.65
PushStreamMethod · 0.65
TestIngester_QueryStreamFunction · 0.65
TestIngester_QueryStreamManySamplesChunksFunction · 0.65
TestStreamingSendsFunction · 0.65
processJobMethod · 0.65

Implementers 13

schedulerForQuerierQuerierLoopClientpkg/scheduler/schedulerpb/scheduler.pb
schedulerForQuerierQuerierLoopServerpkg/scheduler/schedulerpb/scheduler.pb
schedulerForFrontendFrontendLoopClientpkg/scheduler/schedulerpb/scheduler.pb
schedulerForFrontendFrontendLoopServerpkg/scheduler/schedulerpb/scheduler.pb
processServerMockpkg/frontend/v1/queue_test.go
frontendProcessClientpkg/frontend/v1/frontendv1pb/frontend.
frontendProcessServerpkg/frontend/v1/frontendv1pb/frontend.
mockQuerierLoopClientpkg/querier/worker/scheduler_processor
pushStreamServerpkg/ingester/pushstream_security_test.
ingesterPushStreamClientpkg/ingester/client/ingester.pb.go
ingesterPushStreamServerpkg/ingester/client/ingester.pb.go
mockClientStreampkg/ingester/client/client_test.go

Calls

no outgoing calls

Tested by 7

PushStreamMethod · 0.52
BenchmarkGrpcCallsFunction · 0.52
TestConcurrentGrpcCallsFunction · 0.52
Test_newStoreGatewayClientFactoryFunction · 0.52
TestIngester_QueryStreamFunction · 0.52
TestIngester_QueryStreamManySamplesChunksFunction · 0.52
TestStreamingSendsFunction · 0.52