k8s

func AcquireLease ¶

func AcquireLease(ctx context.Context, cl client.Client, leaseName, holder, namespace string, checkStale IsHolderStaleFunc) error

AcquireLease attempts to acquire a named lease for the given holder. If isHolderStale is non-nil and the lease is held by a different holder, the callback is invoked to determine whether the current holder is stale. A stale holder is evicted atomically and the lease is granted to the new holder.

func GetLatestBackup ¶

func GetLatestBackup(ctx context.Context, cli client.Client, cr *pgv2.PerconaPGCluster) (*pgv2.PerconaPGBackup, error)

func GetLease ¶

func GetLease(ctx context.Context, client client.Client, leaseName, namespace string) (*coordinationv1.Lease, 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 GroupExists ¶

func GroupExists(dc *discovery.DiscoveryClient, group string) (bool, error)

GroupExists checks whether a given API group exists in the Kubernetes API Server.

func GroupVersionKindExists ¶

func GroupVersionKindExists(dc *discovery.DiscoveryClient, groupVersion, kind string) (bool, error)

GroupVersionKindExists checks to see whether a given Kind for a given GroupVersion exists in the Kubernetes API Server.

func InitContainer ¶

func InitContainer(cluster *v1beta1.PostgresCluster, componentName, image string,
	pullPolicy corev1.PullPolicy,
	secCtx *corev1.SecurityContext,
	resources corev1.ResourceRequirements,
	component ComponentWithInit,
) corev1.Container

func InitImage ¶

func InitImage(ctx context.Context, cl client.Reader, cluster *v1beta1.PostgresCluster, componentWithInit ComponentWithInit) (string, error)

func ObjectHash ¶

func ObjectHash(obj runtime.Object) (string, error)

func ReleaseLease ¶

func ReleaseLease(ctx context.Context, cl client.Client, leaseName, holder, namespace string) error

ReleaseLease deletes the lease only if it is still held by the given holder. UID and ResourceVersion preconditions prevent accidentally deleting a lease that was re-created by a concurrent acquirer between the Get and Delete.