resourceutil

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 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 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 SetStatus(rr *unstructured.Unstructured, logger logr.Logger, statuses ...string)
• func SuspendablePipelines(logger logr.Logger, jobs []batchv1.Job) []batchv1.Job

Constants

const (
	PipelineCompletedCondition = clusterv1.ConditionType("PipelineCompleted")
	ManualReconciliationLabel  = "kratix.io/manual-reconciliation"
)

Functions

func DoesNotContainFinalizer

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

func FinalizersAreDeleted

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

func FinalizersAreMissing

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

func GetCondition

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

func GetPipelineCompletedConditionStatus

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

func GetResourceNames

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

func HasCondition

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

func IsPromiseMarkedAsUnavailable

func IsPromiseMarkedAsUnavailable(obj *unstructured.Unstructured) bool

func IsThereAPipelineRunning

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

func MarkPipelineAsCompleted

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

func MarkPipelineAsRunning

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

func MarkPromiseConditionAsAvailable

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

func MarkPromiseConditionAsNotAvailable

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 SetStatus

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

func SuspendablePipelines

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

If a job has no active pods we can suspend it