orchestrator

package

v0.1.0 Latest Latest Go to latest Published: Jan 25, 2022 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation ¶

Index ¶

Constants
func APIHost(serviceName string) 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 Service(cr *apiv1alpha1.PerconaServerMySQL) *corev1.Service
func ServiceName(cr *apiv1alpha1.PerconaServerMySQL) string
func StartReplication(ctx context.Context, apiHost, host string, port int32) error
func StatefulSet(cr *apiv1alpha1.PerconaServerMySQL) *appsv1.StatefulSet
func StopReplication(ctx context.Context, apiHost, host string, port int32) error
type Instance
- func ClusterPrimary(ctx context.Context, apiHost, clusterHint string) (*Instance, error)
type InstanceKey

Constants ¶

const (
	DataMountPath = "/var/lib/orchestrator"

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

Variables ¶

This section is empty.

Functions ¶

func APIHost ¶

func APIHost(serviceName string) 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 Service ¶

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

func ServiceName ¶

func ServiceName(cr *apiv1alpha1.PerconaServerMySQL) string

func StartReplication ¶

func StartReplication(ctx context.Context, apiHost, host string, port int32) error

func StatefulSet ¶

func StatefulSet(cr *apiv1alpha1.PerconaServerMySQL) *appsv1.StatefulSet

func StopReplication ¶

func StopReplication(ctx context.Context, apiHost, host string, port int32) error

Types ¶

type Instance ¶

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

func ClusterPrimary ¶

func ClusterPrimary(ctx context.Context, apiHost, clusterHint string) (*Instance, error)

type InstanceKey ¶

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

Source Files ¶

View all Source files

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