utils

package

v1.0.0 Latest Latest Go to latest Published: Jan 2, 2025 License: Apache-2.0 Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

func ClearPodSetInfos(aw *workloadv1beta2.AppWrapper) bool

ClearPodSetInfos clears the PodSetInfos saved by SetPodSetInfos

func EnsureComponentStatusInitialized(aw *workloadv1beta2.AppWrapper) error

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

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

func GetPodSets(aw *workloadv1beta2.AppWrapper) ([]kueue.PodSet, error)

GetPodSets constructs the kueue.PodSets for an AppWrapper

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

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

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(obj *unstructured.Unstructured, path string) (int32, error)

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

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

InferPodSets infers PodSets for known GVKs

func Replicas(ps workloadv1beta2.AppWrapperPodSet) int32

func SanitizeLabel(label string) string

SanitizeLabel sanitizes a string for use as a label

func SetPodSetInfos(aw *workloadv1beta2.AppWrapper, podSetsInfo []podset.PodSetInfo) error

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

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

ValidatePodSets validates the declared and inferred PodSets

This section is empty.