scheduler

Documentation

Index

• type Scheduler
  • func NewScheduler(schedulerConfig config.SchedulerConfig, brokerInfo brokerinfo.BrokerInfo, ...) *Scheduler
  • func (w *Scheduler) ListIntanceGUIDs() []string
  • func (s *Scheduler) Run(signals <-chan os.Signal, ready chan<- struct{}) error
  • func (w *Scheduler) Stop()
  • func (s *Scheduler) WithDriver(drivers ...collector.MetricsCollectorDriver) *Scheduler

Types

type Scheduler

type Scheduler struct {
	// contains filtered or unexported fields
}

Scheduler ...

func NewScheduler

func NewScheduler(
	schedulerConfig config.SchedulerConfig,
	brokerInfo brokerinfo.BrokerInfo,
	metricsEmitter emitter.MetricsEmitter,
	logger lager.Logger,
) *Scheduler

NewScheduler ...

func (*Scheduler) ListIntanceGUIDs

func (w *Scheduler) ListIntanceGUIDs() []string

ListIntanceGUIDs ...

func (*Scheduler) Run

func (s *Scheduler) Run(signals <-chan os.Signal, ready chan<- struct{}) error

func (*Scheduler) Stop

func (w *Scheduler) Stop()

Stop...

func (*Scheduler) WithDriver

func (s *Scheduler) WithDriver(drivers ...collector.MetricsCollectorDriver) *Scheduler

WithDriver ...