scheduler

Documentation

Index

• Variables
• type Scheduler
  • func New(config *schedulerconfig.SchedulerConfiguration, vcClient vcclient.Interface, ...) (*Scheduler, error)
  • func (s *Scheduler) Bootstrap() error
  • func (s *Scheduler) Dump()
  • func (s *Scheduler) Run(stopChan <-chan struct{})

Variables

var (
	// SuperClusterResourceRegister for super clusters
	SuperClusterResourceRegister plugin.ResourceRegister
	// VirtualClusterResourceRegister for virtual clusters
	VirtualClusterResourceRegister plugin.ResourceRegister
)

ResourceRegisters for easier handle of clusters

var (
	// DirtyVirtualClusters for virtual.
	DirtyVirtualClusters sync.Map
	// DirtySuperClusters for super clusters.
	DirtySuperClusters sync.Map
)

The dirty sets are used in bootstrap and in handling cluster offline. If a cluster was in dirty set and becomes online again, the cluster state needs to be synchronized with the scheduler cache first during which the scheduler will not serve any scheduling request from that cluster.

Types

type Scheduler

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

Scheduler object

func New

func New(
	config *schedulerconfig.SchedulerConfiguration,
	vcClient vcclient.Interface,
	vcInformer vcinformers.VirtualClusterInformer,
	superClient superclient.Interface,
	superInformer superinformers.ClusterInformer,
	metaClusterClient clientset.Interface,
	metaInformers informers.SharedInformerFactory,
	stopCh <-chan struct{},
	recorder record.EventRecorder,
) (*Scheduler, error)

New creates new Scheduler

func (*Scheduler) Bootstrap

func (s *Scheduler) Bootstrap() error

Bootstrap initializes the scheduler cache.

func (*Scheduler) Dump

func (s *Scheduler) Dump()

Dump scheduler cache.

func (*Scheduler) Run

func (s *Scheduler) Run(stopChan <-chan struct{})

Run start Scheduler