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

Method QueryStream

pkg/ingester/client/ingester.pb.go:2830–2830  ·  view source on GitHub ↗
(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption)

Source from the content-addressed store, hash-verified

2828 Push(ctx context.Context, in *cortexpb.WriteRequest, opts ...grpc.CallOption) (*cortexpb.WriteResponse, error)
2829 PushStream(ctx context.Context, opts ...grpc.CallOption) (Ingester_PushStreamClient, error)
2830 QueryStream(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (Ingester_QueryStreamClient, error)
2831 QueryExemplars(ctx context.Context, in *ExemplarQueryRequest, opts ...grpc.CallOption) (*ExemplarQueryResponse, error)
2832 LabelValues(ctx context.Context, in *LabelValuesRequest, opts ...grpc.CallOption) (*LabelValuesResponse, error)
2833 LabelValuesStream(ctx context.Context, in *LabelValuesRequest, opts ...grpc.CallOption) (Ingester_LabelValuesStreamClient, error)

Callers 15

BenchmarkGrpcCallsFunction · 0.95
TestConcurrentGrpcCallsFunction · 0.95
TestStreamingSendsFunction · 0.95
TestExpandedCachePostings_RaceFunction · 0.65
runTestQueryTimesFunction · 0.65
TestMatcherCacheFunction · 0.65
TestIngester_PushFunction · 0.65
Test_Ingester_QueryFunction · 0.65
Test_Ingester_Query_MaxInflightQueryRequestFunction · 0.65
TestIngester_Query_ShouldNotCreateTSDBIfDoesNotExistsFunction · 0.65
Test_Ingester_Query_ResourceThresholdBreachedFunction · 0.65
TestIngester_QueryStreamFunction · 0.65

Implementers 4

Ingesterpkg/ingester/ingester.go
IngesterServerMockpkg/ingester/client/cortex_mock_test.g
ingesterClientpkg/ingester/client/ingester.pb.go
UnimplementedIngesterServerpkg/ingester/client/ingester.pb.go

Calls

no outgoing calls

Tested by 15

BenchmarkGrpcCallsFunction · 0.76
TestConcurrentGrpcCallsFunction · 0.76
TestStreamingSendsFunction · 0.76
TestExpandedCachePostings_RaceFunction · 0.52
runTestQueryTimesFunction · 0.52
TestMatcherCacheFunction · 0.52
TestIngester_PushFunction · 0.52
Test_Ingester_QueryFunction · 0.52
Test_Ingester_Query_MaxInflightQueryRequestFunction · 0.52
TestIngester_Query_ShouldNotCreateTSDBIfDoesNotExistsFunction · 0.52
Test_Ingester_Query_ResourceThresholdBreachedFunction · 0.52
TestIngester_QueryStreamFunction · 0.52