Versions in this module Expand all Collapse all v3 v3.0.0 Apr 8, 2024 Changes in this version + const NumTokens + const ReplicationFactor + func SafeReadRing(cfg Config, rm *lokiring.RingManager) ring.ReadRing + type Config struct + GRPCClientConfig grpcclient.Config + MaxOutstandingPerTenant int + MaxQueueHierarchyLevels int + QuerierForgetDelay time.Duration + SchedulerRing lokiring.RingConfig + UseSchedulerRing bool + func (cfg *Config) RegisterFlags(f *flag.FlagSet) + func (cfg *Config) Validate() error + type Limits limits.Limits + type Scheduler struct + func NewScheduler(cfg Config, schedulerLimits Limits, log log.Logger, ...) (*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) QuerierLoop(querier schedulerpb.SchedulerForQuerier_QuerierLoopServer) error