preemption

package
v0.6.2 Latest Latest
Warning

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

Go to latest
Published: Apr 10, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Preemptor

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

func New

func New(cl client.Client, workloadOrdering workload.Ordering, recorder record.EventRecorder) *Preemptor

func (*Preemptor) GetTargets added in v0.4.0

func (p *Preemptor) GetTargets(wl workload.Info, assignment flavorassigner.Assignment, snapshot *cache.Snapshot) []*workload.Info

GetTargets returns the list of workloads that should be evicted in order to make room for wl.

func (*Preemptor) IssuePreemptions added in v0.4.0

func (p *Preemptor) IssuePreemptions(ctx context.Context, targets []*workload.Info, cq *cache.ClusterQueue) (int, error)

IssuePreemptions marks the target workloads as evicted.

func (*Preemptor) OverrideApply

func (p *Preemptor) OverrideApply(f func(context.Context, *kueue.Workload) error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL