resourceutil

package

v0.68.0 Latest Latest Go to latest Published: Apr 20, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/syntasso/kratix

Links

Open Source Insights

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 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 ...string)
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 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 GenerateObjectName ¶ added in v0.67.0

func GenerateObjectName(name string) string

func GetAllWorksForResource ¶ added in v0.67.0

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

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 GetStatus ¶ added in v0.67.0

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

func GetWorkForPromisePipeline ¶ added in v0.67.0

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

func GetWorkForResourcePipeline ¶ added in v0.67.0

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

func GetWorkForStaticDependencies ¶ added in v0.67.0

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

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 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 ¶ 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 SetPromiseWorkLabels(l map[string]string, promiseName, pipelineName string)

func SetResourceWorkLabels ¶ added in v0.67.0

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

func SetStaticDependencyWorkLabels ¶ added in v0.67.0

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

func SetStatus ¶

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

func SortJobsByCreationDateTime ¶ added in v0.44.0

func SortJobsByCreationDateTime(jobs []batchv1.Job, desc bool) []batchv1.Job

func SuspendablePipelines ¶

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

If a job has no active pods we can suspend it

Types ¶

This section is empty.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL