psmdb

Documentation

Index

• Constants
• func CreateResources(r *api.ResourcesSpec) (rr corev1.ResourceRequirements, err error)
• func ExternalService(m *api.PerconaServerMongoDB, replset *api.ReplsetSpec, podName string) *corev1.Service
• 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)
• func NewStatefulSet(name, namespace string) *appsv1.StatefulSet
• func PMMContainer(spec api.PMMSpec, secrets string, customLogin bool, clusterName 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
  • func GetServiceAddr(svc corev1.Service, pod corev1.Pod, cl client.Client) (*ServiceAddr, error)
  • func (s ServiceAddr) String() string

Constants

const (

	// MongodDataVolClaimName is a PVC Claim name
	MongodDataVolClaimName = "mongod-data"
	// MongodContainerDataDir is a mondo data path in container
	MongodContainerDataDir = "/data/db"

	EncryptionKeyName = "encryption-key"
)

const (
	PMMUserKey     = "PMM_SERVER_USER"
	PMMPasswordKey = "PMM_SERVER_PASSWORD"
)

Functions

func CreateResources

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

func ExternalService

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

ExternalService returns a Service object needs to serve external connections

func GetReplsetAddrs

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

GetReplsetAddrs returns a slice of replset host:port addresses

func MongoHost

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

MongoHost returns the mongo host for given pod

func NewStatefulSet

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

NewStatefulSet returns a StatefulSet object configured for a name

func PMMContainer

func PMMContainer(spec api.PMMSpec, secrets string, customLogin bool, clusterName string, v120OrGreater bool) corev1.Container

PMMContainer returns a pmm container from given spec

func PersistentVolumeClaim

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

PersistentVolumeClaim returns a Persistent Volume Claims for Mongod pod

func PodAffinity

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

PodAffinity returns podAffinity options for the pod

func PodDisruptionBudget

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

func Service

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

Service returns a core/v1 API Service

func StatefulSpec

func StatefulSpec(m *api.PerconaServerMongoDB, replset *api.ReplsetSpec, containerName string, ls map[string]string, multiAZ api.MultiAZ, size int32, ikeyName string) (appsv1.StatefulSetSpec, error)

StatefulSpec returns spec for stateful set TODO: Unify Arbiter and Node. Shoudn't be 100500 parameters

Types

type ServiceAddr

type ServiceAddr struct {
	Host string
	Port int
}

func GetServiceAddr

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

func (ServiceAddr) String

func (s ServiceAddr) String() string