Documentation
¶
Index ¶
- Constants
- 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 GenerateObjectName(name string) string
- func GetAllWorksForResource(k8sClient client.Client, namespace, promiseName, resourceName string) ([]v1alpha1.Work, error)
- func GetCondition(obj *unstructured.Unstructured, conditionType clusterv1.ConditionType) *clusterv1.Condition
- func GetObservedGeneration(rr *unstructured.Unstructured) int64
- func GetPipelineCompletedConditionStatus(obj *unstructured.Unstructured) v1.ConditionStatus
- func GetResourceNames(items []unstructured.Unstructured) []string
- 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 HasCondition(obj *unstructured.Unstructured, conditionType clusterv1.ConditionType) bool
- func IsPromiseMarkedAsUnavailable(obj *unstructured.Unstructured) 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 MarkPromiseConditionAsAvailable(obj *unstructured.Unstructured, logger logr.Logger)
- func MarkPromiseConditionAsNotAvailable(obj *unstructured.Unstructured, logger logr.Logger)
- func PipelineWithDesiredSpecExists(logger logr.Logger, obj *unstructured.Unstructured, jobs []batchv1.Job) (*batchv1.Job, error)
- func SetCondition(obj *unstructured.Unstructured, condition *clusterv1.Condition)
- 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)
- func SetStatus(rr *unstructured.Unstructured, logger logr.Logger, statuses ...interface{})
- func SortJobsByCreationDateTime(jobs []batchv1.Job, desc bool) []batchv1.Job
- func SuspendablePipelines(logger logr.Logger, jobs []batchv1.Job) []batchv1.Job
Constants ¶
View Source
const ( PipelineCompletedCondition = clusterv1.ConditionType("PipelineCompleted") ManualReconciliationLabel = "kratix.io/manual-reconciliation" )
Variables ¶
This section is empty.
Functions ¶
func DoesNotContainFinalizer ¶
func FinalizersAreDeleted ¶
func FinalizersAreMissing ¶
func GenerateObjectName ¶ added in v0.67.0
func GetAllWorksForResource ¶ added in v0.67.0
func GetCondition ¶
func GetCondition(obj *unstructured.Unstructured, conditionType clusterv1.ConditionType) *clusterv1.Condition
func GetObservedGeneration ¶ added in v0.76.0
func GetObservedGeneration(rr *unstructured.Unstructured) int64
GetObservedGeneration returns 0 when either status or status.observedGeneration is nil
func GetPipelineCompletedConditionStatus ¶
func GetPipelineCompletedConditionStatus(obj *unstructured.Unstructured) v1.ConditionStatus
func GetResourceNames ¶
func GetResourceNames(items []unstructured.Unstructured) []string
func GetStatus ¶ added in v0.67.0
func GetStatus(rr *unstructured.Unstructured, key string) string
func GetWorkForPromisePipeline ¶ added in v0.67.0
func GetWorkForResourcePipeline ¶ added in v0.67.0
func GetWorkForStaticDependencies ¶ added in v0.67.0
func GetWorksByType ¶ added in v0.67.0
func GetWorksByType(k8sClient client.Client, workflowType v1alpha1.Type, obj *unstructured.Unstructured) ([]v1alpha1.Work, error)
func HasCondition ¶
func HasCondition(obj *unstructured.Unstructured, conditionType clusterv1.ConditionType) bool
func IsPromiseMarkedAsUnavailable ¶ added in v0.1.0
func IsPromiseMarkedAsUnavailable(obj *unstructured.Unstructured) bool
func IsThereAPipelineRunning ¶
func MarkPipelineAsCompleted ¶
func MarkPipelineAsCompleted(logger logr.Logger, obj *unstructured.Unstructured)
func MarkPipelineAsRunning ¶
func MarkPipelineAsRunning(logger logr.Logger, obj *unstructured.Unstructured)
func MarkPromiseConditionAsAvailable ¶ added in v0.1.0
func MarkPromiseConditionAsAvailable(obj *unstructured.Unstructured, logger logr.Logger)
func MarkPromiseConditionAsNotAvailable ¶ added in v0.1.0
func MarkPromiseConditionAsNotAvailable(obj *unstructured.Unstructured, logger logr.Logger)
func PipelineWithDesiredSpecExists ¶
func PipelineWithDesiredSpecExists(logger logr.Logger, obj *unstructured.Unstructured, jobs []batchv1.Job) (*batchv1.Job, error)
func SetCondition ¶
func SetCondition(obj *unstructured.Unstructured, condition *clusterv1.Condition)
func SetPromiseWorkLabels ¶ added in v0.67.0
func SetResourceWorkLabels ¶ added in v0.67.0
func SetStaticDependencyWorkLabels ¶ added in v0.67.0
func SetStatus ¶
func SetStatus(rr *unstructured.Unstructured, logger logr.Logger, statuses ...interface{})
SetStatus takes in key value pairs in the statuses argument. Example: key1, value1, key2, value2, ... All keys must be castable to string. Values can be any type.
func SortJobsByCreationDateTime ¶ added in v0.44.0
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.