invoker

package
v0.37.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 17, 2024 License: Apache-2.0 Imports: 27 Imported by: 15

Documentation

Index

Constants

View Source 
const (
	EventSourceRestoreBatchController   = "RestoreBatch Controller"
	EventSourceRestoreSessionController = "RestoreSession Controller"
)

Variables

This section is empty.

Functions

func BackupCompletedForAllTargets added in v0.19.0 

func BackupCompletedForAllTargets(status []v1beta1.BackupTargetStatus, totalTargets int) bool

func CalculateBackupInvokerPhase added in v0.19.0 

func CalculateBackupInvokerPhase(driver v1beta1.Snapshotter, conditions []kmapi.Condition) v1beta1.BackupInvokerPhase

func IsBackupCompleted added in v0.19.0 

func IsBackupCompleted(phase v1beta1.BackupSessionPhase) bool

func IsRestoreCompleted added in v0.18.0 

func IsRestoreCompleted(phase v1beta1.RestorePhase) bool

func RestoreCompletedForAllTargets added in v0.19.0 

func RestoreCompletedForAllTargets(status []v1beta1.RestoreMemberStatus, totalTargets int) 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 TargetMatched(t1, t2 v1beta1.TargetRef) bool

func TargetOfGroupKind added in v0.11.11 

func TargetOfGroupKind(targetRef v1beta1.TargetRef, group, kind string) bool

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 (inv *BackupBatchInvoker) GetCondition(target *v1beta1.TargetRef, conditionType string) (int, *kmapi.Condition, error)

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) GetRetryConfig added in v0.23.0 

func (inv *BackupBatchInvoker) GetRetryConfig() *v1beta1.RetryConfig

func (*BackupBatchInvoker) GetRuntimeObject added in v0.19.0 

func (inv *BackupBatchInvoker) GetRuntimeObject() runtime.Object

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) GetSummary added in v0.19.0 

func (inv *BackupBatchInvoker) GetSummary(target v1beta1.TargetRef, session kmapi.ObjectReference) *v1beta1.Summary

func (*BackupBatchInvoker) GetTargetInfo added in v0.18.0 

func (inv *BackupBatchInvoker) GetTargetInfo() []BackupTargetInfo

func (*BackupBatchInvoker) GetTimeOut added in v0.21.0 

func (inv *BackupBatchInvoker) GetTimeOut() *metav1.Duration

func (*BackupBatchInvoker) GetTypeMeta added in v0.18.0 

func (inv *BackupBatchInvoker) GetTypeMeta() metav1.TypeMeta

func (*BackupBatchInvoker) HasCondition added in v0.18.0 

func (inv *BackupBatchInvoker) HasCondition(target *v1beta1.TargetRef, conditionType string) (bool, error)

func (*BackupBatchInvoker) IsConditionTrue added in v0.18.0 

func (inv *BackupBatchInvoker) IsConditionTrue(target *v1beta1.TargetRef, conditionType string) (bool, error)

func (*BackupBatchInvoker) IsPaused added in v0.18.0 

func (inv *BackupBatchInvoker) IsPaused() bool

func (*BackupBatchInvoker) NewSession added in v0.23.0 

func (inv *BackupBatchInvoker) NewSession() *v1beta1.BackupSession

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 

func (inv *BackupBatchInvoker) SetCondition(target *v1beta1.TargetRef, newCondition kmapi.Condition) error

func (*BackupBatchInvoker) UpdateObservedGeneration added in v0.23.0 

func (inv *BackupBatchInvoker) UpdateObservedGeneration() error

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 (inv *BackupConfigurationInvoker) GetCondition(target *v1beta1.TargetRef, conditionType string) (int, *kmapi.Condition, error)

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) GetRetryConfig added in v0.23.0 

func (inv *BackupConfigurationInvoker) GetRetryConfig() *v1beta1.RetryConfig

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) GetSummary added in v0.19.0 

func (inv *BackupConfigurationInvoker) GetSummary(target v1beta1.TargetRef, session kmapi.ObjectReference) *v1beta1.Summary

func (*BackupConfigurationInvoker) GetTargetInfo added in v0.18.0 

