scheduler

package
v0.0.0-...-44dad58 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 20, 2021 License: Apache-2.0 Imports: 39 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var DirtySuperClusters sync.Map
View Source
var DirtyVirtualClusters 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.

View Source
var SuperClusterResourceRegister plugin.ResourceRegister
View Source
var VirtualClusterResourceRegister plugin.ResourceRegister

Functions

This section is empty.

Types

type Scheduler

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

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)

func (*Scheduler) Bootstrap

func (s *Scheduler) Bootstrap() error

Bootstrap initializes the scheduler cache

func (*Scheduler) Dump

func (s *Scheduler) Dump()

func (*Scheduler) Run

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL