coscheduling

Documentation

Index

• Constants
• func New(_ runtime.Object, handle handle.PodFrameworkHandle) (framework.Plugin, error)
• type Coscheduling
  • func (cs *Coscheduling) Filter(ctx context.Context, state *framework.CycleState, pod *v1.Pod, ...) *framework.Status
  • func (cs *Coscheduling) Name() string
  • func (cs *Coscheduling) PreFilter(ctx context.Context, state *framework.CycleState, pod *v1.Pod) *framework.Status
  • func (cs *Coscheduling) PreFilterExtensions() framework.PreFilterExtensions

Constants

const (
	// Name is the name of the plugin used in Registry and configurations.
	Name = "Coscheduling"
)

Functions

func New

func New(_ runtime.Object, handle handle.PodFrameworkHandle) (framework.Plugin, error)

New initializes and returns a new Coscheduling plugin.

Types

type Coscheduling

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

Coscheduling is a plugin that schedules pods in a group.

func (*Coscheduling) Filter

func (cs *Coscheduling) Filter(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeInfo framework.NodeInfo) *framework.Status

TODO: remove Filter and refactor plugin registration in scheduler.

func (*Coscheduling) Name

func (cs *Coscheduling) Name() string

Name returns name of the plugin. It is used in logs, etc.

func (*Coscheduling) PreFilter

func (cs *Coscheduling) PreFilter(ctx context.Context, state *framework.CycleState, pod *v1.Pod) *framework.Status

PreFilter reject pods without associate pod group or invalid pod group objects (e.g. timeout)

func (*Coscheduling) PreFilterExtensions

func (cs *Coscheduling) PreFilterExtensions() framework.PreFilterExtensions