invoker

Documentation

Index

• Constants
• 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 BackupInvoker
  • func ExtractBackupInvokerInfo(stashClient cs.Interface, invokerType, invokerName, namespace string) (BackupInvoker, error)
• type BackupTargetInfo
• type RestoreInvoker
  • func ExtractRestoreInvokerInfo(kubeClient kubernetes.Interface, stashClient cs.Interface, ...) (RestoreInvoker, error)
• type RestoreInvokerStatus
• type RestoreTargetInfo

Constants

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

Functions

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

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

func TargetRestoreCompleted

func TargetRestoreCompleted(ref v1beta1.TargetRef, targetStatus []v1beta1.RestoreMemberStatus) bool

Types

type BackupInvoker

type BackupInvoker struct {
	TypeMeta           metav1.TypeMeta
	ObjectMeta         metav1.ObjectMeta
	Labels             map[string]string
	Hash               string
	Driver             v1beta1.Snapshotter
	Schedule           string
	Paused             bool
	Repository         string
	RetentionPolicy    v1alpha1.RetentionPolicy
	RuntimeSettings    ofst.RuntimeSettings
	BackupHistoryLimit *int32
	TargetsInfo        []BackupTargetInfo
	ExecutionOrder     v1beta1.ExecutionOrder
	Hooks              *v1beta1.BackupHooks
	ObjectRef          *core.ObjectReference
	OwnerRef           *metav1.OwnerReference
	ObjectJson         []byte
	AddFinalizer       func() error
	RemoveFinalizer    func() error
	HasCondition       func(*v1beta1.TargetRef, string) (bool, error)
	GetCondition       func(*v1beta1.TargetRef, string) (int, *kmapi.Condition, error)
	SetCondition       func(*v1beta1.TargetRef, kmapi.Condition) error
	IsConditionTrue    func(*v1beta1.TargetRef, string) (bool, error)
	NextInOrder        func(v1beta1.TargetRef, []v1beta1.BackupTargetStatus) bool
}

func ExtractBackupInvokerInfo

func ExtractBackupInvokerInfo(stashClient cs.Interface, invokerType, invokerName, namespace string) (BackupInvoker, error)

type BackupTargetInfo

type BackupTargetInfo struct {
	Task                  v1beta1.TaskRef
	Target                *v1beta1.BackupTarget
	RuntimeSettings       ofst.RuntimeSettings
	TempDir               v1beta1.EmptyDirSettings
	InterimVolumeTemplate *ofst.PersistentVolumeClaim
	Hooks                 *v1beta1.BackupHooks
}

type RestoreInvoker

type RestoreInvoker struct {
	TypeMeta                metav1.TypeMeta
	ObjectMeta              metav1.ObjectMeta
	Labels                  map[string]string
	Hash                    string
	Driver                  v1beta1.Snapshotter
	Repository              string
	TargetsInfo             []RestoreTargetInfo
	ExecutionOrder          v1beta1.ExecutionOrder
	Hooks                   *v1beta1.RestoreHooks
	ObjectRef               *core.ObjectReference
	OwnerRef                *metav1.OwnerReference
	Status                  RestoreInvokerStatus
	ObjectJson              []byte
	AddFinalizer            func() error
	RemoveFinalizer         func() error
	HasCondition            func(*v1beta1.TargetRef, string) (bool, error)
	GetCondition            func(*v1beta1.TargetRef, string) (int, *kmapi.Condition, error)
	SetCondition            func(*v1beta1.TargetRef, kmapi.Condition) error
	IsConditionTrue         func(*v1beta1.TargetRef, string) (bool, error)
	NextInOrder             func(v1beta1.TargetRef, []v1beta1.RestoreMemberStatus) bool
	EnsureKubeDBIntegration func(appClient appcatalog_cs.Interface) (map[string]string, error)

	UpdateRestoreInvokerStatus func(status RestoreInvokerStatus) (RestoreInvokerStatus, error)
	CreateEvent                func(eventType, source, reason, message string) error
}

func ExtractRestoreInvokerInfo

func ExtractRestoreInvokerInfo(kubeClient kubernetes.Interface, stashClient cs.Interface, invokerType, invokerName, namespace string) (RestoreInvoker, error)

type RestoreInvokerStatus

type RestoreInvokerStatus struct {
	Phase           v1beta1.RestorePhase
	SessionDuration string
	Conditions      []kmapi.Condition
	TargetStatus    []v1beta1.RestoreMemberStatus
}

type RestoreTargetInfo

type RestoreTargetInfo struct {
	Task                  v1beta1.TaskRef
	Target                *v1beta1.RestoreTarget
	RuntimeSettings       ofst.RuntimeSettings
	TempDir               v1beta1.EmptyDirSettings
	InterimVolumeTemplate *ofst.PersistentVolumeClaim
	Hooks                 *v1beta1.RestoreHooks
}