preemption

Documentation

Index

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

Constants

const (
	InCohortReclamationReason           string = "InCohortReclamation"
	InCohortFairSharingReason           string = "InCohortFairSharing"
	InCohortReclaimWhileBorrowingReason string = "InCohortReclaimWhileBorrowing"
)

In cohort preemption reasons

const (
	InClusterQueueReason string = "InClusterQueue"
)

In cluster queue preemption reasons

Variables

var HumanReadablePreemptionReasons = map[string]string{
	InClusterQueueReason:                "prioritization in the ClusterQueue",
	InCohortReclamationReason:           "reclamation within the cohort",
	InCohortFairSharingReason:           "fair sharing within the cohort",
	InCohortReclaimWhileBorrowingReason: "reclamation within the cohort while borrowing",
}

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) []*Target

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 []*Target) (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)

type Target

type Target struct {
	WorkloadInfo *workload.Info
	Reason       string
}