labeler

Documentation

Index

• func HasRoleSelector(name string) labels.Selector
• func NonPrimarySelector(name string) labels.Selector
• func PrimarySelector(name string) labels.Selector
• func SecondarySelector(name string) labels.Selector
• type ClusterLabelerController
  • func NewClusterLabelerController(localInstance *cluster.Instance, kubeClient kubernetes.Interface, ...) *ClusterLabelerController
  • func (clc *ClusterLabelerController) EnqueueClusterStatus(obj interface{}) error
  • func (clc *ClusterLabelerController) Run(ctx context.Context)

Functions

func HasRoleSelector

func HasRoleSelector(name string) labels.Selector

HasRoleSelector returns a label selector that selects all Pods for a MySQLCluster that have been labeled as having a role.

func NonPrimarySelector

func NonPrimarySelector(name string) labels.Selector

NonPrimarySelector returns a label selector that selects all Pods excluding primaries of a MySQLCluster.

func PrimarySelector

func PrimarySelector(name string) labels.Selector

PrimarySelector returns a label selector that selects only primaries of a MySQLCluster's Pods.

func SecondarySelector

func SecondarySelector(name string) labels.Selector

SecondarySelector returns a label selector that selects only secondaries of a MySQLCluster's Pods.

Types

type ClusterLabelerController

type ClusterLabelerController struct {
	// contains filtered or unexported fields
}

ClusterLabelerController adds annotations about the InnoDB cluster state to the MySQLCluster's Pods. This controller should only be run iff the the local MySQL instance believes that it is the primary of the MySQL cluster.

func NewClusterLabelerController

func NewClusterLabelerController(
	localInstance *cluster.Instance,
	kubeClient kubernetes.Interface,
	podInformer corev1informers.PodInformer,
) *ClusterLabelerController

NewClusterLabelerController creates a new ClusterLabelerController.

func (*ClusterLabelerController) EnqueueClusterStatus

func (clc *ClusterLabelerController) EnqueueClusterStatus(obj interface{}) error

EnqueueClusterStatus takes an *innodb.ClusterStatus, stores it in the cache.Store, and then enqueues its key.

func (*ClusterLabelerController) Run

func (clc *ClusterLabelerController) Run(ctx context.Context)

Run runs the ClusterLabelerController.