pxc

Documentation

Index

• Constants
• func MergeTemplateAnnotations(sfs *appsv1.StatefulSet, annotations map[string]string)
• func NewServiceHAProxy(cr *api.PerconaXtraDBCluster) *corev1.Service
• func NewServiceHAProxyReplicas(cr *api.PerconaXtraDBCluster) *corev1.Service
• func NewServicePXC(cr *api.PerconaXtraDBCluster) *corev1.Service
• func NewServicePXCUnready(cr *api.PerconaXtraDBCluster) *corev1.Service
• func NewServiceProxySQL(cr *api.PerconaXtraDBCluster) *corev1.Service
• func NewServiceProxySQLUnready(cr *api.PerconaXtraDBCluster) *corev1.Service
• func PodAffinity(af *api.PodAffinity, app api.App) *corev1.Affinity
• func PodDisruptionBudget(spec *api.PodDisruptionBudgetSpec, labels map[string]string, namespace string) *policyv1.PodDisruptionBudget
• func PodTopologySpreadConstraints(tscs []corev1.TopologySpreadConstraint, ls map[string]string) []corev1.TopologySpreadConstraint
• func StatefulSet(ctx context.Context, cl client.Client, sfs api.StatefulApp, ...) (*appsv1.StatefulSet, error)

Constants

const (
	// HeadlessServiceAnnotation is the annotation key for headless service
	HeadlessServiceAnnotation = "percona.com/headless-service"
)

Functions

func MergeTemplateAnnotations

func MergeTemplateAnnotations(sfs *appsv1.StatefulSet, annotations map[string]string)

func NewServiceHAProxy

func NewServiceHAProxy(cr *api.PerconaXtraDBCluster) *corev1.Service

func NewServiceHAProxyReplicas

func NewServiceHAProxyReplicas(cr *api.PerconaXtraDBCluster) *corev1.Service

func NewServicePXC

func NewServicePXC(cr *api.PerconaXtraDBCluster) *corev1.Service

func NewServicePXCUnready

func NewServicePXCUnready(cr *api.PerconaXtraDBCluster) *corev1.Service

func NewServiceProxySQL

func NewServiceProxySQL(cr *api.PerconaXtraDBCluster) *corev1.Service

func NewServiceProxySQLUnready

func NewServiceProxySQLUnready(cr *api.PerconaXtraDBCluster) *corev1.Service

func PodAffinity

func PodAffinity(af *api.PodAffinity, app api.App) *corev1.Affinity

PodAffinity returns podAffinity options for the pod

func PodDisruptionBudget

func PodDisruptionBudget(spec *api.PodDisruptionBudgetSpec, labels map[string]string, namespace string) *policyv1.PodDisruptionBudget

func PodTopologySpreadConstraints

func PodTopologySpreadConstraints(tscs []corev1.TopologySpreadConstraint, ls map[string]string) []corev1.TopologySpreadConstraint

func StatefulSet

func StatefulSet(ctx context.Context, cl client.Client, sfs api.StatefulApp, podSpec *api.PodSpec, cr *api.PerconaXtraDBCluster, secret *corev1.Secret,
	initContainers []corev1.Container, log logr.Logger, vg api.CustomVolumeGetter,
) (*appsv1.StatefulSet, error)

StatefulSet returns StatefulSet according for app to podSpec