Struct frontendProcessor

pkg/querier/worker/frontend_processor.go:41–49

Handles incoming queries from frontend.

// Handles incoming queries from frontend.
type frontendProcessor struct {
	handler        RequestHandler
	maxMessageSize int
	querierID      string

	log log.Logger

	targetHeaders []string
}

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