Documentation ¶
Index ¶
- Constants
- func IsRestoreCompleted(phase v1beta1.RestorePhase) bool
- func TargetBackupCompleted(ref v1beta1.TargetRef, targetStatus []v1beta1.BackupTargetStatus) bool
- func TargetBackupInitiated(ref v1beta1.TargetRef, targetStatus []v1beta1.BackupTargetStatus) bool
- func TargetMatched(t1, t2 v1beta1.TargetRef) bool
- func TargetOfGroupKind(targetRef v1beta1.TargetRef, group, kind string) bool
- func TargetRestoreCompleted(ref v1beta1.TargetRef, targetStatus []v1beta1.RestoreMemberStatus) bool
- type BackupBatchInvoker
- func (inv *BackupBatchInvoker) AddFinalizer() error
- func (inv *BackupBatchInvoker) GetBackupHistoryLimit() *int32
- func (inv *BackupBatchInvoker) GetCondition(target *v1beta1.TargetRef, conditionType string) (int, *kmapi.Condition, error)
- func (inv *BackupBatchInvoker) GetDriver() v1beta1.Snapshotter
- func (inv *BackupBatchInvoker) GetExecutionOrder() v1beta1.ExecutionOrder
- func (inv *BackupBatchInvoker) GetGlobalHooks() *v1beta1.BackupHooks
- func (inv *BackupBatchInvoker) GetHash() string
- func (inv *BackupBatchInvoker) GetLabels() map[string]string
- func (inv *BackupBatchInvoker) GetObjectJSON() (string, error)
- func (inv *BackupBatchInvoker) GetObjectMeta() metav1.ObjectMeta
- func (inv *BackupBatchInvoker) GetObjectRef() (*core.ObjectReference, error)
- func (inv *BackupBatchInvoker) GetOwnerRef() *metav1.OwnerReference
- func (inv *BackupBatchInvoker) GetPhase() v1beta1.BackupInvokerPhase
- func (inv *BackupBatchInvoker) GetRepoRef() kmapi.ObjectReference
- func (inv *BackupBatchInvoker) GetRepository() (*v1alpha1.Repository, error)
- func (inv *BackupBatchInvoker) GetRetentionPolicy() v1alpha1.RetentionPolicy
- func (inv *BackupBatchInvoker) GetRuntimeSettings() ofst.RuntimeSettings
- func (inv *BackupBatchInvoker) GetSchedule() string
- func (inv *BackupBatchInvoker) GetTargetInfo() []BackupTargetInfo
- func (inv *BackupBatchInvoker) GetTypeMeta() metav1.TypeMeta
- func (inv *BackupBatchInvoker) HasCondition(target *v1beta1.TargetRef, conditionType string) (bool, error)
- func (inv *BackupBatchInvoker) IsConditionTrue(target *v1beta1.TargetRef, conditionType string) (bool, error)
- func (inv *BackupBatchInvoker) IsPaused() bool
- func (inv *BackupBatchInvoker) NextInOrder(curTarget v1beta1.TargetRef, targetStatus []v1beta1.BackupTargetStatus) bool
- func (inv *BackupBatchInvoker) RemoveFinalizer() error
- func (inv *BackupBatchInvoker) SetCondition(target *v1beta1.TargetRef, newCondition kmapi.Condition) error
- type BackupConfigurationInvoker
- func (inv *BackupConfigurationInvoker) AddFinalizer() error
- func (inv *BackupConfigurationInvoker) GetBackupHistoryLimit() *int32
- func (inv *BackupConfigurationInvoker) GetCondition(target *v1beta1.TargetRef, conditionType string) (int, *kmapi.Condition, error)
- func (inv *BackupConfigurationInvoker) GetDriver() v1beta1.Snapshotter
- func (inv *BackupConfigurationInvoker) GetExecutionOrder() v1beta1.ExecutionOrder
- func (inv *BackupConfigurationInvoker) GetGlobalHooks() *v1beta1.BackupHooks
- func (inv *BackupConfigurationInvoker) GetHash() string
- func (inv *BackupConfigurationInvoker) GetLabels() map[string]string
- func (inv *BackupConfigurationInvoker) GetObjectJSON() (string, error)
- func (inv *BackupConfigurationInvoker) GetObjectMeta() metav1.ObjectMeta
- func (inv *BackupConfigurationInvoker) GetObjectRef() (*core.ObjectReference, error)
- func (inv *BackupConfigurationInvoker) GetOwnerRef() *metav1.OwnerReference
- func (inv *BackupConfigurationInvoker) GetPhase() v1beta1.BackupInvokerPhase
- func (inv *BackupConfigurationInvoker) GetRepoRef() kmapi.ObjectReference
- func (inv *BackupConfigurationInvoker) GetRepository() (*v1alpha1.Repository, error)
- func (inv *BackupConfigurationInvoker) GetRetentionPolicy() v1alpha1.RetentionPolicy
- func (inv *BackupConfigurationInvoker) GetRuntimeSettings() ofst.RuntimeSettings
- func (inv *BackupConfigurationInvoker) GetSchedule() string
- func (inv *BackupConfigurationInvoker) GetTargetInfo() []BackupTargetInfo
- func (inv *BackupConfigurationInvoker) GetTypeMeta() metav1.TypeMeta
- func (inv *BackupConfigurationInvoker) HasCondition(target *v1beta1.TargetRef, conditionType string) (bool, error)
- func (inv *BackupConfigurationInvoker) IsConditionTrue(target *v1beta1.TargetRef, conditionType string) (bool, error)
- func (inv *BackupConfigurationInvoker) IsPaused() bool
- func (inv *BackupConfigurationInvoker) NextInOrder(curTarget v1beta1.TargetRef, targetStatus []v1beta1.BackupTargetStatus) bool
- func (inv *BackupConfigurationInvoker) RemoveFinalizer() error
- func (inv *BackupConfigurationInvoker) SetCondition(target *v1beta1.TargetRef, newCondition kmapi.Condition) error
- type BackupExecutionOrderHandler
- type BackupInvoker
- func NewBackupBatchInvoker(stashClient cs.Interface, backupBatch *v1beta1.BackupBatch) BackupInvoker
- func NewBackupConfigurationInvoker(stashClient cs.Interface, backupConfig *v1beta1.BackupConfiguration) BackupInvoker
- func NewBackupInvoker(stashClient cs.Interface, kind, name, namespace string) (BackupInvoker, error)
- type BackupInvokerStatusHandler
- type BackupTargetHandler
- type BackupTargetInfo
- type ConditionHandler
- type DriverHandler
- type Eventer
- type KubeDBIntegrator
- type MetadataHandler
- type ObjectFormatter
- type RepositoryGetter
- type RestoreBatchInvoker
- func (inv *RestoreBatchInvoker) AddFinalizer() error
- func (inv *RestoreBatchInvoker) CreateEvent(eventType, source, reason, message string) error
- func (inv *RestoreBatchInvoker) EnsureKubeDBIntegration(appClient appcatalog_cs.Interface) error
- func (inv *RestoreBatchInvoker) GetCondition(target *v1beta1.TargetRef, conditionType string) (int, *kmapi.Condition, error)
- func (inv *RestoreBatchInvoker) GetDriver() v1beta1.Snapshotter
- func (inv *RestoreBatchInvoker) GetExecutionOrder() v1beta1.ExecutionOrder
- func (inv *RestoreBatchInvoker) GetGlobalHooks() *v1beta1.RestoreHooks
- func (inv *RestoreBatchInvoker) GetHash() string
- func (inv *RestoreBatchInvoker) GetLabels() map[string]string
- func (inv *RestoreBatchInvoker) GetObjectJSON() (string, error)
- func (inv *RestoreBatchInvoker) GetObjectMeta() metav1.ObjectMeta
- func (inv *RestoreBatchInvoker) GetObjectRef() (*core.ObjectReference, error)
- func (inv *RestoreBatchInvoker) GetOwnerRef() *metav1.OwnerReference
- func (inv *RestoreBatchInvoker) GetRepoRef() kmapi.ObjectReference
- func (inv *RestoreBatchInvoker) GetRepository() (*v1alpha1.Repository, error)
- func (inv *RestoreBatchInvoker) GetStatus() RestoreInvokerStatus
- func (inv *RestoreBatchInvoker) GetTargetInfo() []RestoreTargetInfo
- func (inv *RestoreBatchInvoker) GetTypeMeta() metav1.TypeMeta
- func (inv *RestoreBatchInvoker) HasCondition(target *v1beta1.TargetRef, conditionType string) (bool, error)
- func (inv *RestoreBatchInvoker) IsConditionTrue(target *v1beta1.TargetRef, conditionType string) (bool, error)
- func (inv *RestoreBatchInvoker) NextInOrder(curTarget v1beta1.TargetRef, targetStatus []v1beta1.RestoreMemberStatus) bool
- func (inv *RestoreBatchInvoker) RemoveFinalizer() error
- func (inv *RestoreBatchInvoker) SetCondition(target *v1beta1.TargetRef, newCondition kmapi.Condition) error
- func (inv *RestoreBatchInvoker) UpdateStatus(status RestoreInvokerStatus) error
- type RestoreExecutionOrderHandler
- type RestoreInvoker
- func NewRestoreBatchInvoker(kubeClient kubernetes.Interface, stashClient cs.Interface, ...) RestoreInvoker
- func NewRestoreInvoker(kubeClient kubernetes.Interface, stashClient cs.Interface, ...) (RestoreInvoker, error)
- func NewRestoreSessionInvoker(kubeClient kubernetes.Interface, stashClient cs.Interface, ...) RestoreInvoker
- type RestoreInvokerStatus
- type RestoreSessionInvoker
- func (inv *RestoreSessionInvoker) AddFinalizer() error
- func (inv *RestoreSessionInvoker) CreateEvent(eventType, source, reason, message string) error
- func (inv *RestoreSessionInvoker) EnsureKubeDBIntegration(appClient appcatalog_cs.Interface) error
- func (inv *RestoreSessionInvoker) GetCondition(target *v1beta1.TargetRef, conditionType string) (int, *kmapi.Condition, error)
- func (inv *RestoreSessionInvoker) GetDriver() v1beta1.Snapshotter
- func (inv *RestoreSessionInvoker) GetExecutionOrder() v1beta1.ExecutionOrder
- func (inv *RestoreSessionInvoker) GetGlobalHooks() *v1beta1.RestoreHooks
- func (inv *RestoreSessionInvoker) GetHash() string
- func (inv *RestoreSessionInvoker) GetLabels() map[string]string
- func (inv *RestoreSessionInvoker) GetObjectJSON() (string, error)
- func (inv *RestoreSessionInvoker) GetObjectMeta() metav1.ObjectMeta
- func (inv *RestoreSessionInvoker) GetObjectRef() (*core.ObjectReference, error)
- func (inv *RestoreSessionInvoker) GetOwnerRef() *metav1.OwnerReference
- func (inv *RestoreSessionInvoker) GetRepoRef() kmapi.ObjectReference
- func (inv *RestoreSessionInvoker) GetRepository() (*v1alpha1.Repository, error)
- func (inv *RestoreSessionInvoker) GetStatus() RestoreInvokerStatus
- func (inv *RestoreSessionInvoker) GetTargetInfo() []RestoreTargetInfo
- func (inv *RestoreSessionInvoker) GetTypeMeta() metav1.TypeMeta
- func (inv *RestoreSessionInvoker) HasCondition(target *v1beta1.TargetRef, conditionType string) (bool, error)
- func (inv *RestoreSessionInvoker) IsConditionTrue(target *v1beta1.TargetRef, conditionType string) (bool, error)
- func (inv *RestoreSessionInvoker) NextInOrder(curTarget v1beta1.TargetRef, targetStatus []v1beta1.RestoreMemberStatus) bool
- func (inv *RestoreSessionInvoker) RemoveFinalizer() error
- func (inv *RestoreSessionInvoker) SetCondition(target *v1beta1.TargetRef, newCondition kmapi.Condition) error
- func (inv *RestoreSessionInvoker) UpdateStatus(status RestoreInvokerStatus) error
- type RestoreStatusHandler
- type RestoreTargetHandler
- type RestoreTargetInfo
Constants ¶
View Source
const ( EventSourceRestoreBatchController = "RestoreBatch Controller" EventSourceRestoreSessionController = "RestoreSession Controller" )
Variables ¶
This section is empty.
Functions ¶
func IsRestoreCompleted ¶ added in v0.18.0
func IsRestoreCompleted(phase v1beta1.RestorePhase) bool
func TargetBackupCompleted ¶
func TargetBackupCompleted(ref v1beta1.TargetRef, targetStatus []v1beta1.BackupTargetStatus) bool
func TargetBackupInitiated ¶
func TargetBackupInitiated(ref v1beta1.TargetRef, targetStatus []v1beta1.BackupTargetStatus) bool
func TargetMatched ¶
func TargetOfGroupKind ¶ added in v0.11.11
func TargetRestoreCompleted ¶
func TargetRestoreCompleted(ref v1beta1.TargetRef, targetStatus []v1beta1.RestoreMemberStatus) bool
Types ¶
type BackupBatchInvoker ¶ added in v0.18.0
type BackupBatchInvoker struct {
// contains filtered or unexported fields
}
func (*BackupBatchInvoker) AddFinalizer ¶ added in v0.18.0
func (inv *BackupBatchInvoker) AddFinalizer() error
func (*BackupBatchInvoker) GetBackupHistoryLimit ¶ added in v0.18.0
func (inv *BackupBatchInvoker) GetBackupHistoryLimit() *int32
func (*BackupBatchInvoker) GetCondition ¶ added in v0.18.0
func (*BackupBatchInvoker) GetDriver ¶ added in v0.18.0
func (inv *BackupBatchInvoker) GetDriver() v1beta1.Snapshotter
func (*BackupBatchInvoker) GetExecutionOrder ¶ added in v0.18.0
func (inv *BackupBatchInvoker) GetExecutionOrder() v1beta1.ExecutionOrder
func (*BackupBatchInvoker) GetGlobalHooks ¶ added in v0.18.0
func (inv *BackupBatchInvoker) GetGlobalHooks() *v1beta1.BackupHooks
func (*BackupBatchInvoker) GetHash ¶ added in v0.18.0
func (inv *BackupBatchInvoker) GetHash() string
func (*BackupBatchInvoker) GetLabels ¶ added in v0.18.0
func (inv *BackupBatchInvoker) GetLabels() map[string]string
func (*BackupBatchInvoker) GetObjectJSON ¶ added in v0.18.0
func (inv *BackupBatchInvoker) GetObjectJSON() (string, error)
func (*BackupBatchInvoker) GetObjectMeta ¶ added in v0.18.0
func (inv *BackupBatchInvoker) GetObjectMeta() metav1.ObjectMeta
func (*BackupBatchInvoker) GetObjectRef ¶ added in v0.18.0
func (inv *BackupBatchInvoker) GetObjectRef() (*core.ObjectReference, error)
func (*BackupBatchInvoker) GetOwnerRef ¶ added in v0.18.0
func (inv *BackupBatchInvoker) GetOwnerRef() *metav1.OwnerReference
func (*BackupBatchInvoker) GetPhase ¶ added in v0.18.0
func (inv *BackupBatchInvoker) GetPhase() v1beta1.BackupInvokerPhase
func (*BackupBatchInvoker) GetRepoRef ¶ added in v0.18.0
func (inv *BackupBatchInvoker) GetRepoRef() kmapi.ObjectReference
func (*BackupBatchInvoker) GetRepository ¶ added in v0.18.0
func (inv *BackupBatchInvoker) GetRepository() (*v1alpha1.Repository, error)
func (*BackupBatchInvoker) GetRetentionPolicy ¶ added in v0.18.0
func (inv *BackupBatchInvoker) GetRetentionPolicy() v1alpha1.RetentionPolicy
func (*BackupBatchInvoker) GetRuntimeSettings ¶ added in v0.18.0
func (inv *BackupBatchInvoker) GetRuntimeSettings() ofst.RuntimeSettings
func (*BackupBatchInvoker) GetSchedule ¶ added in v0.18.0
func (inv *BackupBatchInvoker) GetSchedule() string
func (*BackupBatchInvoker) GetTargetInfo ¶ added in v0.18.0
func (inv *BackupBatchInvoker) GetTargetInfo() []BackupTargetInfo
func (*BackupBatchInvoker) GetTypeMeta ¶ added in v0.18.0
func (inv *BackupBatchInvoker) GetTypeMeta() metav1.TypeMeta
func (*BackupBatchInvoker) HasCondition ¶ added in v0.18.0
func (*BackupBatchInvoker) IsConditionTrue ¶ added in v0.18.0
func (*BackupBatchInvoker) IsPaused ¶ added in v0.18.0
func (inv *BackupBatchInvoker) IsPaused() bool
func (*BackupBatchInvoker) NextInOrder ¶ added in v0.18.0
func (inv *BackupBatchInvoker) NextInOrder(curTarget v1beta1.TargetRef, targetStatus []v1beta1.BackupTargetStatus) bool
func (*BackupBatchInvoker) RemoveFinalizer ¶ added in v0.18.0
func (inv *BackupBatchInvoker) RemoveFinalizer() error
func (*BackupBatchInvoker) SetCondition ¶ added in v0.18.0
type BackupConfigurationInvoker ¶ added in v0.18.0
type BackupConfigurationInvoker struct {
// contains filtered or unexported fields
}
func (*BackupConfigurationInvoker) AddFinalizer ¶ added in v0.18.0
func (inv *BackupConfigurationInvoker) AddFinalizer() error
func (*BackupConfigurationInvoker) GetBackupHistoryLimit ¶ added in v0.18.0
func (inv *BackupConfigurationInvoker) GetBackupHistoryLimit() *int32
func (*BackupConfigurationInvoker) GetCondition ¶ added in v0.18.0
func (*BackupConfigurationInvoker) GetDriver ¶ added in v0.18.0
func (inv *BackupConfigurationInvoker) GetDriver() v1beta1.Snapshotter
func (*BackupConfigurationInvoker) GetExecutionOrder ¶ added in v0.18.0
func (inv *BackupConfigurationInvoker) GetExecutionOrder() v1beta1.ExecutionOrder
func (*BackupConfigurationInvoker) GetGlobalHooks ¶ added in v0.18.0
func (inv *BackupConfigurationInvoker) GetGlobalHooks() *v1beta1.BackupHooks
func (*BackupConfigurationInvoker) GetHash ¶ added in v0.18.0
func (inv *BackupConfigurationInvoker) GetHash() string
func (*BackupConfigurationInvoker) GetLabels ¶ added in v0.18.0
func (inv *BackupConfigurationInvoker) GetLabels() map[string]string
func (*BackupConfigurationInvoker) GetObjectJSON ¶ added in v0.18.0
func (inv *BackupConfigurationInvoker) GetObjectJSON() (string, error)
func (*BackupConfigurationInvoker) GetObjectMeta ¶ added in v0.18.0
func (inv *BackupConfigurationInvoker) GetObjectMeta() metav1.ObjectMeta
func (*BackupConfigurationInvoker) GetObjectRef ¶ added in v0.18.0
func (inv *BackupConfigurationInvoker) GetObjectRef() (*core.ObjectReference, error)
func (*BackupConfigurationInvoker) GetOwnerRef ¶ added in v0.18.0
func (inv *BackupConfigurationInvoker) GetOwnerRef() *metav1.OwnerReference
func (*BackupConfigurationInvoker) GetPhase ¶ added in v0.18.0
func (inv *BackupConfigurationInvoker) GetPhase() v1beta1.BackupInvokerPhase
func (*BackupConfigurationInvoker) GetRepoRef ¶ added in v0.18.0
func (inv *BackupConfigurationInvoker) GetRepoRef() kmapi.ObjectReference
func (*BackupConfigurationInvoker) GetRepository ¶ added in v0.18.0
func (inv *BackupConfigurationInvoker) GetRepository() (*v1alpha1.Repository, error)
func (*BackupConfigurationInvoker) GetRetentionPolicy ¶ added in v0.18.0
func (inv *BackupConfigurationInvoker) GetRetentionPolicy() v1alpha1.RetentionPolicy
func (*BackupConfigurationInvoker) GetRuntimeSettings ¶ added in v0.18.0
func (inv *BackupConfigurationInvoker) GetRuntimeSettings() ofst.RuntimeSettings
func (*BackupConfigurationInvoker) GetSchedule ¶ added in v0.18.0
func (inv *BackupConfigurationInvoker) GetSchedule() string
func (*BackupConfigurationInvoker) GetTargetInfo ¶ added in v0.18.0
func (inv *BackupConfigurationInvoker) GetTargetInfo() []BackupTargetInfo
func (*BackupConfigurationInvoker) GetTypeMeta ¶ added in v0.18.0
func (inv *BackupConfigurationInvoker) GetTypeMeta() metav1.TypeMeta
func (*BackupConfigurationInvoker) HasCondition ¶ added in v0.18.0
func (*BackupConfigurationInvoker) IsConditionTrue ¶ added in v0.18.0
func (*BackupConfigurationInvoker) IsPaused ¶ added in v0.18.0
func (inv *BackupConfigurationInvoker) IsPaused() bool
func (*BackupConfigurationInvoker) NextInOrder ¶ added in v0.18.0
func (inv *BackupConfigurationInvoker) NextInOrder(curTarget v1beta1.TargetRef, targetStatus []v1beta1.BackupTargetStatus) bool
func (*BackupConfigurationInvoker) RemoveFinalizer ¶ added in v0.18.0
func (inv *BackupConfigurationInvoker) RemoveFinalizer() error
func (*BackupConfigurationInvoker) SetCondition ¶ added in v0.18.0
type BackupExecutionOrderHandler ¶ added in v0.18.0
type BackupExecutionOrderHandler interface { GetExecutionOrder() v1beta1.ExecutionOrder NextInOrder(curTarget v1beta1.TargetRef, targetStatus []v1beta1.BackupTargetStatus) bool }
type BackupInvoker ¶
type BackupInvoker interface { MetadataHandler ConditionHandler BackupExecutionOrderHandler BackupTargetHandler RepositoryGetter DriverHandler ObjectFormatter BackupInvokerStatusHandler }
func NewBackupBatchInvoker ¶ added in v0.18.0
func NewBackupBatchInvoker(stashClient cs.Interface, backupBatch *v1beta1.BackupBatch) BackupInvoker
func NewBackupConfigurationInvoker ¶ added in v0.18.0
func NewBackupConfigurationInvoker(stashClient cs.Interface, backupConfig *v1beta1.BackupConfiguration) BackupInvoker
func NewBackupInvoker ¶ added in v0.18.0
func NewBackupInvoker(stashClient cs.Interface, kind, name, namespace string) (BackupInvoker, error)
type BackupInvokerStatusHandler ¶ added in v0.18.0
type BackupInvokerStatusHandler interface {
GetPhase() v1beta1.BackupInvokerPhase
}
type BackupTargetHandler ¶ added in v0.18.0
type BackupTargetHandler interface { GetTargetInfo() []BackupTargetInfo GetRuntimeSettings() ofst.RuntimeSettings GetSchedule() string GetRetentionPolicy() v1alpha1.RetentionPolicy IsPaused() bool GetBackupHistoryLimit() *int32 GetGlobalHooks() *v1beta1.BackupHooks }
type BackupTargetInfo ¶
type BackupTargetInfo struct { Task v1beta1.TaskRef Target *v1beta1.BackupTarget RuntimeSettings ofst.RuntimeSettings TempDir v1beta1.EmptyDirSettings InterimVolumeTemplate *ofst.PersistentVolumeClaim Hooks *v1beta1.BackupHooks }
type ConditionHandler ¶ added in v0.18.0
type ConditionHandler interface { HasCondition(target *v1beta1.TargetRef, conditionType string) (bool, error) GetCondition(target *v1beta1.TargetRef, conditionType string) (int, *kmapi.Condition, error) SetCondition(target *v1beta1.TargetRef, newCondition kmapi.Condition) error IsConditionTrue(target *v1beta1.TargetRef, conditionType string) (bool, error) }
type DriverHandler ¶ added in v0.18.0
type DriverHandler interface {
GetDriver() v1beta1.Snapshotter
}
type KubeDBIntegrator ¶ added in v0.18.0
type KubeDBIntegrator interface {
EnsureKubeDBIntegration(appClient appcatalog_cs.Interface) error
}
type MetadataHandler ¶ added in v0.18.0
type MetadataHandler interface { GetObjectMeta() metav1.ObjectMeta GetTypeMeta() metav1.TypeMeta GetObjectRef() (*core.ObjectReference, error) GetOwnerRef() *metav1.OwnerReference GetLabels() map[string]string AddFinalizer() error RemoveFinalizer() error }
type ObjectFormatter ¶ added in v0.18.0
type RepositoryGetter ¶ added in v0.18.0
type RepositoryGetter interface { GetRepoRef() kmapi.ObjectReference GetRepository() (*v1alpha1.Repository, error) }
type RestoreBatchInvoker ¶ added in v0.18.0
type RestoreBatchInvoker struct {
// contains filtered or unexported fields
}
func (*RestoreBatchInvoker) AddFinalizer ¶ added in v0.18.0
func (inv *RestoreBatchInvoker) AddFinalizer() error
func (*RestoreBatchInvoker) CreateEvent ¶ added in v0.18.0
func (inv *RestoreBatchInvoker) CreateEvent(eventType, source, reason, message string) error
func (*RestoreBatchInvoker) EnsureKubeDBIntegration ¶ added in v0.18.0
func (inv *RestoreBatchInvoker) EnsureKubeDBIntegration(appClient appcatalog_cs.Interface) error
func (*RestoreBatchInvoker) GetCondition ¶ added in v0.18.0
func (*RestoreBatchInvoker) GetDriver ¶ added in v0.18.0
func (inv *RestoreBatchInvoker) GetDriver() v1beta1.Snapshotter
func (*RestoreBatchInvoker) GetExecutionOrder ¶ added in v0.18.0
func (inv *RestoreBatchInvoker) GetExecutionOrder() v1beta1.ExecutionOrder
func (*RestoreBatchInvoker) GetGlobalHooks ¶ added in v0.18.0
func (inv *RestoreBatchInvoker) GetGlobalHooks() *v1beta1.RestoreHooks
func (*RestoreBatchInvoker) GetHash ¶ added in v0.18.0
func (inv *RestoreBatchInvoker) GetHash() string
func (*RestoreBatchInvoker) GetLabels ¶ added in v0.18.0
func (inv *RestoreBatchInvoker) GetLabels() map[string]string
func (*RestoreBatchInvoker) GetObjectJSON ¶ added in v0.18.0
func (inv *RestoreBatchInvoker) GetObjectJSON() (string, error)
func (*RestoreBatchInvoker) GetObjectMeta ¶ added in v0.18.0
func (inv *RestoreBatchInvoker) GetObjectMeta() metav1.ObjectMeta
func (*RestoreBatchInvoker) GetObjectRef ¶ added in v0.18.0
func (inv *RestoreBatchInvoker) GetObjectRef() (*core.ObjectReference, error)
func (*RestoreBatchInvoker) GetOwnerRef ¶ added in v0.18.0
func (inv *RestoreBatchInvoker) GetOwnerRef() *metav1.OwnerReference
func (*RestoreBatchInvoker) GetRepoRef ¶ added in v0.18.0
func (inv *RestoreBatchInvoker) GetRepoRef() kmapi.ObjectReference
func (*RestoreBatchInvoker) GetRepository ¶ added in v0.18.0
func (inv *RestoreBatchInvoker) GetRepository() (*v1alpha1.Repository, error)
func (*RestoreBatchInvoker) GetStatus ¶ added in v0.18.0
func (inv *RestoreBatchInvoker) GetStatus() RestoreInvokerStatus
func (*RestoreBatchInvoker) GetTargetInfo ¶ added in v0.18.0
func (inv *RestoreBatchInvoker) GetTargetInfo() []RestoreTargetInfo
func (*RestoreBatchInvoker) GetTypeMeta ¶ added in v0.18.0
func (inv *RestoreBatchInvoker) GetTypeMeta() metav1.TypeMeta
func (*RestoreBatchInvoker) HasCondition ¶ added in v0.18.0
func (*RestoreBatchInvoker) IsConditionTrue ¶ added in v0.18.0
func (*RestoreBatchInvoker) NextInOrder ¶ added in v0.18.0
func (inv *RestoreBatchInvoker) NextInOrder(curTarget v1beta1.TargetRef, targetStatus []v1beta1.RestoreMemberStatus) bool
func (*RestoreBatchInvoker) RemoveFinalizer ¶ added in v0.18.0
func (inv *RestoreBatchInvoker) RemoveFinalizer() error
func (*RestoreBatchInvoker) SetCondition ¶ added in v0.18.0
func (*RestoreBatchInvoker) UpdateStatus ¶ added in v0.18.0
func (inv *RestoreBatchInvoker) UpdateStatus(status RestoreInvokerStatus) error
type RestoreExecutionOrderHandler ¶ added in v0.18.0
type RestoreExecutionOrderHandler interface { GetExecutionOrder() v1beta1.ExecutionOrder NextInOrder(curTarget v1beta1.TargetRef, targetStatus []v1beta1.RestoreMemberStatus) bool }
type RestoreInvoker ¶
type RestoreInvoker interface { MetadataHandler ConditionHandler RestoreExecutionOrderHandler RestoreTargetHandler RepositoryGetter DriverHandler Eventer KubeDBIntegrator ObjectFormatter RestoreStatusHandler }
func NewRestoreBatchInvoker ¶ added in v0.18.0
func NewRestoreBatchInvoker(kubeClient kubernetes.Interface, stashClient cs.Interface, restoreBatch *v1beta1.RestoreBatch) RestoreInvoker
func NewRestoreInvoker ¶ added in v0.18.0
func NewRestoreInvoker(kubeClient kubernetes.Interface, stashClient cs.Interface, kind, name, namespace string) (RestoreInvoker, error)
func NewRestoreSessionInvoker ¶ added in v0.18.0
func NewRestoreSessionInvoker(kubeClient kubernetes.Interface, stashClient cs.Interface, restoreSession *v1beta1.RestoreSession) RestoreInvoker
type RestoreInvokerStatus ¶
type RestoreInvokerStatus struct { Phase v1beta1.RestorePhase SessionDuration string Conditions []kmapi.Condition TargetStatus []v1beta1.RestoreMemberStatus }
type RestoreSessionInvoker ¶ added in v0.18.0
type RestoreSessionInvoker struct {
// contains filtered or unexported fields
}
func (*RestoreSessionInvoker) AddFinalizer ¶ added in v0.18.0
func (inv *RestoreSessionInvoker) AddFinalizer() error
func (*RestoreSessionInvoker) CreateEvent ¶ added in v0.18.0
func (inv *RestoreSessionInvoker) CreateEvent(eventType, source, reason, message string) error
func (*RestoreSessionInvoker) EnsureKubeDBIntegration ¶ added in v0.18.0
func (inv *RestoreSessionInvoker) EnsureKubeDBIntegration(appClient appcatalog_cs.Interface) error
func (*RestoreSessionInvoker) GetCondition ¶ added in v0.18.0
func (*RestoreSessionInvoker) GetDriver ¶ added in v0.18.0
func (inv *RestoreSessionInvoker) GetDriver() v1beta1.Snapshotter
func (*RestoreSessionInvoker) GetExecutionOrder ¶ added in v0.18.0
func (inv *RestoreSessionInvoker) GetExecutionOrder() v1beta1.ExecutionOrder
func (*RestoreSessionInvoker) GetGlobalHooks ¶ added in v0.18.0
func (inv *RestoreSessionInvoker) GetGlobalHooks() *v1beta1.RestoreHooks
func (*RestoreSessionInvoker) GetHash ¶ added in v0.18.0
func (inv *RestoreSessionInvoker) GetHash() string
func (*RestoreSessionInvoker) GetLabels ¶ added in v0.18.0
func (inv *RestoreSessionInvoker) GetLabels() map[string]string
func (*RestoreSessionInvoker) GetObjectJSON ¶ added in v0.18.0
func (inv *RestoreSessionInvoker) GetObjectJSON() (string, error)
func (*RestoreSessionInvoker) GetObjectMeta ¶ added in v0.18.0
func (inv *RestoreSessionInvoker) GetObjectMeta() metav1.ObjectMeta
func (*RestoreSessionInvoker) GetObjectRef ¶ added in v0.18.0
func (inv *RestoreSessionInvoker) GetObjectRef() (*core.ObjectReference, error)
func (*RestoreSessionInvoker) GetOwnerRef ¶ added in v0.18.0
func (inv *RestoreSessionInvoker) GetOwnerRef() *metav1.OwnerReference
func (*RestoreSessionInvoker) GetRepoRef ¶ added in v0.18.0
func (inv *RestoreSessionInvoker) GetRepoRef() kmapi.ObjectReference
func (*RestoreSessionInvoker) GetRepository ¶ added in v0.18.0
func (inv *RestoreSessionInvoker) GetRepository() (*v1alpha1.Repository, error)
func (*RestoreSessionInvoker) GetStatus ¶ added in v0.18.0
func (inv *RestoreSessionInvoker) GetStatus() RestoreInvokerStatus
func (*RestoreSessionInvoker) GetTargetInfo ¶ added in v0.18.0
func (inv *RestoreSessionInvoker) GetTargetInfo() []RestoreTargetInfo
func (*RestoreSessionInvoker) GetTypeMeta ¶ added in v0.18.0
func (inv *RestoreSessionInvoker) GetTypeMeta() metav1.TypeMeta
func (*RestoreSessionInvoker) HasCondition ¶ added in v0.18.0
func (*RestoreSessionInvoker) IsConditionTrue ¶ added in v0.18.0
func (*RestoreSessionInvoker) NextInOrder ¶ added in v0.18.0
func (inv *RestoreSessionInvoker) NextInOrder(curTarget v1beta1.TargetRef, targetStatus []v1beta1.RestoreMemberStatus) bool
func (*RestoreSessionInvoker) RemoveFinalizer ¶ added in v0.18.0
func (inv *RestoreSessionInvoker) RemoveFinalizer() error
func (*RestoreSessionInvoker) SetCondition ¶ added in v0.18.0
func (*RestoreSessionInvoker) UpdateStatus ¶ added in v0.18.0
func (inv *RestoreSessionInvoker) UpdateStatus(status RestoreInvokerStatus) error
type RestoreStatusHandler ¶ added in v0.18.0
type RestoreStatusHandler interface { GetStatus() RestoreInvokerStatus UpdateStatus(newStatus RestoreInvokerStatus) error }
type RestoreTargetHandler ¶ added in v0.18.0
type RestoreTargetHandler interface { GetTargetInfo() []RestoreTargetInfo GetGlobalHooks() *v1beta1.RestoreHooks }
type RestoreTargetInfo ¶
type RestoreTargetInfo struct { Task v1beta1.TaskRef Target *v1beta1.RestoreTarget RuntimeSettings ofst.RuntimeSettings TempDir v1beta1.EmptyDirSettings InterimVolumeTemplate *ofst.PersistentVolumeClaim Hooks *v1beta1.RestoreHooks }
Click to show internal directories.
Click to hide internal directories.