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 GetInitImage(ctx context.Context, cr *api.PerconaXtraDBCluster, cli client.Client) (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 PauseCluster(ctx context.Context, cl client.Client, cr *api.PerconaXtraDBCluster) (bool, error)
• func PauseClusterWithWait(ctx context.Context, cl client.Client, cr *api.PerconaXtraDBCluster, ...) error
• func SetControllerReference(owner runtime.Object, obj metav1.Object, scheme *runtime.Scheme) error
• func StartStopSignalHandler(client client.Client, namespaces []string) context.Context
• func UnpauseCluster(ctx context.Context, cl client.Client, cr *api.PerconaXtraDBCluster) (bool, error)
• func UnpauseClusterWithWait(ctx context.Context, cl client.Client, cr *api.PerconaXtraDBCluster) (err error)

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 GetInitImage

func GetInitImage(ctx context.Context, cr *api.PerconaXtraDBCluster, cli client.Client) (string, error)

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 PauseCluster

func PauseCluster(ctx context.Context, cl client.Client, cr *api.PerconaXtraDBCluster) (bool, error)

func PauseClusterWithWait

func PauseClusterWithWait(ctx context.Context, cl client.Client, cr *api.PerconaXtraDBCluster, deletePVC bool) error

Deprecated: PauseClusterWithWait is a function which blocks reconcile process. Use PauseCluster instead

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.

func UnpauseCluster

func UnpauseCluster(ctx context.Context, cl client.Client, cr *api.PerconaXtraDBCluster) (bool, error)

func UnpauseClusterWithWait

func UnpauseClusterWithWait(ctx context.Context, cl client.Client, cr *api.PerconaXtraDBCluster) (err error)

Deprecated: UnpauseClusterWithWait is a function which blocks reconcile process. Use UnpauseCluster instead