Documentation
¶
Index ¶
- type Config
- type Frontend
- func (f *Frontend) CheckReady(_ context.Context) error
- func (f *Frontend) NotifyClientShutdown(_ context.Context, req *frontendv1pb.NotifyClientShutdownRequest) (*frontendv1pb.NotifyClientShutdownResponse, error)
- func (f *Frontend) Process(server frontendv1pb.Frontend_ProcessServer) error
- func (f *Frontend) RoundTripGRPC(ctx context.Context, req *httpgrpc.HTTPRequest) (*httpgrpc.HTTPResponse, error)
- type Limits
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
MaxOutstandingPerTenant int `yaml:"max_outstanding_per_tenant"`
QuerierForgetDelay time.Duration `yaml:"querier_forget_delay"`
}
Config for a Frontend.
func (*Config) RegisterFlags ¶
func (cfg *Config) RegisterFlags(f *flag.FlagSet)
RegisterFlags adds the flags required to config this to the given FlagSet.
type Frontend ¶
type Frontend struct {
services.Service
// contains filtered or unexported fields
}
Frontend queues HTTP requests, dispatches them to backends, and handles retries for requests which failed.
func New ¶
func New(cfg Config, limits Limits, log log.Logger, registerer prometheus.Registerer) (*Frontend, error)
New creates a new frontend. Frontend implements service, and must be started and stopped.
func (*Frontend) CheckReady ¶
func (f *Frontend) CheckReady(_ context.Context) error
CheckReady determines if the query frontend is ready. Function parameters/return chosen to match the same method in the ingester
func (*Frontend) NotifyClientShutdown ¶ added in v1.9.0
func (f *Frontend) NotifyClientShutdown(_ context.Context, req *frontendv1pb.NotifyClientShutdownRequest) (*frontendv1pb.NotifyClientShutdownResponse, error)
func (*Frontend) Process ¶
func (f *Frontend) Process(server frontendv1pb.Frontend_ProcessServer) error
Process allows backends to pull requests from the frontend.
func (*Frontend) RoundTripGRPC ¶
func (f *Frontend) RoundTripGRPC(ctx context.Context, req *httpgrpc.HTTPRequest) (*httpgrpc.HTTPResponse, error)
RoundTripGRPC round trips a proto (instead of a HTTP request).
Click to show internal directories.
Click to hide internal directories.