utils

package

v0.0.0-...-78176ad Latest Latest Go to latest Published: Dec 19, 2024 License: Apache-2.0 Imports: 25 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/nagare-media/engine

Documentation ¶

Index ¶

Variables
func DeleteCondition(conditions []enginev1.Condition, t enginev1.ConditionType) []enginev1.Condition
func EnsureOwnerRef(ownerReferences []metav1.OwnerReference, ref metav1.OwnerReference) []metav1.OwnerReference
func FullPatch(ctx context.Context, c client.Client, obj, oldObj client.Object) (bool, error)
func FullServerSideApply(ctx context.Context, c client.Client, obj client.Object, manager string) error
func GenerateName(base string) string
func GetAnnotatedObject(ctx context.Context, c client.Client, obj client.Object, ...) (client.Object, error)
func HasChangesIn(obj client.Object, patch client.Patch, keys []string) (bool, error)
func IsInDeletion[T interface{ ... }](obj T) bool
func JobHasTerminated(job *batchv1.Job) bool
func JobIsActive(job *batchv1.Job) bool
func JobWasSuccessful(job *batchv1.Job) bool
func LocalFunctionToObjectRef(lref *meta.LocalObjectReference, namespace string) (*meta.ObjectReference, error)
func LocalMediaProcessingEntityToObjectRef(lref *meta.LocalObjectReference, namespace string) (*meta.ObjectReference, error)
func MarkCondition(conditions []enginev1.Condition, t enginev1.ConditionType, ...) []enginev1.Condition
func MarkConditionFalse(conditions []enginev1.Condition, t enginev1.ConditionType) []enginev1.Condition
func MarkConditionTrue(conditions []enginev1.Condition, t enginev1.ConditionType) []enginev1.Condition
func MarkConditionUnknown(conditions []enginev1.Condition, t enginev1.ConditionType) []enginev1.Condition
func NormalizeExactRef(s *runtime.Scheme, ref *meta.ExactObjectReference, obj client.Object) error
func NormalizeFunctionRef(s *runtime.Scheme, ref *meta.ObjectReference) error
func NormalizeLocalFunctionRef(s *runtime.Scheme, ref *meta.LocalObjectReference) error
func NormalizeLocalMediaProcessingEntityRef(s *runtime.Scheme, ref *meta.LocalObjectReference) error
func NormalizeLocalRef(s *runtime.Scheme, ref *meta.LocalObjectReference, obj client.Object) error
func NormalizeLocalTaskTemplateRef(s *runtime.Scheme, ref *meta.LocalObjectReference) error
func NormalizeMediaProcessingEntityRef(s *runtime.Scheme, ref *meta.ObjectReference) error
func NormalizeRef(s *runtime.Scheme, ref *meta.ObjectReference, obj client.Object) error
func NormalizeTaskTemplateRef(s *runtime.Scheme, ref *meta.ObjectReference) error
func PartiallyResolveLocalRef(c client.Client, namespace string, ref *meta.LocalObjectReference) (client.Object, error)
func PartiallyResolveRef(c client.Client, ref *meta.ObjectReference) (client.Object, error)
func Patch(ctx context.Context, c client.Client, obj, oldObj client.Object) (bool, error)
func PatchStatus(ctx context.Context, c client.Client, obj, oldObj client.Object) (bool, error)
func ResolveConfigMapOrSecretRefInline(ctx context.Context, c client.Client, ref *meta.ConfigMapOrSecretReference) error
func ResolveConfigMapRefInline(ctx context.Context, c client.Client, ref *meta.ConfigMapOrSecretReference) error
func ResolveExactRef(ctx context.Context, c client.Client, ref *meta.ExactObjectReference) (client.Object, error)
func ResolveLocalRef(ctx context.Context, c client.Client, namespace string, ...) (client.Object, error)
func ResolveRef(ctx context.Context, c client.Client, ref *meta.ObjectReference) (client.Object, error)
func ResolveSecretRefInline(ctx context.Context, c client.Client, ref *meta.ConfigMapOrSecretReference) error
func SelectFunctionRef(ctx context.Context, c client.Client, namespace string, sel labels.Selector) (*meta.ObjectReference, error)
func SelectMediaProcessingEntityRef(ctx context.Context, c client.Client, namespace string, sel labels.Selector) (*meta.ObjectReference, error)
func ServerSideApply(ctx context.Context, c client.Client, obj client.Object, manager string) error
func ServerSideApplyStatus(ctx context.Context, c client.Client, obj client.Object, manager string) error
func SetCondition(conditions []enginev1.Condition, cNew enginev1.Condition) []enginev1.Condition
func StrategicMergeList[T any](dest *T, objs ...*T) error
func TaskHasTerminated(task *enginev1.Task) bool
func TaskIsActive(task *enginev1.Task) bool
func ToExactRef(obj client.Object) *meta.ExactObjectReference
func ToLocalRef(obj client.Object) *meta.LocalObjectReference
func ToRef(obj client.Object) *meta.ObjectReference
func WorkflowHasTerminated(wf *enginev1.Workflow) bool
func WorkflowIsActive(wf *enginev1.Workflow) bool

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrSelectedMultiple = errors.New("selection returned multiple items")
)

