invoker

package
v0.18.0 Latest Latest
Warning

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

Go to latest
Published: Feb 10, 2022 License: Apache-2.0 Imports: 22 Imported by: 15

Documentation

Index

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 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 (*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 (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) 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

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 (*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 (*BackupConfigurationInvoker) GetRepoRef added in v0.18.0

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 (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) 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

type BackupExecutionOrderHandler added in v0.18.0

type BackupExecutionOrderHandler interface {
	GetExecutionOrder() v1beta1.ExecutionOrder
	NextInOrder(curTarget v1beta1.TargetRef, targetStatus []v1beta1.BackupTargetStatus) bool
}

type BackupInvoker

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 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) 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 (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

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 (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) GetStatus added in v0.18.0

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 (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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL