controller

Documentation

Index

• Constants
• func AddSuffix(a string, arr ...string) string
• func ExportSvcLabel(meta metav1.ObjectMeta, id int) map[string]string
• func Inject(cli client.Client, scheme *runtime.Scheme, cr *v1.Etcd, log *zap.SugaredLogger, ...) *controller
• func MemberLabel(meta metav1.ObjectMeta, id int) map[string]string
• func MergeLabels(allLabels ...map[string]string) map[string]string
• type ResourceBuilder
  • func NewResourceBuilder(cr *dbv1.Etcd) *ResourceBuilder
  • func (s *ResourceBuilder) EmptyDirVolume(name string) corev1.Volume
  • func (s *ResourceBuilder) Env() []corev1.EnvVar
  • func (s *ResourceBuilder) ExportService(name string, labels, selector map[string]string) *corev1.Service
  • func (s *ResourceBuilder) HeadlessService(name string, labels, selector map[string]string) *corev1.Service
  • func (s *ResourceBuilder) PVC(name, storage string) *corev1.PersistentVolumeClaim
  • func (s *ResourceBuilder) StatefulSet(labels map[string]string) *appv1.StatefulSet

Constants

const (
	Export    = "export"
	SelectAll = -999
	SpecHash  = "etcd-operator/spec-hash"
)

const (
	PortClientName = "client"
)

Functions

func AddSuffix

func AddSuffix(a string, arr ...string) string

func ExportSvcLabel

func ExportSvcLabel(meta metav1.ObjectMeta, id int) map[string]string

func Inject

func Inject(cli client.Client, scheme *runtime.Scheme, cr *v1.Etcd, log *zap.SugaredLogger, cfg conf.Config) *controller

func MemberLabel

func MemberLabel(meta metav1.ObjectMeta, id int) map[string]string

func MergeLabels

func MergeLabels(allLabels ...map[string]string) map[string]string

MergeLabels merges all the label maps received as argument into a single new label map.

Types

type ResourceBuilder

type ResourceBuilder struct {
	// contains filtered or unexported fields
}

func NewResourceBuilder

func NewResourceBuilder(cr *dbv1.Etcd) *ResourceBuilder

func (*ResourceBuilder) EmptyDirVolume

func (s *ResourceBuilder) EmptyDirVolume(name string) corev1.Volume

func (*ResourceBuilder) Env

func (s *ResourceBuilder) Env() []corev1.EnvVar

func (*ResourceBuilder) ExportService

func (s *ResourceBuilder) ExportService(name string, labels, selector map[string]string) *corev1.Service

func (*ResourceBuilder) HeadlessService

func (s *ResourceBuilder) HeadlessService(name string, labels, selector map[string]string) *corev1.Service

func (*ResourceBuilder) PVC

func (s *ResourceBuilder) PVC(name, storage string) *corev1.PersistentVolumeClaim

func (*ResourceBuilder) StatefulSet

func (s *ResourceBuilder) StatefulSet(labels map[string]string) *appv1.StatefulSet