Struct schedulerProcessor

pkg/querier/worker/scheduler_processor.go:69–82

Handles incoming queries from query-scheduler.

// Handles incoming queries from query-scheduler.
type schedulerProcessor struct {
	log            log.Logger
	handler        RequestHandler
	grpcConfig     grpcclient.Config
	maxMessageSize int
	querierID      string
	querierAddress string

	frontendPool                  *client.Pool
	frontendClientRequestDuration *prometheus.HistogramVec

	targetHeaders          []string
	schedulerClientFactory func(conn *grpc.ClientConn) schedulerpb.SchedulerForQuerierClient
}

// notifyShutdown implements processor.
func (sp *schedulerProcessor) notifyShutdown(ctx context.Context, conn *grpc.ClientConn, address string) {