scheduler

Documentation

Index

• Constants
• func New(obj runtime.Object, f framework.Handle) (framework.Plugin, error)
• type MultiSchedulingPlugin
  • func (m MultiSchedulingPlugin) Filter(pc context.Context, state *framework.CycleState, pod *v1.Pod, ...) *framework.Status
  • func (m MultiSchedulingPlugin) Name() string
• type Scheduler
  • func NewScheduler(ctx context.Context, cc schedulerappconfig.Config, stopCh <-chan struct{}) (*Scheduler, error)
  • func (sched *Scheduler) Run(ctx context.Context) error

Constants

const Name = "MultiClusterScheduling"

Name is MultiClusterScheduling plugin name, will use in configuration file

Functions

func New

func New(obj runtime.Object, f framework.Handle) (framework.Plugin, error)

New initializes a new plugin and returns it.

Types

type MultiSchedulingPlugin

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

MultiSchedulingPlugin is plugin implemented scheduling framework

func (MultiSchedulingPlugin) Filter

func (m MultiSchedulingPlugin) Filter(pc context.Context, state *framework.CycleState,
	pod *v1.Pod, nodeInfo *framework.NodeInfo) *framework.Status

Filter check if a pod can run on node

func (MultiSchedulingPlugin) Name

func (m MultiSchedulingPlugin) Name() string

Name returns the plugin name

type Scheduler

type Scheduler struct {
	*scheduler.Scheduler
	// configuration of multicluster
	Config schedulerappconfig.Config
	// stop signal
	StopCh <-chan struct{}
}

Scheduler define the multicluster struct

func NewScheduler

func NewScheduler(ctx context.Context, cc schedulerappconfig.Config, stopCh <-chan struct{}) (*Scheduler, error)

NewScheduler executes the multicluster based on the given configuration. It only return on error or when stopCh is closed.

func (*Scheduler) Run

func (sched *Scheduler) Run(ctx context.Context) error

Run executes the multicluster based on the given configuration. It only return on error or when stopCh is closed.