plugin

Documentation

Index

• func NewGpuSharePlugin(fakeclient externalclientset.Interface, configuration runtime.Object, ...) (framework.Plugin, error)
• func NewLocalPlugin(fakeclient externalclientset.Interface, ...) (framework.Plugin, error)
• func NewSimonPlugin(fakeclient externalclientset.Interface, configuration runtime.Object, ...) (framework.Plugin, error)
• type GpuSharePlugin
  • func (plugin *GpuSharePlugin) Bind(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...) *framework.Status
  • func (plugin *GpuSharePlugin) ExportGpuNodeInfoAsNodeGpuInfo(nodeName string) (*gpusharecache.NodeGpuInfo, error)
  • func (plugin *GpuSharePlugin) Filter(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...) *framework.Status
  • func (plugin *GpuSharePlugin) InitSchedulerCache()
  • func (plugin *GpuSharePlugin) MakePodCopyReadyForBindUpdate(pod *corev1.Pod, nodeName string) (*corev1.Pod, error)
  • func (plugin *GpuSharePlugin) Name() string
  • func (plugin *GpuSharePlugin) NodeGet(name string) (*corev1.Node, error)
  • func (plugin *GpuSharePlugin) NormalizeScore(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...) *framework.Status
  • func (plugin *GpuSharePlugin) PodGet(name string, namespace string) (*corev1.Pod, error)
  • func (plugin *GpuSharePlugin) Reserve(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...) *framework.Status
  • func (plugin *GpuSharePlugin) Score(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...) (int64, *framework.Status)
  • func (plugin *GpuSharePlugin) ScoreExtensions() framework.ScoreExtensions
  • func (plugin *GpuSharePlugin) Unreserve(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...)
• type LocalPlugin
  • func (plugin *LocalPlugin) Bind(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...) *framework.Status
  • func (plugin *LocalPlugin) Filter(ctx context.Context, state *framework.CycleState, pod *v1.Pod, ...) *framework.Status
  • func (plugin *LocalPlugin) Name() string
  • func (plugin *LocalPlugin) NormalizeScore(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...) *framework.Status
  • func (plugin *LocalPlugin) Score(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...) (int64, *framework.Status)
  • func (plugin *LocalPlugin) ScoreExtensions() framework.ScoreExtensions
• type SimonPlugin
  • func (plugin *SimonPlugin) Bind(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...) *framework.Status
  • func (plugin *SimonPlugin) BindPodToNode(ctx context.Context, state *framework.CycleState, p *corev1.Pod, ...) *framework.Status
  • func (plugin *SimonPlugin) Name() string
  • func (plugin *SimonPlugin) NormalizeScore(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...) *framework.Status
  • func (plugin *SimonPlugin) Score(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...) (int64, *framework.Status)
  • func (plugin *SimonPlugin) ScoreExtensions() framework.ScoreExtensions

Functions

func NewGpuSharePlugin

func NewGpuSharePlugin(fakeclient externalclientset.Interface, configuration runtime.Object, f framework.Handle) (framework.Plugin, error)

func NewLocalPlugin

func NewLocalPlugin(fakeclient externalclientset.Interface, storageInformers storagev1informers.Interface, configuration runtime.Object, f framework.Handle) (framework.Plugin, error)

NewLocalPlugin

func NewSimonPlugin

func NewSimonPlugin(fakeclient externalclientset.Interface, configuration runtime.Object, f framework.Handle) (framework.Plugin, error)

Types

type GpuSharePlugin

type GpuSharePlugin struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

GpuSharePlugin is a plugin for scheduling framework

func (*GpuSharePlugin) Bind

func (plugin *GpuSharePlugin) Bind(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, nodeName string) *framework.Status

Bind Plugin Bind updates the GPU resources of the pod.

func (*GpuSharePlugin) ExportGpuNodeInfoAsNodeGpuInfo

func (plugin *GpuSharePlugin) ExportGpuNodeInfoAsNodeGpuInfo(nodeName string) (*gpusharecache.NodeGpuInfo, error)

func (*GpuSharePlugin) Filter

