preemption

Documentation

Index

• type Preemptor
  • func New(cl client.Client, workloadOrdering workload.Ordering, ...) *Preemptor
  • func (p *Preemptor) GetTargets(log logr.Logger, wl workload.Info, assignment flavorassigner.Assignment, ...) []*workload.Info
  • func (p *Preemptor) IssuePreemptions(ctx context.Context, preemptor *workload.Info, targets []*workload.Info, ...) (int, error)
  • func (p *Preemptor) OverrideApply(f func(context.Context, *kueue.Workload, string, string) error)

Types

type Preemptor

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

func New

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

func (*Preemptor) GetTargets

func (p *Preemptor) GetTargets(log logr.Logger, 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

func (p *Preemptor) IssuePreemptions(ctx context.Context, preemptor *workload.Info, 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, string, string) error)