Versions in this module Expand all Collapse all v1 v1.99.99 Aug 20, 2021 Changes in this version + func BuildTagArgs(tagList []string) []string + func NewExecutor(config job.Config) queue.Executor + type ArchiveExecutor struct + func NewArchiveExecutor(config job.Config) *ArchiveExecutor + func (*ArchiveExecutor) Exclusive() bool + func (a *ArchiveExecutor) Execute() error + func (a *ArchiveExecutor) GetConcurrencyLimit() int + func (g *ArchiveExecutor) CreateObjectIfNotExisting(obj client.Object) error + func (g *ArchiveExecutor) GetJobNamespace() string + func (g *ArchiveExecutor) GetJobNamespacedName() types.NamespacedName + func (g *ArchiveExecutor) GetJobType() k8upv1alpha1.JobType + func (g *ArchiveExecutor) GetRepository() string + func (g *ArchiveExecutor) Logger() logr.Logger + func (g *ArchiveExecutor) RegisterJobSucceededConditionCallback() + type BackupExecutor struct + func NewBackupExecutor(config job.Config) *BackupExecutor + func (*BackupExecutor) Exclusive() bool + func (b *BackupExecutor) Execute() error + func (b *BackupExecutor) GetConcurrencyLimit() int + func (b *BackupExecutor) StartPreBackup() (bool, error) + func (b *BackupExecutor) StopPreBackupDeployments() + func (g *BackupExecutor) CreateObjectIfNotExisting(obj client.Object) error + func (g *BackupExecutor) GetJobNamespace() string + func (g *BackupExecutor) GetJobNamespacedName() types.NamespacedName + func (g *BackupExecutor) GetJobType() k8upv1alpha1.JobType + func (g *BackupExecutor) GetRepository() string + func (g *BackupExecutor) Logger() logr.Logger + func (g *BackupExecutor) RegisterJobSucceededConditionCallback() + type CheckExecutor struct + func NewCheckExecutor(config job.Config) *CheckExecutor + func (*CheckExecutor) Exclusive() bool + func (c *CheckExecutor) Execute() error + func (c *CheckExecutor) GetConcurrencyLimit() int + func (g *CheckExecutor) CreateObjectIfNotExisting(obj client.Object) error + func (g *CheckExecutor) GetJobNamespace() string + func (g *CheckExecutor) GetJobNamespacedName() types.NamespacedName + func (g *CheckExecutor) GetJobType() k8upv1alpha1.JobType + func (g *CheckExecutor) GetRepository() string + func (g *CheckExecutor) Logger() logr.Logger + func (g *CheckExecutor) RegisterJobSucceededConditionCallback() + type EnvVarConverter struct + Vars map[string]envVarEntry + func DefaultEnv(namespace string) EnvVarConverter + func NewEnvVarConverter() EnvVarConverter + func (e *EnvVarConverter) Convert() []corev1.EnvVar + func (e *EnvVarConverter) Merge(source EnvVarConverter) error + func (e *EnvVarConverter) SetEnvVarSource(key string, value *corev1.EnvVarSource) + func (e *EnvVarConverter) SetString(key, value string) + type PruneExecutor struct + func NewPruneExecutor(config job.Config) *PruneExecutor + func (g *PruneExecutor) CreateObjectIfNotExisting(obj client.Object) error + func (g *PruneExecutor) GetJobNamespace() string + func (g *PruneExecutor) GetJobNamespacedName() types.NamespacedName + func (g *PruneExecutor) GetJobType() k8upv1alpha1.JobType + func (g *PruneExecutor) GetRepository() string + func (g *PruneExecutor) Logger() logr.Logger + func (g *PruneExecutor) RegisterJobSucceededConditionCallback() + func (p *PruneExecutor) Exclusive() bool + func (p *PruneExecutor) Execute() error + func (p *PruneExecutor) GetConcurrencyLimit() int + type QueueWorker struct + func GetExecutor() *QueueWorker + type RestoreExecutor struct + func NewRestoreExecutor(config job.Config) *RestoreExecutor + func (*RestoreExecutor) Exclusive() bool + func (g *RestoreExecutor) CreateObjectIfNotExisting(obj client.Object) error + func (g *RestoreExecutor) GetJobNamespace() string + func (g *RestoreExecutor) GetJobNamespacedName() types.NamespacedName + func (g *RestoreExecutor) GetJobType() k8upv1alpha1.JobType + func (g *RestoreExecutor) GetRepository() string + func (g *RestoreExecutor) Logger() logr.Logger + func (g *RestoreExecutor) RegisterJobSucceededConditionCallback() + func (r *RestoreExecutor) Execute() error + func (r *RestoreExecutor) GetConcurrencyLimit() int
Go to main page