utils

Documentation

Index

• func EnsureComponentStatusInitialized(aw *workloadv1beta2.AppWrapper) error
• func ExpectedPodCount(aw *workloadv1beta2.AppWrapper) (int32, 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) ([]workloadv1beta2.AppWrapperPodSet, error)
• func Replicas(ps workloadv1beta2.AppWrapperPodSet) int32
• func SanitizeLabel(label string) string
• func ValidatePodSets(declared []workloadv1beta2.AppWrapperPodSet, ...) error

Functions

func EnsureComponentStatusInitialized

func EnsureComponentStatusInitialized(aw *workloadv1beta2.AppWrapper) error

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

func ExpectedPodCount

func ExpectedPodCount(aw *workloadv1beta2.AppWrapper) (int32, 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) ([]workloadv1beta2.AppWrapperPodSet, error)

InferPodSets infers PodSets for known GVKs

func Replicas

func Replicas(ps workloadv1beta2.AppWrapperPodSet) int32

func SanitizeLabel

func SanitizeLabel(label string) string

SanitizeLabel sanitizes a string for use as a label

func ValidatePodSets

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

ValidatePodSets validates the declared and inferred PodSets