plugin

package
v0.1.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 28, 2022 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewGpuSharePlugin added in v0.1.1 

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 added in v0.1.1 

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

GpuSharePlugin is a plugin for scheduling framework

func (*GpuSharePlugin) Bind added in v0.1.1 

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 added in v0.1.1 

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

func (*GpuSharePlugin) Filter added in v0.1.1 

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 added in v0.1.1 

func (plugin *GpuSharePlugin) InitSchedulerCache()

func (*GpuSharePlugin) MakePodCopyReadyForBindUpdate added in v0.1.1 

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

func (*GpuSharePlugin) Name added in v0.1.1 

func (plugin *GpuSharePlugin) Name() string

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

func (*GpuSharePlugin) NodeGet added in v0.1.1 

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

func (*GpuSharePlugin) NormalizeScore added in v0.1.1 

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 added in v0.1.1 

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

func (*GpuSharePlugin) Reserve added in v0.1.1 

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 added in v0.1.1 

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 added in v0.1.1 

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

ScoreExtensions of the Score plugin.

func (*GpuSharePlugin) Unreserve added in v0.1.1 

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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.