controller

Documentation

Index

• Constants
• type Config
  • func NewConfig(clientConfig *rest.Config) *Config
  • func (c *Config) New() (*StashController, error)
• 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 (
	BackupExecutorSidecar   = "sidecar"
	BackupExecutorCSIDriver = "csi-driver"
	BackupExecutorJob       = "job"
)

const (
	RestorerInitContainer = "init-container"
	RestorerCSIDriver     = "csi-driver"
	RestorerJob           = "restore-job"
)

const (
	RecoveryEventComponent = "stash-recovery"
)

Types

type Config

type Config struct {
	ClientConfig     *rest.Config
	KubeClient       kubernetes.Interface
	OcClient         oc_cs.Interface
	StashClient      cs.Interface
	CRDClient        crd_cs.Interface
	AppCatalogClient appcatalog_cs.Interface
	// contains filtered or unexported fields
}

func NewConfig

func NewConfig(clientConfig *rest.Config) *Config

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{})