controller

Documentation

Index

• Variables
• func NewScheduleController(namespace string, schedulesClient arkv1client.SchedulesGetter, ...) *scheduleController
• type Interface
  • func NewBackupController(backupInformer informers.BackupInformer, client arkv1client.BackupsGetter, ...) Interface
  • func NewBackupSyncController(client arkv1client.BackupsGetter, backupService cloudprovider.BackupService, ...) Interface
  • func NewDownloadRequestController(downloadRequestClient arkv1client.DownloadRequestsGetter, ...) Interface
  • func NewGCController(backupService cloudprovider.BackupService, ...) Interface
  • func NewRestoreController(namespace string, restoreInformer informers.RestoreInformer, ...) Interface

Variables

var MinVersionForDelete = version.MustParseSemantic("1.7.5")

MinVersionForDelete is the minimum Kubernetes server version that Ark requires in order to be able to properly delete backups (including the associated snapshots and object storage files). This is because Ark uses finalizers on the backup CRD to implement garbage-collection and deletion.

Functions

func NewScheduleController

func NewScheduleController(
	namespace string,
	schedulesClient arkv1client.SchedulesGetter,
	backupsClient arkv1client.BackupsGetter,
	schedulesInformer informers.ScheduleInformer,
	syncPeriod time.Duration,
	logger logrus.FieldLogger,
) *scheduleController

Types

type Interface

type Interface interface {
	// Run runs the component.
	Run(ctx context.Context, workers int) error
}

Interface represents a runnable component.

func NewBackupController

func NewBackupController(
	backupInformer informers.BackupInformer,
	client arkv1client.BackupsGetter,
	backupper backup.Backupper,
	backupService cloudprovider.BackupService,
	bucket string,
	pvProviderExists bool,
	logger logrus.FieldLogger,
	pluginManager plugin.Manager,
) Interface

func NewBackupSyncController

func NewBackupSyncController(
	client arkv1client.BackupsGetter,
	backupService cloudprovider.BackupService,
	bucket string,
	syncPeriod time.Duration,
	logger logrus.FieldLogger,
) Interface

func NewDownloadRequestController

func NewDownloadRequestController(
	downloadRequestClient arkv1client.DownloadRequestsGetter,
	downloadRequestInformer informers.DownloadRequestInformer,
	backupService cloudprovider.BackupService,
	bucket string,
	logger logrus.FieldLogger,
) Interface

NewDownloadRequestController creates a new DownloadRequestController.

func NewGCController

func NewGCController(
	backupService cloudprovider.BackupService,
	snapshotService cloudprovider.SnapshotService,
	bucket string,
	syncPeriod time.Duration,
	backupInformer informers.BackupInformer,
	backupClient arkv1client.BackupsGetter,
	restoreInformer informers.RestoreInformer,
	restoreClient arkv1client.RestoresGetter,
	logger logrus.FieldLogger,
) Interface

NewGCController constructs a new gcController.

func NewRestoreController

func NewRestoreController(
	namespace string,
	restoreInformer informers.RestoreInformer,
	restoreClient arkv1client.RestoresGetter,
	backupClient arkv1client.BackupsGetter,
	restorer restore.Restorer,
	backupService cloudprovider.BackupService,
	bucket string,
	backupInformer informers.BackupInformer,
	pvProviderExists bool,
	logger logrus.FieldLogger,
	pluginManager plugin.Manager,
) Interface