worker

Jun 12, 2023

Changes in this version

type Config

+ MaxConcurrent int

Feb 20, 2023

Changes in this version

+ func NewQuerierWorker(cfg Config, handler RequestHandler, log log.Logger, reg prometheus.Registerer) (services.Service, error)

+ type Config struct

+ DNSLookupPeriod time.Duration

+ GRPCClientConfig grpcclient.Config

+ MaxConcurrentRequests int

+ MaxLoopDuration time.Duration

+ QuerierID string

+ QuerySchedulerDiscovery schedulerdiscovery.Config

+ SchedulerAddress string

+ func (cfg *Config) RegisterFlags(f *flag.FlagSet)

+ func (cfg *Config) Validate(log log.Logger) error

+ type RequestHandler interface

+ Handle func(context.Context, *httpgrpc.HTTPRequest) (*httpgrpc.HTTPResponse, error)