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

Method Process

pkg/frontend/v1/frontendv1pb/frontend.pb.go:483–483  ·  view source on GitHub ↗

After calling this method, client enters a loop, in which it waits for a "FrontendToClient" message and replies with single "ClientToFrontend" message.

(ctx context.Context, opts ...grpc.CallOption)

Source from the content-addressed store, hash-verified

481 // After calling this method, client enters a loop, in which it waits for
482 // a "FrontendToClient" message and replies with single "ClientToFrontend" message.
483 Process(ctx context.Context, opts ...grpc.CallOption) (Frontend_ProcessClient, error)
484 // The client notifies the query-frontend that it started a graceful shutdown.
485 NotifyClientShutdown(ctx context.Context, in *NotifyClientShutdownRequest, opts ...grpc.CallOption) (*NotifyClientShutdownResponse, error)
486}

Callers 5

TestRoundRobinQueuesFunction · 0.65
prepareSeriesKeysMethod · 0.65

Implementers 4

Frontendpkg/frontend/v1/frontend.go
frontendClientpkg/frontend/v1/frontendv1pb/frontend.
UnimplementedFrontendServerpkg/frontend/v1/frontendv1pb/frontend.
mockGrpcServiceHandlerpkg/cortex/cortex_test.go

Calls

no outgoing calls

Tested by 2

TestRoundRobinQueuesFunction · 0.52