schedulingmanager

Documentation

Index

• type SchedulerWrapper
  • func (s *SchedulerWrapper) HasPlugin(typeConfigName string) bool
• type SchedulingManager
  • func StartSchedulingManager(config *util.ControllerConfig, stopChan <-chan struct{}) (*SchedulingManager, error)
  • func (c *SchedulingManager) GetScheduler(schedulingKind string) *SchedulerWrapper
  • func (c *SchedulingManager) Run(stopChan <-chan struct{})

Types

type SchedulerWrapper

type SchedulerWrapper struct {

	// Actual scheduler.
	schedulingtypes.Scheduler
	// contains filtered or unexported fields
}

func (*SchedulerWrapper) HasPlugin

func (s *SchedulerWrapper) HasPlugin(typeConfigName string) bool

type SchedulingManager

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

func StartSchedulingManager

func StartSchedulingManager(config *util.ControllerConfig, stopChan <-chan struct{}) (*SchedulingManager, error)

func (*SchedulingManager) GetScheduler

func (c *SchedulingManager) GetScheduler(schedulingKind string) *SchedulerWrapper

func (*SchedulingManager) Run

func (c *SchedulingManager) Run(stopChan <-chan struct{})

Run runs the Controller.