mig

package

v0.0.3 Latest Latest Go to latest Published: Sep 24, 2025 License: Apache-2.0 Imports: 22 Imported by: 0

Details

View Source

const Name = "MigAccelerator"

This section is empty.

func New(ctx context.Context, args runtime.Object, handle framework.Handle) (framework.Plugin, error)

New initializes a new plugin and returns it.

type Args struct {
	Namespace string `json:"namespace,omitempty"`
}

Args holds the scheduler plugin configuration.

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

Plugin implements a scheduler Filter extension for GPU allocation.

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

Filter checks if the given node has an available MIG slice for the pod.

func (p *Plugin) Name() string

Name returns the plugin name.

func (p *Plugin) PreBind(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, nodeName string) *framework.Status

PreBind finalizes AllocationClaims on the chosen node and cleans up staged claims on the other nodes.

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

Score favors nodes with the most remaining free MIG slice capacity after accounting for all AllocationClaims including those staged for this Pod.

func (p *Plugin) ScoreExtensions() framework.ScoreExtensions

ScoreExtensions returns nil as the plugin does not implement score extensions.