workload

Documentation

Index

• func FindConditionIndex(status *kueue.WorkloadStatus, conditionType string) int
• func InCondition(w *kueue.Workload, condition string) bool
• func Key(w *kueue.Workload) string
• func QueueKey(w *kueue.Workload) string
• func ResourceQuantity(name corev1.ResourceName, v int64) resource.Quantity
• func ResourceValue(name corev1.ResourceName, q resource.Quantity) int64
• func UpdateStatus(ctx context.Context, c client.Client, wl *kueue.Workload, conditionType string, ...) error
• func UpdateStatusIfChanged(ctx context.Context, c client.Client, wl *kueue.Workload, conditionType string, ...) error
• type Info
  • func NewInfo(w *kueue.Workload) *Info
  • func (i *Info) Update(wl *kueue.Workload)
• type PodSetResources
• type Requests

Functions

func FindConditionIndex

func FindConditionIndex(status *kueue.WorkloadStatus, conditionType string) int

FindConditionIndex finds the provided condition from the given status and returns the index. Returns -1 if the condition is not present.

func InCondition

func InCondition(w *kueue.Workload, condition string) bool

func Key

func Key(w *kueue.Workload) string

func QueueKey

func QueueKey(w *kueue.Workload) string

func ResourceQuantity

func ResourceQuantity(name corev1.ResourceName, v int64) resource.Quantity

func ResourceValue

func ResourceValue(name corev1.ResourceName, q resource.Quantity) int64

ResourceValue returns the integer value for the resource name. It's milli-units for CPU and absolute units for everything else.

func UpdateStatus

func UpdateStatus(ctx context.Context,
	c client.Client,
	wl *kueue.Workload,
	conditionType string,
	conditionStatus metav1.ConditionStatus,
	reason, message string) error

UpdateStatus updates the condition of a workload.

func UpdateStatusIfChanged

func UpdateStatusIfChanged(ctx context.Context,
	c client.Client,
	wl *kueue.Workload,
	conditionType string,
	conditionStatus metav1.ConditionStatus,
	reason, message string) error

Types

type Info

type Info struct {
	Obj *kueue.Workload
	// list of total resources requested by the podsets.
	TotalRequests []PodSetResources
	// Populated from the queue during admission or from the admission field if
	// already admitted.
	ClusterQueue string
}

Info holds a Workload object and some pre-processing.

func NewInfo

func NewInfo(w *kueue.Workload) *Info

func (*Info) Update

func (i *Info) Update(wl *kueue.Workload)

type PodSetResources

type PodSetResources struct {
	Name     string
	Requests Requests
	Flavors  map[corev1.ResourceName]string
}

type Requests

type Requests map[corev1.ResourceName]int64

Requests maps ResourceName to flavor to value; for CPU it is tracked in MilliCPU.