resourceutil

May 3, 2024

Changes in this version

+ func GetObservedGeneration(rr *unstructured.Unstructured) int64

Apr 16, 2024

Changes in this version

+ func GenerateObjectName(name string) string

+ func GetAllWorksForResource(k8sClient client.Client, namespace, promiseName, resourceName string) ([]v1alpha1.Work, error)

+ func GetStatus(rr *unstructured.Unstructured, key string) string

+ func GetWorkForPromisePipeline(k8sClient client.Client, namespace, promiseName, pipelineName string) (*v1alpha1.Work, error)

+ func GetWorkForResourcePipeline(k8sClient client.Client, ...) (*v1alpha1.Work, error)

+ func GetWorkForStaticDependencies(k8sClient client.Client, namespace, promiseName string) (*v1alpha1.Work, error)

+ func GetWorksByType(k8sClient client.Client, workflowType v1alpha1.Type, ...) ([]v1alpha1.Work, error)

+ func SetPromiseWorkLabels(l map[string]string, promiseName, pipelineName string)

+ func SetResourceWorkLabels(l map[string]string, promiseName, resourceName, pipelineName string)

+ func SetStaticDependencyWorkLabels(l map[string]string, promiseName string)

Feb 9, 2024

Changes in this version

+ func SortJobsByCreationDateTime(jobs []batchv1.Job) []batchv1.Job

Dec 20, 2023

Changes in this version

+ func IsPromiseMarkedAsUnavailable(obj *unstructured.Unstructured) bool

+ func MarkPromiseConditionAsAvailable(obj *unstructured.Unstructured, logger logr.Logger)

+ func MarkPromiseConditionAsNotAvailable(obj *unstructured.Unstructured, logger logr.Logger)

Oct 5, 2023

Changes in this version

+ const ManualReconciliationLabel

+ const PipelineCompletedCondition

+ func DoesNotContainFinalizer(resource client.Object, finalizer string) bool

+ func FinalizersAreDeleted(resource client.Object, finalizers []string) bool

+ func FinalizersAreMissing(resource client.Object, finalizers []string) bool

+ func GetCondition(obj *unstructured.Unstructured, conditionType clusterv1.ConditionType) *clusterv1.Condition

+ func GetPipelineCompletedConditionStatus(obj *unstructured.Unstructured) v1.ConditionStatus

+ func GetResourceNames(items []unstructured.Unstructured) []string

+ func HasCondition(obj *unstructured.Unstructured, conditionType clusterv1.ConditionType) bool

+ func IsThereAPipelineRunning(logger logr.Logger, jobs []batchv1.Job) bool

+ func MarkPipelineAsCompleted(logger logr.Logger, obj *unstructured.Unstructured)

+ func MarkPipelineAsRunning(logger logr.Logger, obj *unstructured.Unstructured)

+ func PipelineWithDesiredSpecExists(logger logr.Logger, obj *unstructured.Unstructured, jobs []batchv1.Job) (*batchv1.Job, error)

+ func SetCondition(obj *unstructured.Unstructured, condition *clusterv1.Condition)

+ func SetStatus(rr *unstructured.Unstructured, logger logr.Logger, statuses ...string)

+ func SuspendablePipelines(logger logr.Logger, jobs []batchv1.Job) []batchv1.Job