func (inv *BackupConfigurationInvoker) GetTargetInfo() []BackupTargetInfo

func (*BackupConfigurationInvoker) GetTimeOut added in v0.21.0 

func (inv *BackupConfigurationInvoker) GetTimeOut() *metav1.Duration

func (*BackupConfigurationInvoker) GetTypeMeta added in v0.18.0 

func (inv *BackupConfigurationInvoker) GetTypeMeta() metav1.TypeMeta

func (*BackupConfigurationInvoker) HasCondition added in v0.18.0 

func (inv *BackupConfigurationInvoker) HasCondition(target *v1beta1.TargetRef, conditionType string) (bool, error)

func (*BackupConfigurationInvoker) IsConditionTrue added in v0.18.0 

func (inv *BackupConfigurationInvoker) IsConditionTrue(target *v1beta1.TargetRef, conditionType string) (bool, error)

func (*BackupConfigurationInvoker) IsPaused added in v0.18.0 

func (inv *BackupConfigurationInvoker) IsPaused() bool

func (*BackupConfigurationInvoker) NewSession added in v0.23.0 

func (inv *BackupConfigurationInvoker) NewSession() *v1beta1.BackupSession

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 

func (inv *BackupConfigurationInvoker) SetCondition(target *v1beta1.TargetRef, newCondition kmapi.Condition) error

func (*BackupConfigurationInvoker) UpdateObservedGeneration added in v0.23.0 

func (inv *BackupConfigurationInvoker) UpdateObservedGeneration() error

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
	SessionHandler
	BackupExecutionOrderHandler
	BackupTargetHandler
	RepositoryGetter
	DriverHandler
	TimeOutGetter
	ObjectFormatter
	BackupInvokerStatusHandler
	Summarizer
	RetryHandler
}

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
	UpdateObservedGeneration() error
}

type BackupSessionHandler added in v0.19.0 

type BackupSessionHandler struct {
	// contains filtered or unexported fields
}

func NewBackupSessionHandler added in v0.19.0 

func NewBackupSessionHandler(stashClient cs.Interface, backupSession *v1beta1.BackupSession) *BackupSessionHandler

func (*BackupSessionHandler) GetBackupSession added in v0.19.0 

func (h *BackupSessionHandler) GetBackupSession() *v1beta1.BackupSession

func (*BackupSessionHandler) GetConditions added in v0.19.0 

func (h *BackupSessionHandler) GetConditions() []kmapi.Condition

func (*BackupSessionHandler) GetInvoker added in v0.19.0 

func (h *BackupSessionHandler) GetInvoker() (BackupInvoker, error)

func (*BackupSessionHandler) GetInvokerRef added in v0.19.0 

func (h *BackupSessionHandler) GetInvokerRef() v1beta1.BackupInvokerRef

func (*BackupSessionHandler) GetObjectMeta added in v0.19.0 

func (h *BackupSessionHandler) GetObjectMeta() metav1.ObjectMeta

func (*BackupSessionHandler) GetStatus added in v0.19.0 

func (h *BackupSessionHandler) GetStatus() v1beta1.BackupSessionStatus

func (*BackupSessionHandler) GetTargetConditions added in v0.19.0 

func (h *BackupSessionHandler) GetTargetConditions(target v1beta1.TargetRef) []kmapi.Condition

func (*BackupSessionHandler) GetTargetStatus added in v0.19.0 

func (h *BackupSessionHandler) GetTargetStatus() []v1beta1.BackupTargetStatus

func (*BackupSessionHandler) UpdateStatus added in v0.19.0 

func (h *BackupSessionHandler) UpdateStatus(status *v1beta1.BackupSessionStatus) error

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 Eventer added in v0.18.0 

type Eventer interface {
	CreateEvent(eventType, source, reason, message string) error
}

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 ObjectFormatter interface {
	GetHash() string
	GetObjectJSON() (string, error)
}

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 (inv *RestoreBatchInvoker) GetCondition(target *v1beta1.TargetRef, conditionType string) (int, *kmapi.Condition, error)

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) GetRuntimeObject added in v0.19.0 

