controllers

Documentation

Index

• Constants
• func GetObjectPath(backup *stork_api.ApplicationBackup) string
• func IsResourceTypePVC(backup *stork_api.ApplicationBackup) bool
• func IsVolsToBeBackedUp(backup *stork_api.ApplicationBackup) bool
• func RegisterDefaultCRDs() error
• type ApplicationBackupController
  • func NewApplicationBackup(mgr manager.Manager, r record.EventRecorder, ...) *ApplicationBackupController
  • func (a *ApplicationBackupController) Init(mgr manager.Manager, backupAdminNamespace string, syncTime int64) error
  • func (a *ApplicationBackupController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
• type ApplicationBackupScheduleController
  • func NewApplicationBackupSchedule(mgr manager.Manager, r record.EventRecorder) *ApplicationBackupScheduleController
  • func (s *ApplicationBackupScheduleController) Init(mgr manager.Manager) error
  • func (s *ApplicationBackupScheduleController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
• type ApplicationCloneController
  • func NewApplicationClone(mgr manager.Manager, d volume.Driver, r record.EventRecorder, ...) *ApplicationCloneController
  • func (a *ApplicationCloneController) Init(mgr manager.Manager, adminNamespace string) error
  • func (a *ApplicationCloneController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
• type ApplicationRestoreController
  • func NewApplicationRestore(mgr manager.Manager, r record.EventRecorder, ...) *ApplicationRestoreController
  • func (a *ApplicationRestoreController) Init(mgr manager.Manager, restoreAdminNamespace string) error
  • func (a *ApplicationRestoreController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
• type BackupSyncController
  • func (b *BackupSyncController) Init(stopChannel chan os.Signal) error
• type WatchFunc

Constants

const (

	// ApplicationBackupScheduleNameAnnotation Annotation used to specify the name of schedule that
	// created the backup
	ApplicationBackupScheduleNameAnnotation = annotationPrefix + "applicationBackupScheduleName"
	// ApplicationBackupSchedulePolicyTypeAnnotation Annotation used to specify the type of the
	// policy that triggered the backup
	ApplicationBackupSchedulePolicyTypeAnnotation = annotationPrefix + "applicationBackupSchedulePolicyType"
	// ApplicationBackupObjectLockRetentionAnnotation - object lock retention period annotation
	// Since this annotation is used in the px-backup, creating with portworx.io annotation prefix.
	ApplicationBackupObjectLockRetentionAnnotation = "portworx.io/" + "object-lock-retention-period"
)

Functions

func GetObjectPath

func GetObjectPath(
	backup *stork_api.ApplicationBackup,
) string

GetObjectPath construct the full base path for a given backup The format is "namespace/backupName/backupUID" which will be unique for each backup

func IsResourceTypePVC

func IsResourceTypePVC(backup *stork_api.ApplicationBackup) bool

IsResourceTypePVC check if given ResourceType is PVC

func IsVolsToBeBackedUp

func IsVolsToBeBackedUp(backup *stork_api.ApplicationBackup) bool

IsVolsToBeBackedUp for a given backupspec do we need to have volumes backed up

func RegisterDefaultCRDs

func RegisterDefaultCRDs() error

RegisterDefaultCRDs registered already supported CRDs

Types

type ApplicationBackupController

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

ApplicationBackupController reconciles applicationbackup objects

func NewApplicationBackup

func NewApplicationBackup(mgr manager.Manager, r record.EventRecorder, rc resourcecollector.ResourceCollector) *ApplicationBackupController

NewApplicationBackup creates a new instance of ApplicationBackupController.

func (*ApplicationBackupController) Init

func (a *ApplicationBackupController) Init(mgr manager.Manager, backupAdminNamespace string, syncTime int64) error

Init Initialize the application backup controller

func (*ApplicationBackupController) Reconcile

func (a *ApplicationBackupController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile updates for ApplicationBackup objects.

type ApplicationBackupScheduleController

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

ApplicationBackupScheduleController reconciles ApplicationBackupSchedule objects

func NewApplicationBackupSchedule

func NewApplicationBackupSchedule(mgr manager.Manager, r record.EventRecorder) *ApplicationBackupScheduleController

NewApplicationBackupSchedule creates a new instance of ApplicationBackupScheduleController.

func (*ApplicationBackupScheduleController) Init

func (s *ApplicationBackupScheduleController) Init(mgr manager.Manager) error

Init Initialize the backup schedule controller

func (*ApplicationBackupScheduleController) Reconcile

func (s *ApplicationBackupScheduleController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile updates for ApplicationBackupSchedule objects.

type ApplicationCloneController

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

ApplicationCloneController reconciles applicationclone objects

func NewApplicationClone

func NewApplicationClone(mgr manager.Manager, d volume.Driver, r record.EventRecorder, rc resourcecollector.ResourceCollector) *ApplicationCloneController

NewApplicationClone create a new instance of ApplicationCloneController.

func (*ApplicationCloneController) Init

func (a *ApplicationCloneController) Init(mgr manager.Manager, adminNamespace string) error

Init Initialize the application clone controller

func (*ApplicationCloneController) Reconcile

func (a *ApplicationCloneController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile updates for ApplicationClone objects.

type ApplicationRestoreController

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

ApplicationRestoreController reconciles applicationrestore objects

func NewApplicationRestore

func NewApplicationRestore(mgr manager.Manager, r record.EventRecorder, rc resourcecollector.ResourceCollector) *ApplicationRestoreController

NewApplicationRestore creates a new instance of ApplicationRestoreController.

func (*ApplicationRestoreController) Init

func (a *ApplicationRestoreController) Init(mgr manager.Manager, restoreAdminNamespace string) error

Init Initialize the application restore controller

func (*ApplicationRestoreController) Reconcile

func (a *ApplicationRestoreController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile updates for ApplicationRestore objects.

type BackupSyncController

type BackupSyncController struct {
	Recorder     record.EventRecorder
	SyncInterval time.Duration
	// contains filtered or unexported fields
}

BackupSyncController reconciles applicationbackup objects

func (*BackupSyncController) Init

func (b *BackupSyncController) Init(stopChannel chan os.Signal) error

Init Initializes the backup sync controller

type WatchFunc

type WatchFunc func(object runtime.Object)

WatchFunc is a callback provided to the Watch functions