Documentation ¶
Index ¶
- Constants
- type Config
- type StashController
- func (c *StashController) EnsureBackupTriggeringCronJob(invoker apis.Invoker) error
- func (c *StashController) EnsureBackupTriggeringCronJobDeleted(invoker apis.Invoker) error
- func (c *StashController) EnsureScaledownCronJob(restic *api.Restic) error
- func (c *StashController) EnsureSidecar(restic *api.Restic)
- func (c *StashController) EnsureSidecarDeleted(namespace, name string)
- func (c *StashController) EnsureV1beta1Sidecar(targetRef api_v1beta1.TargetRef, namespace string) error
- func (c *StashController) EnsureV1beta1SidecarDeleted(targetRef api_v1beta1.TargetRef, namespace string) error
- func (c *StashController) MigrateObservedGeneration() error
- func (c *StashController) NewBackupSessionWebhook() hooks.AdmissionHook
- func (c *StashController) NewDaemonSetWebhook() hooks.AdmissionHook
- func (c *StashController) NewDeploymentConfigWebhook() hooks.AdmissionHook
- func (c *StashController) NewDeploymentWebhook() hooks.AdmissionHook
- func (c *StashController) NewRecoveryWebhook() hooks.AdmissionHook
- func (c *StashController) NewReplicaSetWebhook() hooks.AdmissionHook
- func (c *StashController) NewReplicationControllerWebhook() hooks.AdmissionHook
- func (c *StashController) NewRepositoryWebhook() hooks.AdmissionHook
- func (c *StashController) NewResticWebhook() hooks.AdmissionHook
- func (c *StashController) NewRestoreSessionWebhook() hooks.AdmissionHook
- func (c *StashController) NewStatefulSetWebhook() hooks.AdmissionHook
- func (c *StashController) Run(stopCh <-chan struct{})
- func (c *StashController) RunInformers(stopCh <-chan struct{})
Constants ¶
const ( BackupJobPrefix = "backup" VolumeSnapshotPrefix = "vs" PromJobBackupSessionController = "stash-backupsession-controller" )
const ( DefaultBackupSessionCronJobPSPName = "stash-backupsession-cron" DefaultBackupJobPSPName = "stash-backup-job" DefaultRestoreJobPSPName = "stash-restore-job" )
const ( RestoreJobPrefix = "restore" PromJobRestoreSessionController = "stash-restoresession-controller" )
const (
RecoveryEventComponent = "stash-recovery"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { ClientConfig *rest.Config KubeClient kubernetes.Interface OcClient oc_cs.Interface StashClient cs.Interface CRDClient crd_cs.ApiextensionsV1beta1Interface AppCatalogClient appcatalog_cs.Interface // contains filtered or unexported fields }
func (*Config) New ¶
func (c *Config) New() (*StashController, error)
type StashController ¶
type StashController struct {
// contains filtered or unexported fields
}
func (*StashController) EnsureBackupTriggeringCronJob ¶
func (c *StashController) EnsureBackupTriggeringCronJob(invoker apis.Invoker) error
EnsureBackupTriggeringCronJob creates a Kubernetes CronJob for the respective backup invoker the CornJob will create a BackupSession object in each schedule respective BackupSession controller will watch this BackupSession object and take backup instantly
func (*StashController) EnsureBackupTriggeringCronJobDeleted ¶
func (c *StashController) EnsureBackupTriggeringCronJobDeleted(invoker apis.Invoker) error
EnsureBackupTriggeringCronJobDeleted ensure that the CronJob of the respective backup invoker has it as owner. Kuebernetes garbage collector will take care of removing the CronJob
func (*StashController) EnsureScaledownCronJob ¶
func (c *StashController) EnsureScaledownCronJob(restic *api.Restic) error
func (*StashController) EnsureSidecar ¶
func (c *StashController) EnsureSidecar(restic *api.Restic)
func (*StashController) EnsureSidecarDeleted ¶
func (c *StashController) EnsureSidecarDeleted(namespace, name string)
func (*StashController) EnsureV1beta1Sidecar ¶
func (c *StashController) EnsureV1beta1Sidecar(targetRef api_v1beta1.TargetRef, namespace string) error
EnsureV1beta1Sidecar send an event to workload respective controller the workload controller will take care of injecting backup sidecar
func (*StashController) EnsureV1beta1SidecarDeleted ¶
func (c *StashController) EnsureV1beta1SidecarDeleted(targetRef api_v1beta1.TargetRef, namespace string) error
EnsureV1beta1SidecarDeleted send an event to workload respective controller the workload controller will take care of removing respective sidecar
func (*StashController) MigrateObservedGeneration ¶
func (c *StashController) MigrateObservedGeneration() error
func (*StashController) NewBackupSessionWebhook ¶
func (c *StashController) NewBackupSessionWebhook() hooks.AdmissionHook
func (*StashController) NewDaemonSetWebhook ¶
func (c *StashController) NewDaemonSetWebhook() hooks.AdmissionHook
func (*StashController) NewDeploymentConfigWebhook ¶
func (c *StashController) NewDeploymentConfigWebhook() hooks.AdmissionHook
func (*StashController) NewDeploymentWebhook ¶
func (c *StashController) NewDeploymentWebhook() hooks.AdmissionHook
func (*StashController) NewRecoveryWebhook ¶
func (c *StashController) NewRecoveryWebhook() hooks.AdmissionHook
func (*StashController) NewReplicaSetWebhook ¶
func (c *StashController) NewReplicaSetWebhook() hooks.AdmissionHook
func (*StashController) NewReplicationControllerWebhook ¶
func (c *StashController) NewReplicationControllerWebhook() hooks.AdmissionHook
func (*StashController) NewRepositoryWebhook ¶
func (c *StashController) NewRepositoryWebhook() hooks.AdmissionHook
func (*StashController) NewResticWebhook ¶
func (c *StashController) NewResticWebhook() hooks.AdmissionHook
func (*StashController) NewRestoreSessionWebhook ¶
func (c *StashController) NewRestoreSessionWebhook() hooks.AdmissionHook
func (*StashController) NewStatefulSetWebhook ¶
func (c *StashController) NewStatefulSetWebhook() hooks.AdmissionHook
func (*StashController) Run ¶
func (c *StashController) Run(stopCh <-chan struct{})
func (*StashController) RunInformers ¶
func (c *StashController) RunInformers(stopCh <-chan struct{})
Source Files ¶
- appbindings.go
- backup.go
- backup_configuration.go
- backup_session.go
- backupbatch.go
- config.go
- controller.go
- daemonsets.go
- deployment.go
- deploymentconfiguration.go
- init_container.go
- inputs.go
- jobs.go
- migration.go
- namespaces.go
- psp.go
- pvc.go
- rcs.go
- recoveries.go
- replicasets.go
- repository.go
- restics.go
- restore_session.go
- sidecar.go
- stash.go
- statefulsets.go