MCPcopy Create free account
hub / github.com/cortexproject/cortex / Send

Method Send

pkg/ingester/client/ingester.pb.go:2870–2870  ·  view source on GitHub ↗
(*cortexpb.StreamWriteRequest)

Source from the content-addressed store, hash-verified

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

Callers 6

PushStreamMethod · 0.65
SendQueryStreamFunction · 0.65
SendMetricsForLabelMatchersStreamFunction · 0.65
SendLabelValuesStreamFunction · 0.65
SendLabelNamesStreamFunction · 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

no test coverage detected