func (plugin *GpuSharePlugin) Filter(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, nodeInfo *framework.NodeInfo) *framework.Status

Filter Plugin Filter filters out non-allocatable nodes

func (*GpuSharePlugin) InitSchedulerCache

func (plugin *GpuSharePlugin) InitSchedulerCache()

func (*GpuSharePlugin) MakePodCopyReadyForBindUpdate

func (plugin *GpuSharePlugin) MakePodCopyReadyForBindUpdate(pod *corev1.Pod, nodeName string) (*corev1.Pod, error)

func (*GpuSharePlugin) Name

func (plugin *GpuSharePlugin) Name() string

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

func (*GpuSharePlugin) NodeGet

func (plugin *GpuSharePlugin) NodeGet(name string) (*corev1.Node, error)

func (*GpuSharePlugin) NormalizeScore

func (plugin *GpuSharePlugin) NormalizeScore(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, scores framework.NodeScoreList) *framework.Status

NormalizeScore invoked after scoring all nodes.

func (*GpuSharePlugin) PodGet

func (plugin *GpuSharePlugin) PodGet(name string, namespace string) (*corev1.Pod, error)

func (*GpuSharePlugin) Reserve

func (plugin *GpuSharePlugin) Reserve(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, nodeName string) *framework.Status

Reserve Plugin Reserve updates the GPU resource of the given node, according to the pod's request.

func (*GpuSharePlugin) Score

func (plugin *GpuSharePlugin) Score(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, nodeName string) (int64, *framework.Status)

Score Plugin Score invoked at the score extension point.

func (*GpuSharePlugin) ScoreExtensions

func (plugin *GpuSharePlugin) ScoreExtensions() framework.ScoreExtensions

ScoreExtensions of the Score plugin.

func (*GpuSharePlugin) Unreserve

func (plugin *GpuSharePlugin) Unreserve(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, nodeName string)

Unreserve undoes the GPU resource updated in Reserve function.

type LocalPlugin

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

LocalPlugin is a plugin for scheduling framework

func (*LocalPlugin) Bind

func (plugin *LocalPlugin) Bind(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, nodeName string) *framework.Status

Bind invoked at the bind extension point. LocalPlugin Bind must be executed before SimonPlugin Bind

func (*LocalPlugin) Filter

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

Score invoked at the score extension point.

func (*LocalPlugin) Name

func (plugin *LocalPlugin) Name() string

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

func (*LocalPlugin) NormalizeScore

func (plugin *LocalPlugin) NormalizeScore(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, scores framework.NodeScoreList) *framework.Status

NormalizeScore invoked after scoring all nodes.

func (*LocalPlugin) Score

func (plugin *LocalPlugin) Score(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, nodeName string) (int64, *framework.Status)

func (*LocalPlugin) ScoreExtensions

func (plugin *LocalPlugin) ScoreExtensions() framework.ScoreExtensions

ScoreExtensions of the Score plugin.

type SimonPlugin

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

SimonPlugin is a plugin for scheduling framework

func (*SimonPlugin) Bind

func (plugin *SimonPlugin) Bind(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, nodeName string) *framework.Status

Bind invoked at the bind extension point.

func (*SimonPlugin) BindPodToNode

func (plugin *SimonPlugin) BindPodToNode(ctx context.Context, state *framework.CycleState, p *corev1.Pod, nodeName string) *framework.Status

BindPodToNode bind pod to a node and trigger pod update event

func (*SimonPlugin) Name

func (plugin *SimonPlugin) Name() string

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

func (*SimonPlugin) NormalizeScore

func (plugin *SimonPlugin) NormalizeScore(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, scores framework.NodeScoreList) *framework.Status

NormalizeScore invoked after scoring all nodes.

func (*SimonPlugin) Score

func (plugin *SimonPlugin) Score(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, nodeName string) (int64, *framework.Status)

Score invoked at the score extension point.

func (*SimonPlugin) ScoreExtensions

func (plugin *SimonPlugin) ScoreExtensions() framework.ScoreExtensions

ScoreExtensions of the Score plugin.