restore

package
v0.0.0-...-c2ba8ab Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 28, 2020 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterMetrics

func RegisterMetrics()

Types

type AgentController

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

AgentController handles the excution of MySQLRestores 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 mysqlv1client.MySQLRestoresGetter,
	restoreInformer informers.MySQLRestoreInformer,
	clusterInformer informers.MySQLClusterInformer,
	backupInformer informers.MySQLBackupInformer,
	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 OperatorController

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

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

func NewOperatorController

func NewOperatorController(
	kubeClient kubernetes.Interface,
	client mysqlv1client.MySQLRestoresGetter,
	restoreInformer informers.MySQLRestoreInformer,
	clusterInformer informers.MySQLClusterInformer,
	backupInformer informers.MySQLBackupInformer,
	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.

Jump to

Keyboard shortcuts

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