Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewQuerierWorker ¶
func NewQuerierWorker(cfg Config, handler RequestHandler, log log.Logger, reg prometheus.Registerer) (services.Service, error)
Types ¶
type Config ¶
type Config struct { SchedulerAddress string `yaml:"scheduler_address" doc:"hidden"` DNSLookupPeriod time.Duration `yaml:"dns_lookup_duration" category:"advanced" doc:"hidden"` QuerierID string `yaml:"id" category:"advanced"` GRPCClientConfig grpcclient.Config `` /* 155-byte string literal not displayed */ // This configuration is injected internally. MaxConcurrentRequests int `yaml:"-"` // Must be same as passed to PromQL Engine. QuerySchedulerDiscovery schedulerdiscovery.Config `yaml:"-"` MaxLoopDuration time.Duration `yaml:"-"` }
func (*Config) RegisterFlags ¶
type RequestHandler ¶
type RequestHandler interface {
Handle(context.Context, *httpgrpc.HTTPRequest) (*httpgrpc.HTTPResponse, error)
}
RequestHandler for HTTP requests wrapped in protobuf messages.
Click to show internal directories.
Click to hide internal directories.