Functions ¶

func DeleteCondition ¶

func DeleteCondition(conditions []enginev1.Condition, t enginev1.ConditionType) []enginev1.Condition

func EnsureOwnerRef ¶

func EnsureOwnerRef(ownerReferences []metav1.OwnerReference, ref metav1.OwnerReference) []metav1.OwnerReference

EnsureOwnerRef makes sure the slice contains the OwnerReference.

func FullPatch ¶

func FullPatch(ctx context.Context, c client.Client, obj, oldObj client.Object) (bool, error)

func FullServerSideApply ¶

func FullServerSideApply(ctx context.Context, c client.Client, obj client.Object, manager string) error

func GenerateName ¶

func GenerateName(base string) string

func GetAnnotatedObject ¶

func GetAnnotatedObject(ctx context.Context, c client.Client, obj client.Object, annotationKey, annotationVal string, opts ...client.ListOption) (client.Object, error)

func HasChangesIn ¶

func HasChangesIn(obj client.Object, patch client.Patch, keys []string) (bool, error)

func IsInDeletion ¶

func IsInDeletion[T interface{ GetDeletionTimestamp() *metav1.Time }](obj T) bool

func JobHasTerminated ¶

func JobHasTerminated(job *batchv1.Job) bool

func JobIsActive ¶

func JobIsActive(job *batchv1.Job) bool

func JobWasSuccessful ¶

func JobWasSuccessful(job *batchv1.Job) bool

func LocalFunctionToObjectRef ¶

func LocalFunctionToObjectRef(lref *meta.LocalObjectReference, namespace string) (*meta.ObjectReference, error)

func LocalMediaProcessingEntityToObjectRef ¶

func LocalMediaProcessingEntityToObjectRef(lref *meta.LocalObjectReference, namespace string) (*meta.ObjectReference, error)

func MarkCondition ¶

func MarkCondition(conditions []enginev1.Condition, t enginev1.ConditionType, s corev1.ConditionStatus) []enginev1.Condition

func MarkConditionFalse ¶

func MarkConditionFalse(conditions []enginev1.Condition, t enginev1.ConditionType) []enginev1.Condition

func MarkConditionTrue ¶

func MarkConditionTrue(conditions []enginev1.Condition, t enginev1.ConditionType) []enginev1.Condition

func MarkConditionUnknown ¶

func MarkConditionUnknown(conditions []enginev1.Condition, t enginev1.ConditionType) []enginev1.Condition

func NormalizeExactRef ¶

func NormalizeExactRef(s *runtime.Scheme, ref *meta.ExactObjectReference, obj client.Object) error

func NormalizeFunctionRef ¶

func NormalizeFunctionRef(s *runtime.Scheme, ref *meta.ObjectReference) error

func NormalizeLocalFunctionRef ¶

func NormalizeLocalFunctionRef(s *runtime.Scheme, ref *meta.LocalObjectReference) error

func NormalizeLocalMediaProcessingEntityRef ¶

func NormalizeLocalMediaProcessingEntityRef(s *runtime.Scheme, ref *meta.LocalObjectReference) error

func NormalizeLocalRef ¶

func NormalizeLocalRef(s *runtime.Scheme, ref *meta.LocalObjectReference, obj client.Object) error

func NormalizeLocalTaskTemplateRef ¶

func NormalizeLocalTaskTemplateRef(s *runtime.Scheme, ref *meta.LocalObjectReference) error

func NormalizeMediaProcessingEntityRef ¶

func NormalizeMediaProcessingEntityRef(s *runtime.Scheme, ref *meta.ObjectReference) error

func NormalizeRef ¶

func NormalizeRef(s *runtime.Scheme, ref *meta.ObjectReference, obj client.Object) error

func NormalizeTaskTemplateRef ¶

func NormalizeTaskTemplateRef(s *runtime.Scheme, ref *meta.ObjectReference) error

func PartiallyResolveLocalRef ¶

func PartiallyResolveLocalRef(c client.Client, namespace string, ref *meta.LocalObjectReference) (client.Object, error)

func PartiallyResolveRef ¶

func PartiallyResolveRef(c client.Client, ref *meta.ObjectReference) (client.Object, error)

func Patch ¶

func Patch(ctx context.Context, c client.Client, obj, oldObj client.Object) (bool, error)

func PatchStatus ¶

func PatchStatus(ctx context.Context, c client.Client, obj, oldObj client.Object) (bool, error)

func ResolveConfigMapOrSecretRefInline ¶

func ResolveConfigMapOrSecretRefInline(ctx context.Context, c client.Client, ref *meta.ConfigMapOrSecretReference) error

func ResolveConfigMapRefInline ¶

func ResolveConfigMapRefInline(ctx context.Context, c client.Client, ref *meta.ConfigMapOrSecretReference) error

func ResolveExactRef ¶

func ResolveExactRef(ctx context.Context, c client.Client, ref *meta.ExactObjectReference) (client.Object, error)

func ResolveLocalRef ¶

func ResolveLocalRef(ctx context.Context, c client.Client, namespace string, ref *meta.LocalObjectReference) (client.Object, error)

func ResolveRef ¶

func ResolveRef(ctx context.Context, c client.Client, ref *meta.ObjectReference) (client.Object, error)

func ResolveSecretRefInline ¶

func ResolveSecretRefInline(ctx context.Context, c client.Client, ref *meta.ConfigMapOrSecretReference) error

func SelectFunctionRef ¶

func SelectFunctionRef(ctx context.Context, c client.Client, namespace string, sel labels.Selector) (*meta.ObjectReference, error)

func SelectMediaProcessingEntityRef ¶

func SelectMediaProcessingEntityRef(ctx context.Context, c client.Client, namespace string, sel labels.Selector) (*meta.ObjectReference, error)

func ServerSideApply ¶

func ServerSideApply(ctx context.Context, c client.Client, obj client.Object, manager string) error

func ServerSideApplyStatus ¶

func ServerSideApplyStatus(ctx context.Context, c client.Client, obj client.Object, manager string) error

func SetCondition ¶

func SetCondition(conditions []enginev1.Condition, cNew enginev1.Condition) []enginev1.Condition

func StrategicMergeList ¶

func StrategicMergeList[T any](dest *T, objs ...*T) error

func TaskHasTerminated ¶

func TaskHasTerminated(task *enginev1.Task) bool

func TaskIsActive ¶

func TaskIsActive(task *enginev1.Task) bool

func ToExactRef ¶

func ToExactRef(obj client.Object) *meta.ExactObjectReference

func ToLocalRef ¶

func ToLocalRef(obj client.Object) *meta.LocalObjectReference

func ToRef ¶

func ToRef(obj client.Object) *meta.ObjectReference

func WorkflowHasTerminated ¶

func WorkflowHasTerminated(wf *enginev1.Workflow) bool

func WorkflowIsActive ¶

func WorkflowIsActive(wf *enginev1.Workflow) bool

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