scheduler

Documentation

Index

• Constants
• func New(configuration *runtime.Unknown, f framework.FrameworkHandle) (framework.Plugin, error)
• type Args
• type LVM
  • func (y *LVM) Filter(ctx context.Context, state *framework.CycleState, pod *v1.Pod, ...) *framework.Status
  • func (y *LVM) Name() string
  • func (y *LVM) NormalizeScore(ctx context.Context, state *framework.CycleState, p *v1.Pod, ...) *framework.Status
  • func (y *LVM) PostFilter(ctx context.Context, state *framework.CycleState, pod *v1.Pod, ...) *framework.Status
  • func (y *LVM) Score(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) (int64, *framework.Status)
  • func (y *LVM) ScoreExtensions() framework.ScoreExtensions

Constants

const (
	Name = "lvm"
)

Functions

func New

func New(configuration *runtime.Unknown, f framework.FrameworkHandle) (framework.Plugin, error)

Types

type Args

type Args struct {
	KubeConfig string `json:"kubeconfig,omitempty"`
	Master     string `json:"master,omitempty"`
}

type LVM

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

func (*LVM) Filter

func (y *LVM) Filter(ctx context.Context, state *framework.CycleState, pod *v1.Pod, node *nodeinfo.NodeInfo) *framework.Status

func (*LVM) Name

func (y *LVM) Name() string

func (*LVM) NormalizeScore

func (y *LVM) NormalizeScore(ctx context.Context, state *framework.CycleState, p *v1.Pod, scores framework.NodeScoreList) *framework.Status

func (*LVM) PostFilter

func (y *LVM) PostFilter(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodes []*v1.Node, filteredNodesStatuses framework.NodeToStatusMap) *framework.Status

func (*LVM) Score

func (y *LVM) Score(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) (int64, *framework.Status)

func (*LVM) ScoreExtensions

func (y *LVM) ScoreExtensions() framework.ScoreExtensions