orchestrator

Documentation

Index

• Constants
• Variables
• func APIHost(cr *apiv1alpha1.PerconaServerMySQL) string
• func AddPeerExec(ctx context.Context, cliCmd clientcmd.Client, pod *corev1.Pod, peer string) error
• func ConfigMap(cr *apiv1alpha1.PerconaServerMySQL, data map[string]string) *corev1.ConfigMap
• func ConfigMapData(cr *apiv1alpha1.PerconaServerMySQL) (map[string]string, error)
• func ConfigMapName(cr *apiv1alpha1.PerconaServerMySQL) string
• func DiscoverExec(ctx context.Context, cliCmd clientcmd.Client, pod *corev1.Pod, host string, ...) error
• func EnsureNodeIsPrimaryExec(ctx context.Context, cliCmd clientcmd.Client, pod *corev1.Pod, ...) error
• func FQDN(cr *apiv1alpha1.PerconaServerMySQL, idx int) string
• func Labels(cr *apiv1alpha1.PerconaServerMySQL) map[string]string
• func MatchLabels(cr *apiv1alpha1.PerconaServerMySQL) map[string]string
• func Name(cr *apiv1alpha1.PerconaServerMySQL) string
• func NamespacedName(cr *apiv1alpha1.PerconaServerMySQL) types.NamespacedName
• func PodName(cr *apiv1alpha1.PerconaServerMySQL, idx int) string
• func PodService(cr *apiv1alpha1.PerconaServerMySQL, t corev1.ServiceType, podName string) *corev1.Service
• func RaftNodes(cr *apiv1alpha1.PerconaServerMySQL) []string
• func RemovePeerExec(ctx context.Context, cliCmd clientcmd.Client, pod *corev1.Pod, peer string) error
• func Service(cr *apiv1alpha1.PerconaServerMySQL) *corev1.Service
• func ServiceName(cr *apiv1alpha1.PerconaServerMySQL) string
• func SetWriteableExec(ctx context.Context, cliCmd clientcmd.Client, pod *corev1.Pod, host string, ...) error
• func StartReplicationExec(ctx context.Context, cliCmd clientcmd.Client, pod *corev1.Pod, host string, ...) error
• func StatefulSet(cr *apiv1alpha1.PerconaServerMySQL, initImage, tlsHash string) *appsv1.StatefulSet
• func StopReplicationExec(ctx context.Context, cliCmd clientcmd.Client, pod *corev1.Pod, host string, ...) error
• type Exposer
  • func (e *Exposer) Exposed() bool
  • func (e *Exposer) Labels() map[string]string
  • func (e *Exposer) Name(index string) string
  • func (e *Exposer) SaveOldMeta() bool
  • func (e *Exposer) Service(name string) *corev1.Service
  • func (e *Exposer) Size() int32
• type Instance
  • func ClusterPrimaryExec(ctx context.Context, cliCmd clientcmd.Client, pod *corev1.Pod, ...) (*Instance, error)
• type InstanceKey

Constants

const (
	ComponentName = "orc"

	ConfigFileName = "orchestrator.conf.json"

	CredsMountPath = "/etc/orchestrator/orchestrator-users-secret"
)

Variables

var ErrEmptyResponse = errors.New("empty response")

Functions

func APIHost

func APIHost(cr *apiv1alpha1.PerconaServerMySQL) string

func AddPeerExec

func AddPeerExec(ctx context.Context, cliCmd clientcmd.Client, pod *corev1.Pod, peer string) error

func ConfigMap

func ConfigMap(cr *apiv1alpha1.PerconaServerMySQL, data map[string]string) *corev1.ConfigMap

func ConfigMapData

func ConfigMapData(cr *apiv1alpha1.PerconaServerMySQL) (map[string]string, error)

func ConfigMapName

func ConfigMapName(cr *apiv1alpha1.PerconaServerMySQL) string

func DiscoverExec

func DiscoverExec(ctx context.Context, cliCmd clientcmd.Client, pod *corev1.Pod, host string, port int) error

func EnsureNodeIsPrimaryExec

func EnsureNodeIsPrimaryExec(ctx context.Context, cliCmd clientcmd.Client, pod *corev1.Pod, clusterHint, host string, port int) error

func FQDN

func FQDN(cr *apiv1alpha1.PerconaServerMySQL, idx int) string

func Labels

func Labels(cr *apiv1alpha1.PerconaServerMySQL) map[string]string

Labels returns labels of orchestrator

func MatchLabels

func MatchLabels(cr *apiv1alpha1.PerconaServerMySQL) map[string]string

func Name

func Name(cr *apiv1alpha1.PerconaServerMySQL) string

Name returns component name

func NamespacedName

func NamespacedName(cr *apiv1alpha1.PerconaServerMySQL) types.NamespacedName

func PodName

func PodName(cr *apiv1alpha1.PerconaServerMySQL, idx int) string

func PodService

func PodService(cr *apiv1alpha1.PerconaServerMySQL, t corev1.ServiceType, podName string) *corev1.Service

func RaftNodes

func RaftNodes(cr *apiv1alpha1.PerconaServerMySQL) []string

func RemovePeerExec

func RemovePeerExec(ctx context.Context, cliCmd clientcmd.Client, pod *corev1.Pod, peer string) error

func Service

func Service(cr *apiv1alpha1.PerconaServerMySQL) *corev1.Service

func ServiceName

func ServiceName(cr *apiv1alpha1.PerconaServerMySQL) string

func SetWriteableExec

func SetWriteableExec(ctx context.Context, cliCmd clientcmd.Client, pod *corev1.Pod, host string, port int) error

func StartReplicationExec

func StartReplicationExec(ctx context.Context, cliCmd clientcmd.Client, pod *corev1.Pod, host string, port int32) error

func StatefulSet

func StatefulSet(cr *apiv1alpha1.PerconaServerMySQL, initImage, tlsHash string) *appsv1.StatefulSet

func StopReplicationExec

func StopReplicationExec(ctx context.Context, cliCmd clientcmd.Client, pod *corev1.Pod, host string, port int32) error

Types

type Exposer

type Exposer apiv1alpha1.PerconaServerMySQL

func (*Exposer) Exposed

func (e *Exposer) Exposed() bool

func (*Exposer) Labels

func (e *Exposer) Labels() map[string]string

func (*Exposer) Name

func (e *Exposer) Name(index string) string

func (*Exposer) SaveOldMeta

func (e *Exposer) SaveOldMeta() bool

func (*Exposer) Service

func (e *Exposer) Service(name string) *corev1.Service

func (*Exposer) Size

func (e *Exposer) Size() int32

type Instance

type Instance struct {
	Key       InstanceKey   `json:"Key"`
	Alias     string        `json:"InstanceAlias"`
	MasterKey InstanceKey   `json:"MasterKey"`
	Replicas  []InstanceKey `json:"Replicas"`
	ReadOnly  bool          `json:"ReadOnly"`
}

func ClusterPrimaryExec

func ClusterPrimaryExec(ctx context.Context, cliCmd clientcmd.Client, pod *corev1.Pod, clusterHint string) (*Instance, error)

type InstanceKey

type InstanceKey struct {
	Hostname string `json:"Hostname"`
	Port     int32  `json:"Port"`
}