minisched

Documentation

Index

• type Scheduler
  • func New(client clientset.Interface, informerFactory informers.SharedInformerFactory) (*Scheduler, error)
  • func (sched *Scheduler) Bind(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) error
  • func (sched *Scheduler) ErrorFunc(pod *v1.Pod, err error)
  • func (sched *Scheduler) GetWaitingPod(uid types.UID) *waitingpod.WaitingPod
  • func (sched *Scheduler) Run(ctx context.Context)
  • func (sched *Scheduler) RunFilterPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodes []v1.Node) ([]*v1.Node, error)
  • func (sched *Scheduler) RunPermitPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) (status *framework.Status)
  • func (sched *Scheduler) RunPreScorePlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, ...) *framework.Status
  • func (sched *Scheduler) RunScorePlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, ...) (framework.NodeScoreList, *framework.Status)
  • func (sched *Scheduler) WaitOnPermit(ctx context.Context, pod *v1.Pod) *framework.Status

Types

type Scheduler

type Scheduler struct {
	SchedulingQueue *queue.SchedulingQueue
	// contains filtered or unexported fields
}

func New

func New(
	client clientset.Interface,
	informerFactory informers.SharedInformerFactory,
) (*Scheduler, error)

func (*Scheduler) Bind

func (sched *Scheduler) Bind(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) error

func (*Scheduler) ErrorFunc

func (sched *Scheduler) ErrorFunc(pod *v1.Pod, err error)

func (*Scheduler) GetWaitingPod

func (sched *Scheduler) GetWaitingPod(uid types.UID) *waitingpod.WaitingPod

func (*Scheduler) Run

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

func (*Scheduler) RunFilterPlugins

func (sched *Scheduler) RunFilterPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodes []v1.Node) ([]*v1.Node, error)

func (*Scheduler) RunPermitPlugins

func (sched *Scheduler) RunPermitPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) (status *framework.Status)

func (*Scheduler) RunPreScorePlugins

func (sched *Scheduler) RunPreScorePlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodes []*v1.Node) *framework.Status

func (*Scheduler) RunScorePlugins

func (sched *Scheduler) RunScorePlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodes []*v1.Node) (framework.NodeScoreList, *framework.Status)

func (*Scheduler) WaitOnPermit

func (sched *Scheduler) WaitOnPermit(ctx context.Context, pod *v1.Pod) *framework.Status

WaitOnPermit will block, if the pod is a waiting pod, until the waiting pod is rejected or allowed.