controllers

Documentation

Index

• Constants
• func GetObjectPath(backup *stork_api.ApplicationBackup) string
• 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(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(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(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(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"
)

const (
	// IBMApp registration name
	IBMApp = "ibm"
	// CouchBaseApp registration name
	CouchBaseApp = "couchbase"
	// RedisClusterApp registration name
	RedisClusterApp = "redis"
	// CassandraApp registration name
	CassandraApp = "cassandra"
	// WeblogicDomainApp registration name
	WeblogicDomainApp = "weblogic"
	// RabbitMQApp registration name
	RabbitMQApp = "rabbitmq"
	// PerconaDBApp registration name
	PerconaDBApp = "perconadb"
	// PrometheusApp registration name
	PrometheusApp = "prometheus"
	// KafkaApp registration name
	KafkaApp = "kafka"
	// PostgressApp registration name
	PostgressApp = "postgress"
)

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 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(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(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(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(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