snapshot

Documentation

Index

• func CreateRestorePVCDef(restorePVCName string, volumeSnapshot *vsv1.VolumeSnapshot, ...) *corev1.PersistentVolumeClaim
• func CreateRestorePVCDefFromVMRestore(vmRestoreName, restorePVCName string, volumeSnapshot *vsv1.VolumeSnapshot, ...) *corev1.PersistentVolumeClaim
• func VmRestoreProgressing(vmRestore *snapshotv1.VirtualMachineRestore) bool
• func VmSnapshotReady(vmSnapshot *snapshotv1.VirtualMachineSnapshot) bool
• type VMRestoreController
  • func (ctrl *VMRestoreController) Init()
  • func (ctrl *VMRestoreController) Run(threadiness int, stopCh <-chan struct{}) error
• type VMSnapshotController
  • func (ctrl *VMSnapshotController) GetVolumeSnapshot(namespace, name string) (*vsv1.VolumeSnapshot, error)
  • func (ctrl *VMSnapshotController) Init()
  • func (ctrl *VMSnapshotController) Run(threadiness int, stopCh <-chan struct{}) error
• type VolumeSnapshotProvider

Functions

func CreateRestorePVCDef

func CreateRestorePVCDef(restorePVCName string, volumeSnapshot *vsv1.VolumeSnapshot, volumeBackup *snapshotv1.VolumeBackup) *corev1.PersistentVolumeClaim

func CreateRestorePVCDefFromVMRestore

func CreateRestorePVCDefFromVMRestore(vmRestoreName, restorePVCName string, volumeSnapshot *vsv1.VolumeSnapshot, volumeBackup *snapshotv1.VolumeBackup, sourceVmName, sourceVmNamespace string) *corev1.PersistentVolumeClaim

func VmRestoreProgressing

func VmRestoreProgressing(vmRestore *snapshotv1.VirtualMachineRestore) bool

func VmSnapshotReady

func VmSnapshotReady(vmSnapshot *snapshotv1.VirtualMachineSnapshot) bool

Types

type VMRestoreController

type VMRestoreController struct {
	Client kubecli.KubevirtClient

	VMRestoreInformer         cache.SharedIndexInformer
	VMSnapshotInformer        cache.SharedIndexInformer
	VMSnapshotContentInformer cache.SharedIndexInformer
	VMInformer                cache.SharedIndexInformer
	VMIInformer               cache.SharedIndexInformer
	DataVolumeInformer        cache.SharedIndexInformer
	PVCInformer               cache.SharedIndexInformer
	StorageClassInformer      cache.SharedIndexInformer

	VolumeSnapshotProvider VolumeSnapshotProvider

	Recorder record.EventRecorder
	// contains filtered or unexported fields
}

VMRestoreController is resonsible for restoring VMs

func (*VMRestoreController) Init

func (ctrl *VMRestoreController) Init()

Init initializes the restore controller

func (*VMRestoreController) Run

func (ctrl *VMRestoreController) Run(threadiness int, stopCh <-chan struct{}) error

Run the controller

type VMSnapshotController

type VMSnapshotController struct {
	Client kubecli.KubevirtClient

	VMSnapshotInformer        cache.SharedIndexInformer
	VMSnapshotContentInformer cache.SharedIndexInformer
	VMInformer                cache.SharedIndexInformer
	VMIInformer               cache.SharedIndexInformer
	StorageClassInformer      cache.SharedIndexInformer
	PVCInformer               cache.SharedIndexInformer
	CRDInformer               cache.SharedIndexInformer
	PodInformer               cache.SharedIndexInformer
	DVInformer                cache.SharedIndexInformer
	CRInformer                cache.SharedIndexInformer

	Recorder record.EventRecorder

	ResyncPeriod time.Duration
	// contains filtered or unexported fields
}

VMSnapshotController is resonsible for snapshotting VMs

func (*VMSnapshotController) GetVolumeSnapshot

func (ctrl *VMSnapshotController) GetVolumeSnapshot(namespace, name string) (*vsv1.VolumeSnapshot, error)

func (*VMSnapshotController) Init

func (ctrl *VMSnapshotController) Init()

Init initializes the snapshot controller

func (*VMSnapshotController) Run

func (ctrl *VMSnapshotController) Run(threadiness int, stopCh <-chan struct{}) error

Run the controller

type VolumeSnapshotProvider

type VolumeSnapshotProvider interface {
	GetVolumeSnapshot(string, string) (*vsv1.VolumeSnapshot, error)
}