manager

Documentation

Index

• func RegisterMetrics()
• type ClusterManager
  • func NewClusterManager(kubeClient kubernetes.Interface, ...) *ClusterManager
  • func NewLocalClusterManger(kubeclient kubernetes.Interface, ...) (*ClusterManager, error)
  • func (m *ClusterManager) Run(ctx context.Context)
  • func (m *ClusterManager) Sync(ctx context.Context) bool

Functions

func RegisterMetrics

func RegisterMetrics()

RegisterMetrics registers the cluster managemnent metrics.

Types

type ClusterManager

type ClusterManager struct {

	// Instance is the local instance of MySQL under management.
	Instance *cluster.Instance
	// contains filtered or unexported fields
}

ClusterManager manages the local MySQL instance's membership of an InnoDB cluster.

func NewClusterManager

func NewClusterManager(
	kubeClient kubernetes.Interface,
	kubeInformerFactory kubeinformers.SharedInformerFactory,
	mysqlshFactory func(string) mysqlsh.Interface,
	instance *cluster.Instance,
) *ClusterManager

NewClusterManager creates a InnoDB cluster ClusterManager.

func NewLocalClusterManger

func NewLocalClusterManger(kubeclient kubernetes.Interface, kubeInformerFactory kubeinformers.SharedInformerFactory) (*ClusterManager, error)

NewLocalClusterManger creates a new cluster.ClusterManager for the local MySQL instance.

func (*ClusterManager) Run

func (m *ClusterManager) Run(ctx context.Context)

Run runs the ClusterManager controller. NOTE: ctx is not currently used for cancellation by caller (the stopCh is).

func (*ClusterManager) Sync

func (m *ClusterManager) Sync(ctx context.Context) bool

Sync ensures that the MySQL database instance managed by this instance of the agent is part of the InnoDB cluster and is online.