backupschedule

Documentation

Index

• Constants
• type Controller
  • func NewController(opClient mysqlop.Interface, kubeClient kubernetes.Interface, ...) *Controller
  • func (controller *Controller) Run(ctx context.Context, numWorkers int) error

Constants

const (
	// CronScheduleValidationError is used as part of the Event 'reason' when a
	// BackupSchedule fails validation due to an invalid Cron schedule string.
	CronScheduleValidationError = "CronScheduleValidationError"
)

Types

type Controller

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

Controller watches the Kubernetes API for changes to BackupSchedule resources.

func NewController

func NewController(
	opClient mysqlop.Interface,
	kubeClient kubernetes.Interface,
	backupScheduleInformer opinformers.BackupScheduleInformer,
	syncPeriod time.Duration,
	namespace string,
) *Controller

NewController creates a new BackupScheduleController.

func (*Controller) Run

func (controller *Controller) 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.