utils

Documentation

Index

• Constants
• func ClearPodSetInfos(aw *awv1beta2.AppWrapper) bool
• func EnsureComponentStatusInitialized(aw *awv1beta2.AppWrapper) error
• func ExpectedPodCount(aw *awv1beta2.AppWrapper) (int32, error)
• func GetComponentPodSpecs(aw *awv1beta2.AppWrapper) ([]*v1.PodTemplateSpec, []awv1beta2.AppWrapperPodSet, error)
• func GetPodTemplateSpec(obj *unstructured.Unstructured, path string) (*v1.PodTemplateSpec, error)
• func GetRawTemplate(obj map[string]interface{}, path string) (map[string]interface{}, error)
• func GetReplicas(obj *unstructured.Unstructured, path string) (int32, error)
• func InferPodSets(obj *unstructured.Unstructured) ([]awv1beta2.AppWrapperPodSet, error)
• func Replicas(ps awv1beta2.AppWrapperPodSet) int32
• func SanitizeLabel(label string) string
• func SetPodSetInfos(aw *awv1beta2.AppWrapper, podSetsInfo []awv1beta2.AppWrapperPodSetInfo) error
• func ValidatePodSets(declared []awv1beta2.AppWrapperPodSet, inferred []awv1beta2.AppWrapperPodSet) error

Constants

const (
	PodSetAnnotationTASPodIndexLabel      = "workload.codeflare.dev.appwrapper/tas-pod-index-label"
	PodSetAnnotationTASSubGroupIndexLabel = "workload.codeflare.dev.appwrapper/tas-sub-group-index-label"
	PodSetAnnotationTASSubGroupCount      = "workload.codeflare.dev.appwrapper/tas-sub-group-count"
)

Functions

func ClearPodSetInfos

func ClearPodSetInfos(aw *awv1beta2.AppWrapper) bool

ClearPodSetInfos clears the PodSetInfos saved by SetPodSetInfos

func EnsureComponentStatusInitialized

func EnsureComponentStatusInitialized(aw *awv1beta2.AppWrapper) error

EnsureComponentStatusInitialized initializes aw.Status.ComponenetStatus, including performing PodSet inference for known GVKs

func ExpectedPodCount

func ExpectedPodCount(aw *awv1beta2.AppWrapper) (int32, error)

func GetComponentPodSpecs

func GetComponentPodSpecs(aw *awv1beta2.AppWrapper) ([]*v1.PodTemplateSpec, []awv1beta2.AppWrapperPodSet, error)

func GetPodTemplateSpec

func GetPodTemplateSpec(obj *unstructured.Unstructured, path string) (*v1.PodTemplateSpec, error)

GetPodTemplateSpec extracts a Kueue-compatible PodTemplateSpec at the given path within obj

func GetRawTemplate

func GetRawTemplate(obj map[string]interface{}, path string) (map[string]interface{}, error)

return the subobject found at the given path, or nil if the path is invalid

func GetReplicas

func GetReplicas(obj *unstructured.Unstructured, path string) (int32, error)

GetReplicas parses the value at the given path within obj as an int

func InferPodSets

func InferPodSets(obj *unstructured.Unstructured) ([]awv1beta2.AppWrapperPodSet, error)

InferPodSets infers PodSets for known GVKs

func Replicas

func Replicas(ps awv1beta2.AppWrapperPodSet) int32

func SanitizeLabel

func SanitizeLabel(label string) string

SanitizeLabel sanitizes a string for use as a label

func SetPodSetInfos

func SetPodSetInfos(aw *awv1beta2.AppWrapper, podSetsInfo []awv1beta2.AppWrapperPodSetInfo) error

SetPodSetInfos propagates podSetsInfo into the PodSetInfos of aw.Spec.Components

func ValidatePodSets

func ValidatePodSets(declared []awv1beta2.AppWrapperPodSet, inferred []awv1beta2.AppWrapperPodSet) error

ValidatePodSets validates the declared and inferred PodSets