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

Method CloseSend

pkg/distributor/distributor_test.go:4040–4042  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

4038}
4039
4040func (*queryStream) CloseSend() error {
4041 return nil
4042}
4043
4044func (s *queryStream) Recv() (*client.QueryStreamResponse, error) {
4045 if s.i >= len(s.results) {

Callers 15

TestConcurrentGrpcCallsFunction · 0.45
TestSchedulerEnqueueWithFrontendDisconnectFunction · 0.45
TestCancelRequestInProgressFunction · 0.45
TestSchedulerForwardsErrorToFrontendFunction · 0.45
SeriesMethod · 0.45
runOneMethod · 0.45
queryIngesterStreamMethod · 0.45
LabelValuesForLabelNameStreamMethod · 0.45
LabelNamesStreamMethod · 0.45
MetricsForLabelMatchersStreamMethod · 0.45
SeriesMethod · 0.45
NextMethod · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected