k8s

func Always ¶ added in v0.8.0

func Always(_ unstructured.Unstructured) bool

func NewDefaultBackoff ¶ added in v0.8.0

func NewDefaultBackoff() wait.Backoff

func NewRetryingClient ¶ added in v0.8.0

func NewRetryingClient(c client.WithWatch, predicate func(error) bool, backoff wait.Backoff) client.WithWatch

func Patch ¶

func Patch[T any, PT ObjectWithDeepCopy[T]](
	ctx context.Context,
	k8sClient client.Client,
	obj PT,
	modify func(),
) error

Patch updates k8s objects by subsequently calling k8s client `Patch()` and `Status().Patch()` The `modify` lambda is expected to mutate the `obj` but does not take the object as an argument as the object should be visible in the parent scope Example:

var pod *corev1.Pod

patchErr = k8s.Patch(ctx, fakeClient, pod, func() {
	pod.Spec.RestartPolicy = corev1.RestartPolicyOnFailure
	pod.Status.Message = "hello"
})

Note that this function should be used when current user has permissions to patch both object's spec and status, e.g. in controllers context

func PatchResource ¶ added in v0.4.0

func PatchResource[T any, PT ObjectWithDeepCopy[T]](
	ctx context.Context,
	k8sClient client.Client,
	obj PT,
	modify func(),
) error

PatchResource updates k8s objects by calling k8s client `Patch`. It does not patch the object status which makes it convenient to use in contexts where the current user is not permitted to patch the status, such as within the api repositories. The `modify` lambda is expected to mutate the `obj` but does not take the object as an argument as the object should be visible in the parent scope Example:

var pod *corev1.Pod

patchErr = k8s.PatchResource(ctx, fakeClient, pod, func() {
  pod.Spec.RestartPolicy = corev1.RestartPolicyOnFailure
})

Note that this function should be used when current user has permissions to patch both object's spec and status, e.g. in controllers context