preemption

Documentation

Index

• type Preemptor
  • func New(cl client.Client, recorder record.EventRecorder) *Preemptor
  • func (p *Preemptor) GetTargets(wl workload.Info, assignment flavorassigner.Assignment, ...) []*workload.Info
  • func (p *Preemptor) IssuePreemptions(ctx context.Context, targets []*workload.Info, cq *cache.ClusterQueue) (int, error)
  • func (p *Preemptor) OverrideApply(f func(context.Context, *kueue.Workload) error)

Types

type Preemptor

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

func New

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

func (*Preemptor) GetTargets

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

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)