Versions in this module Expand all Collapse all v2 v2.4.3 Mar 21, 2022 Changes in this version + func SafeReadRing(s *Scheduler) ring.ReadRing + type Config struct + GRPCClientConfig grpcclient.Config + MaxOutstandingPerTenant int + QuerierForgetDelay time.Duration + SchedulerRing lokiutil.RingConfig + UseSchedulerRing bool + func (cfg *Config) RegisterFlags(f *flag.FlagSet) + type Limits interface + MaxQueriersPerUser func(user string) int + type Scheduler struct + func NewScheduler(cfg Config, limits Limits, log log.Logger, registerer prometheus.Registerer) (*Scheduler, error) + func (s *Scheduler) FrontendLoop(frontend schedulerpb.SchedulerForFrontend_FrontendLoopServer) error + func (s *Scheduler) NotifyQuerierShutdown(_ context.Context, req *schedulerpb.NotifyQuerierShutdownRequest) (*schedulerpb.NotifyQuerierShutdownResponse, error) + func (s *Scheduler) OnRingInstanceHeartbeat(_ *ring.BasicLifecycler, _ *ring.Desc, _ *ring.InstanceDesc) + func (s *Scheduler) OnRingInstanceRegister(_ *ring.BasicLifecycler, ringDesc ring.Desc, instanceExists bool, ...) (ring.InstanceState, ring.Tokens) + func (s *Scheduler) OnRingInstanceStopping(_ *ring.BasicLifecycler) + func (s *Scheduler) OnRingInstanceTokens(_ *ring.BasicLifecycler, _ ring.Tokens) + func (s *Scheduler) QuerierLoop(querier schedulerpb.SchedulerForQuerier_QuerierLoopServer) error + func (s *Scheduler) ServeHTTP(w http.ResponseWriter, req *http.Request) Other modules containing this package github.com/pao214/loki/v3
Go to main page