preemption

Documentation

Index

• Variables
• type PreemptionOracle
  • func NewOracle(preemptor *Preemptor, snapshot *cache.Snapshot) *PreemptionOracle
  • func (p *PreemptionOracle) IsReclaimPossible(log logr.Logger, cq *cache.ClusterQueueSnapshot, wl workload.Info, ...) bool
• 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

Variables

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

Types

type PreemptionOracle

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

func NewOracle

func NewOracle(preemptor *Preemptor, snapshot *cache.Snapshot) *PreemptionOracle

func (*PreemptionOracle) IsReclaimPossible

func (p *PreemptionOracle) IsReclaimPossible(log logr.Logger, cq *cache.ClusterQueueSnapshot, wl workload.Info, fr resources.FlavorResource, quantity int64) bool

IsReclaimPossible determines if a ClusterQueue can fit this FlavorResource by reclaiming its nominal quota which it lent to its Cohort.

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,
	clock clock.Clock,
) *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
}