Method processQueriesOnSingleStream

pkg/querier/worker/worker.go:84–84

Each invocation of processQueriesOnSingleStream starts new streaming operation to query-frontend or query-scheduler to fetch queries and execute them. This method must react on context being finished, and stop when that happens. processorManager (not processor) is responsible for starting as many

(ctx context.Context, conn *grpc.ClientConn, address string)

	//
	// processorManager (not processor) is responsible for starting as many goroutines as needed for each connection.
	processQueriesOnSingleStream(ctx context.Context, conn *grpc.ClientConn, address string)

	// notifyShutdown notifies the remote query-frontend or query-scheduler that the querier is
	// shutting down.