orchestrator

Documentation

Index

• Constants
• Variables
• func APIHost(cr *apiv1alpha1.PerconaServerMySQL) string
• func AddPeer(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 Discover(ctx context.Context, cliCmd clientcmd.Client, pod *corev1.Pod, host string, ...) error
• func EnsureNodeIsPrimary(ctx context.Context, cliCmd clientcmd.Client, pod *corev1.Pod, ...) error
• func FQDN(cr *apiv1alpha1.PerconaServerMySQL, idx int) string
• func ForgetInstance(ctx context.Context, cliCmd clientcmd.Client, pod *corev1.Pod, host string, ...) error
• 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 RBAC(cr *apiv1alpha1.PerconaServerMySQL) (*rbacv1.Role, *rbacv1.RoleBinding, *corev1.ServiceAccount)
• func RaftNodes(cr *apiv1alpha1.PerconaServerMySQL) []string
• func RemovePeer(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 SetWriteable(ctx context.Context, cliCmd clientcmd.Client, pod *corev1.Pod, host string, ...) error
• func StartReplication(ctx context.Context, cliCmd clientcmd.Client, pod *corev1.Pod, host string, ...) error
• func StatefulSet(cr *apiv1alpha1.PerconaServerMySQL, initImage, tlsHash string) *appsv1.StatefulSet
• func StopReplication(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 Cluster(ctx context.Context, cliCmd clientcmd.Client, pod *corev1.Pod, ...) ([]*Instance, error)
  • func ClusterPrimary(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 AddPeer

func AddPeer(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 Discover

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

func EnsureNodeIsPrimary

func EnsureNodeIsPrimary(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 ForgetInstance

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

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 RBAC

func RBAC(cr *apiv1alpha1.PerconaServerMySQL) (*rbacv1.Role, *rbacv1.RoleBinding, *corev1.ServiceAccount)

func RaftNodes

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

func RemovePeer

func RemovePeer(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 SetWriteable

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

func StartReplication

func StartReplication(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 StopReplication

func StopReplication(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"`
	Problems  []string      `json:"Problems"`
}

func Cluster

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

func ClusterPrimary

func ClusterPrimary(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"`
}