func (inv *RestoreBatchInvoker) GetRuntimeObject() runtime.Object

func (*RestoreBatchInvoker) GetStatus added in v0.18.0 

func (inv *RestoreBatchInvoker) GetStatus() RestoreInvokerStatus

func (*RestoreBatchInvoker) GetSummary added in v0.19.0 

func (inv *RestoreBatchInvoker) GetSummary(target v1beta1.TargetRef, session kmapi.ObjectReference) *v1beta1.Summary

func (*RestoreBatchInvoker) GetTargetInfo added in v0.18.0 

func (inv *RestoreBatchInvoker) GetTargetInfo() []RestoreTargetInfo

func (*RestoreBatchInvoker) GetTimeOut added in v0.21.0 

func (inv *RestoreBatchInvoker) GetTimeOut() *metav1.Duration

func (*RestoreBatchInvoker) GetTypeMeta added in v0.18.0 

func (inv *RestoreBatchInvoker) GetTypeMeta() metav1.TypeMeta

func (*RestoreBatchInvoker) HasCondition added in v0.18.0 

func (inv *RestoreBatchInvoker) HasCondition(target *v1beta1.TargetRef, conditionType string) (bool, error)

func (*RestoreBatchInvoker) IsConditionTrue added in v0.18.0 

func (inv *RestoreBatchInvoker) IsConditionTrue(target *v1beta1.TargetRef, conditionType string) (bool, error)

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 (inv *RestoreBatchInvoker) SetCondition(target *v1beta1.TargetRef, newCondition kmapi.Condition) error

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
	TimeOutGetter
	Eventer
	KubeDBIntegrator
	ObjectFormatter
	RestoreStatusHandler
	Summarizer
}

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
	SessionDeadline *metav1.Time
	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 (inv *RestoreSessionInvoker) GetCondition(target *v1beta1.TargetRef, conditionType string) (int, *kmapi.Condition, error)

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) GetRuntimeObject added in v0.19.0 

func (inv *RestoreSessionInvoker) GetRuntimeObject() runtime.Object

func (*RestoreSessionInvoker) GetStatus added in v0.18.0 

func (inv *RestoreSessionInvoker) GetStatus() RestoreInvokerStatus

func (*RestoreSessionInvoker) GetSummary added in v0.19.0 

func (inv *RestoreSessionInvoker) GetSummary(target v1beta1.TargetRef, session kmapi.ObjectReference) *v1beta1.Summary

func (*RestoreSessionInvoker) GetTargetInfo added in v0.18.0 

func (inv *RestoreSessionInvoker) GetTargetInfo() []RestoreTargetInfo

func (*RestoreSessionInvoker) GetTimeOut added in v0.21.0 

func (inv *RestoreSessionInvoker) GetTimeOut() *metav1.Duration

func (*RestoreSessionInvoker) GetTypeMeta added in v0.18.0 

func (inv *RestoreSessionInvoker) GetTypeMeta() metav1.TypeMeta

func (*RestoreSessionInvoker) HasCondition added in v0.18.0 

func (inv *RestoreSessionInvoker) HasCondition(target *v1beta1.TargetRef, conditionType string) (bool, error)

func (*RestoreSessionInvoker) IsConditionTrue added in v0.18.0 

func (inv *RestoreSessionInvoker) IsConditionTrue(target *v1beta1.TargetRef, conditionType string) (bool, error)

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 (inv *RestoreSessionInvoker) SetCondition(target *v1beta1.TargetRef, newCondition kmapi.Condition) error

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
}

type RetryHandler added in v0.23.0 

type RetryHandler interface {
	GetRetryConfig() *v1beta1.RetryConfig
}

type SessionHandler added in v0.23.0 

type SessionHandler interface {
	NewSession() *v1beta1.BackupSession
}

type Summarizer added in v0.19.0 

type Summarizer interface {
	GetSummary(target v1beta1.TargetRef, session kmapi.ObjectReference) *v1beta1.Summary
}

type TimeOutGetter added in v0.21.0 

type TimeOutGetter interface {
	GetTimeOut() *metav1.Duration
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.