k8s

package

v1.20.0 Latest Latest Go to latest Published: May 16, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation ¶

const WatchNamespaceEnvVar = "WATCH_NAMESPACE"

View Source

var (
	ErrNotTheHolder = errors.New("not the holder")
)

func AcquireLease(ctx context.Context, c client.Client, name, namespace, holder string) (*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 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 ReleaseLease(ctx context.Context, c client.Client, name, namespace, holder string) error

This section is empty.