psmdb

May 21, 2024

Changes in this version

+ const LDAPConfVolClaimName

+ const LDAPTLSVolClaimName

+ func GetNodeLabels(ctx context.Context, cl client.Client, cr *api.PerconaServerMongoDB, ...) (map[string]string, error)

Oct 9, 2023

Changes in this version

+ func GetOutdatedRSPods(ctx context.Context, k8sclient client.Client, cr *api.PerconaServerMongoDB, ...) (corev1.PodList, error)

+ func MongosLabels(cr *api.PerconaServerMongoDB) map[string]string

+ func PodTopologySpreadConstraints(cr *api.PerconaServerMongoDB, tscs []corev1.TopologySpreadConstraint, ...) []corev1.TopologySpreadConstraint

+ func RSLabels(cr *api.PerconaServerMongoDB, rsName string) map[string]string

Mar 8, 2023

Changes in this version

+ var ErrNoIngressPoints = errors.New("ingress points not found")

+ var ErrServiceNotExists = errors.New("service doesn't exist")

Sep 14, 2022

Changes in this version

+ const BinMountPath

+ const BinVolumeName

+ const SSLDir

May 4, 2022

Changes in this version

+ func GetExportedServices(ctx context.Context, cl client.Client, cr *api.PerconaServerMongoDB) (*mcsv1alpha1.ServiceExportList, error)

+ func GetMCSAddr(m *api.PerconaServerMongoDB, pod string) string

+ func GetMongosAddrs(ctx context.Context, cl client.Client, cr *api.PerconaServerMongoDB) ([]string, error)

+ func GetMongosPods(ctx context.Context, cl client.Client, cr *api.PerconaServerMongoDB) (corev1.PodList, error)

+ func GetMongosServices(ctx context.Context, cl client.Client, cr *api.PerconaServerMongoDB) (*corev1.ServiceList, error)

+ func GetServiceMeshAddr(m *api.PerconaServerMongoDB, pod, replset string) string

+ func IsServiceImported(ctx context.Context, k8sclient client.Client, cr *api.PerconaServerMongoDB, ...) (bool, error)

+ func MongosHost(ctx context.Context, cl client.Client, cr *api.PerconaServerMongoDB, ...) (string, error)

+ func MongosStatefulset(cr *api.PerconaServerMongoDB) *appsv1.StatefulSet

+ func MongosStatefulsetSpec(cr *api.PerconaServerMongoDB, template corev1.PodTemplateSpec) appsv1.StatefulSetSpec

+ func MongosTemplateSpec(cr *api.PerconaServerMongoDB, initImage string, log logr.Logger, ...) (corev1.PodTemplateSpec, error)

+ func StandaloneClient(ctx context.Context, k8sclient client.Client, cr *api.PerconaServerMongoDB, ...) (*mgo.Client, error)

Sep 29, 2021

Changes in this version

+ func GetPrimaryPod(client *mgo.Client) (string, error)

+ func GetRSPods(k8sclient client.Client, cr *api.PerconaServerMongoDB, rsName string) (corev1.PodList, error)

+ func MongoClient(k8sclient client.Client, cr *api.PerconaServerMongoDB, rs api.ReplsetSpec, ...) (*mgo.Client, error)

+ func MongosClient(k8sclient client.Client, cr *api.PerconaServerMongoDB, c Credentials) (*mgo.Client, error)

+ type Credentials struct

+ Password string

+ Username string

+ type CustomConfig struct

+ HashHex string

+ Type VolumeSourceType

+ type HashableObject interface

+ GetHashHex func() (string, error)

+ GetRuntimeObject func() runtime.Object

Jun 28, 2021

Changes in this version

+ func MongodCustomConfigName(clusterName, replicaSetName string) string

+ func MongosCustomConfigName(clusterName string) string

+ func VolumeSourceTypeToObj(s VolumeSourceType) runtime.Object

+ type VolumeSourceType int

+ const VolumeSourceConfigMap

+ const VolumeSourceNone

+ const VolumeSourceSecret

+ func (s VolumeSourceType) IsUsable() bool

+ func (s VolumeSourceType) String() string

+ func (s VolumeSourceType) VolumeSource(name string) corev1.VolumeSource

Dec 21, 2020

Changes in this version

+ func AddPMMContainer(cr *api.PerconaServerMongoDB, usersSecretName string, pmmsec corev1.Secret, ...) (corev1.Container, error)

+ func GetAddr(m *api.PerconaServerMongoDB, pod, replset string) string

+ func InitContainers(cr *api.PerconaServerMongoDB, operatorPod corev1.Pod) []corev1.Container

+ func InternalKey(cr *api.PerconaServerMongoDB) string

+ func MongosDeployment(cr *api.PerconaServerMongoDB) *appsv1.Deployment

+ func MongosDeploymentSpec(cr *api.PerconaServerMongoDB, operatorPod corev1.Pod) (appsv1.DeploymentSpec, error)

+ func MongosService(cr *api.PerconaServerMongoDB) corev1.Service

+ func MongosServiceSpec(cr *api.PerconaServerMongoDB) corev1.ServiceSpec

+ func PMMAgentScript() []corev1.EnvVar

Sep 4, 2020

Changes in this version

+ func EntrypointInitContainer(initImageName string) corev1.Container

Mar 27, 2020

Changes in this version

+ func GetReplsetAddrs(cl client.Client, m *api.PerconaServerMongoDB, replset *api.ReplsetSpec, ...) ([]string, error)

+ func MongoHost(cl client.Client, m *api.PerconaServerMongoDB, replset *api.ReplsetSpec, ...) (string, error)

Jul 7, 2019

Changes in this version

+ const EncryptionKeyName

Jun 26, 2019

Changes in this version

+ const PMMPasswordKey

+ const PMMUserKey

Mar 18, 2019

Changes in this version

+ const MongodContainerDataDir

+ const MongodDataVolClaimName

+ func CreateResources(r *api.ResourcesSpec) (rr corev1.ResourceRequirements, err error)

+ func ExternalService(m *api.PerconaServerMongoDB, replset *api.ReplsetSpec, podName string) *corev1.Service

+ func NewStatefulSet(name, namespace string) *appsv1.StatefulSet

+ func PMMContainer(spec api.PMMSpec, secrets string) corev1.Container

+ func PersistentVolumeClaim(name, namespace string, spec *corev1.PersistentVolumeClaimSpec) corev1.PersistentVolumeClaim

+ func PodAffinity(af *api.PodAffinity, labels map[string]string) *corev1.Affinity

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

+ func Service(m *api.PerconaServerMongoDB, replset *api.ReplsetSpec) *corev1.Service

+ func StatefulSpec(m *api.PerconaServerMongoDB, replset *api.ReplsetSpec, containerName string, ...) (appsv1.StatefulSetSpec, error)

+ type ServiceAddr struct

+ Host string

+ Port int

+ func GetServiceAddr(svc corev1.Service, pod corev1.Pod, cl client.Client) (*ServiceAddr, error)

+ func (s ServiceAddr) String() string