restore

Documentation

Index

• func RegisterMetrics()
• type AgentController
  • func NewAgentController(kubeClient kubernetes.Interface, client clientset.RestoresGetter, ...) *AgentController
  • func (controller *AgentController) Run(ctx context.Context, numWorkers int) error
• type ConditionUpdater
• type OperatorController
  • func NewOperatorController(kubeClient kubernetes.Interface, client clientset.RestoresGetter, ...) *OperatorController
  • func (controller *OperatorController) Run(ctx context.Context, numWorkers int) error

Functions

func RegisterMetrics

func RegisterMetrics()

RegisterMetrics registers the restore metrics.

Types

type AgentController

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

AgentController handles the excution of Restores on a specific (primary) mysql-agent. It is run in each mysql-agent. TODO: Probably should only be run iff the local mysql instance is a primary.

func NewAgentController

func NewAgentController(
	kubeClient kubernetes.Interface,
	client clientset.RestoresGetter,
	restoreInformer informersv1alpha1.RestoreInformer,
	clusterInformer informersv1alpha1.ClusterInformer,
	backupInformer informersv1alpha1.BackupInformer,
	podInformer corev1informers.PodInformer,
	podName string,
) *AgentController

NewAgentController constructs a new AgentController.

func (*AgentController) Run

func (controller *AgentController) Run(ctx context.Context, numWorkers int) error

Run is a blocking function that runs the specified number of worker goroutines to process items in the work queue. It will return when it receives on the stopCh channel.

type ConditionUpdater

type ConditionUpdater interface {
	Update(restore *v1alpha1.Restore, condition *v1alpha1.RestoreCondition) error
}

ConditionUpdater enables updating Restore conditions.

type OperatorController

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

OperatorController handles validation, labeling, and scheduling of Restores to be executed on a specific (primary) mysql-agent. It is run in the operator.

func NewOperatorController

func NewOperatorController(
	kubeClient kubernetes.Interface,
	client clientset.RestoresGetter,
	restoreInformer informersv1alpha1.RestoreInformer,
	clusterInformer informersv1alpha1.ClusterInformer,
	backupInformer informersv1alpha1.BackupInformer,
	podInformer corev1informers.PodInformer,
) *OperatorController

NewOperatorController constructs a new OperatorController.

func (*OperatorController) Run

func (controller *OperatorController) Run(ctx context.Context, numWorkers int) error

Run is a blocking function that runs the specified number of worker goroutines to process items in the work queue. It will return when it receives on the stopCh channel.