k8s

Documentation

Index

• Constants
• func AnnotateObject(ctx context.Context, c client.Client, obj client.Object, ...) error
• func DeannotateObject(ctx context.Context, c client.Client, obj client.Object, annotation string) error
• func GetOperatorNamespace() (string, error)
• func GetWatchNamespace() (string, error)
• func OperatorPod(ctx context.Context, cl client.Client) (corev1.Pod, error)
• func OwnerRef(ro runtime.Object, scheme *runtime.Scheme) (metav1.OwnerReference, error)
• func SetControllerReference(owner runtime.Object, obj metav1.Object, scheme *runtime.Scheme) error
• func StartStopSignalHandler(client client.Client, namespaces []string) context.Context

Constants

const WatchNamespaceEnvVar = "WATCH_NAMESPACE"

Functions

func AnnotateObject

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

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

DeannotateObject removes the specified annotation from the object

func GetOperatorNamespace

func GetOperatorNamespace() (string, error)

GetOperatorNamespace returns the namespace of the operator pod

func GetWatchNamespace

func GetWatchNamespace() (string, error)

GetWatchNamespace returns the namespace the operator should be watching for changes

func OperatorPod

func OperatorPod(ctx context.Context, cl client.Client) (corev1.Pod, error)

func OwnerRef

func OwnerRef(ro runtime.Object, scheme *runtime.Scheme) (metav1.OwnerReference, error)

OwnerRef returns OwnerReference to object

func SetControllerReference

func SetControllerReference(owner runtime.Object, obj metav1.Object, scheme *runtime.Scheme) error

SetControllerReference sets owner as a owner for the object obj

func StartStopSignalHandler

func StartStopSignalHandler(client client.Client, namespaces []string) context.Context

StartStopSignalHandler starts gorutine which is waiting for termination signal and returns a context which is cancelled when operator can really stop.