psmdb

package

v1.4.0 Latest Latest Go to latest Published: Mar 27, 2020 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/AgentK20/percona-server-mongodb-operator

Links

Open Source Insights

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 ¶

View Source

const (

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

	EncryptionKeyName = "encryption-key"
)

View Source

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

Variables ¶

This section is empty.

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 ¶ added in v1.4.0

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 ¶ added in v1.4.0

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
backup
mongo
secret
tls

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL