k8s

package

v1.23.0 Latest Latest Go to latest Published: Jul 22, 2026 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation ¶

const WatchNamespaceEnvVar = "WATCH_NAMESPACE"

View Source

var (
	ErrNotTheHolder     = errors.New("not the holder")
	ErrLeaseAlreadyHeld = errors.New("lease held by another holder")
)

func AcquireLease(ctx context.Context, c client.Client, name, namespace, holder string, checkStale IsHolderStaleFunc) (*coordv1.Lease, error)

func AnnotateObject(ctx context.Context, c client.Client, obj client.Object, annotations map[string]string) error

AnnotateObject adds the specified annotations to the object

func DeannotateObject(ctx context.Context, c client.Client, obj client.Object, annotation string) error

DeannotateObject removes the specified annotation from the object

func DeleteIfExists(ctx context.Context, c client.Client, obj client.Object) error

func GetLease(ctx context.Context, c client.Client, name, namespace string) (*coordv1.Lease, error)

func GetOperatorNamespace() (string, error)

GetOperatorNamespace returns the namespace of the operator pod

func GetWatchNamespace() (string, error)

GetWatchNamespace returns the namespace the operator should be watching for changes

func IsLeaseActive(ctx context.Context, c client.Client, name, namespace string) (bool, error)

func IsPodReady(pod corev1.Pod) bool

func ReleaseLease(ctx context.Context, c client.Client, name, namespace, holder string) error

type IsHolderStaleFunc func(ctx context.Context, lease *coordv1.Lease) (bool, error)