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) ProcessTracepoint(server frontendv1pb.Frontend_ProcessTracepointServer) error
- func (f *Frontend) QuerierRoundTrip(ctx context.Context, req *frontendv1pb.HTTPRequest) (*frontendv1pb.HTTPResponse, error)
- func (f *Frontend) TracepointRoundTrip(ctx context.Context, req *frontendv1pb.HTTPRequest) (*frontendv1pb.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 ¶
RegisterFlags adds the flags required to config this to the given FlagSet.
type Frontend ¶
type Frontend struct {
services.Service
frontendv1pb.UnimplementedFrontendServer
// 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 ¶
CheckReady determines if the query frontend is ready. Function parameters/return chosen to match the same method in the ingester
func (*Frontend) NotifyClientShutdown ¶
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) ProcessTracepoint ¶
func (f *Frontend) ProcessTracepoint(server frontendv1pb.Frontend_ProcessTracepointServer) error
func (*Frontend) QuerierRoundTrip ¶
func (f *Frontend) QuerierRoundTrip(ctx context.Context, req *frontendv1pb.HTTPRequest) (*frontendv1pb.HTTPResponse, error)
QuerierRoundTrip sends a http request to the querier via a GRPC stream connection from the querier we 'store' the request in a queue (requestQueue) locally until a querier asks for a job
func (*Frontend) TracepointRoundTrip ¶
func (f *Frontend) TracepointRoundTrip(ctx context.Context, req *frontendv1pb.HTTPRequest) (*frontendv1pb.HTTPResponse, error)
TracepointRoundTrip sends a http request to the tracepointAPI via a GRPC stream connection from the tracepointAPI we 'store' the request in a queue (tpRequestQueue) locally until a tracepointAPI asks for a job
Source Files
Directories