orchestrator

package

v0.5.0 Latest Latest Go to latest Published: Mar 30, 2023 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation ¶

Index ¶

Constants
Variables
func APIHost(cr *apiv1alpha1.PerconaServerMySQL) string
func AddPeer(ctx context.Context, apiHost string, 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, apiHost, host string, port int) error
func EnsureNodeIsPrimary(ctx context.Context, apiHost, clusterHint, host string, port int) 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 RemovePeer(ctx context.Context, apiHost string, peer string) error
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, initImage string) *appsv1.StatefulSet
func StopReplication(ctx context.Context, apiHost, host string, port int32) 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 ClusterPrimary(ctx context.Context, apiHost, clusterHint string) (*Instance, error)
type InstanceKey

Constants ¶

const (
	ConfigFileName = "orchestrator.conf.json"

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

Variables ¶

View Source

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

Functions ¶

func APIHost ¶

func APIHost(cr *apiv1alpha1.PerconaServerMySQL) string

func AddPeer ¶ added in v0.2.0

func AddPeer(ctx context.Context, apiHost string, peer string) error

func ConfigMap ¶ added in v0.2.0

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

func ConfigMapData ¶ added in v0.2.0

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

func ConfigMapName ¶ added in v0.2.0

func ConfigMapName(cr *apiv1alpha1.PerconaServerMySQL) string

func Discover ¶ added in v0.4.0

func Discover(ctx context.Context, apiHost, host string, port int) error

func EnsureNodeIsPrimary ¶ added in v0.3.0

func EnsureNodeIsPrimary(ctx context.Context, apiHost, clusterHint, host string, port int) error

func FQDN ¶ added in v0.2.0

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 ¶ added in v0.2.0

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

func PodService ¶ added in v0.2.0

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

func RaftNodes ¶ added in v0.2.0

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

func RemovePeer ¶ added in v0.2.0

func RemovePeer(ctx context.Context, apiHost string, peer string) error

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, initImage string) *appsv1.StatefulSet

func StopReplication ¶

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

Types ¶

type Exposer ¶ added in v0.2.0

type Exposer apiv1alpha1.PerconaServerMySQL

func (*Exposer) Exposed ¶ added in v0.2.0

func (e *Exposer) Exposed() bool

func (*Exposer) Labels ¶ added in v0.2.0

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

func (*Exposer) Name ¶ added in v0.2.0

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

func (*Exposer) SaveOldMeta ¶ added in v0.4.0

func (e *Exposer) SaveOldMeta() bool

func (*Exposer) Service ¶ added in v0.2.0

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

func (*Exposer) Size ¶ added in v0.2.0

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"`
}

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