datamover

Documentation

Index

• func GetRealSource(sourceNamespace string, pvcName string) string
• func GetUploaderType(dataMover string) string
• func IsBuiltInUploader(dataMover string) bool
• type BackupMicroService
  • func NewBackupMicroService(ctx context.Context, client client.Client, kubeClient kubernetes.Interface, ...) *BackupMicroService
  • func (r *BackupMicroService) Init() error
  • func (r *BackupMicroService) OnDataUploadCancelled(ctx context.Context, namespace string, duName string)
  • func (r *BackupMicroService) OnDataUploadCompleted(ctx context.Context, namespace string, duName string, result datapath.Result)
  • func (r *BackupMicroService) OnDataUploadFailed(ctx context.Context, namespace string, duName string, err error)
  • func (r *BackupMicroService) OnDataUploadProgress(ctx context.Context, namespace string, duName string, ...)
  • func (r *BackupMicroService) RunCancelableDataPath(ctx context.Context) (string, error)
  • func (r *BackupMicroService) Shutdown()
• type DataUploadDeleteAction
  • func NewDataUploadDeleteAction(logger logrus.FieldLogger, client client.Client) *DataUploadDeleteAction
  • func (d *DataUploadDeleteAction) AppliesTo() (velero.ResourceSelector, error)
  • func (d *DataUploadDeleteAction) Execute(input *velero.DeleteItemActionExecuteInput) error
• type RestoreMicroService
  • func NewRestoreMicroService(ctx context.Context, client client.Client, kubeClient kubernetes.Interface, ...) *RestoreMicroService
  • func (r *RestoreMicroService) Init() error
  • func (r *RestoreMicroService) OnDataDownloadCancelled(ctx context.Context, namespace string, ddName string)
  • func (r *RestoreMicroService) OnDataDownloadCompleted(ctx context.Context, namespace string, ddName string, result datapath.Result)
  • func (r *RestoreMicroService) OnDataDownloadFailed(ctx context.Context, namespace string, ddName string, err error)
  • func (r *RestoreMicroService) OnDataDownloadProgress(ctx context.Context, namespace string, ddName string, ...)
  • func (r *RestoreMicroService) RunCancelableDataPath(ctx context.Context) (string, error)
  • func (r *RestoreMicroService) Shutdown()

Functions

func GetRealSource

func GetRealSource(sourceNamespace string, pvcName string) string

func GetUploaderType

func GetUploaderType(dataMover string) string

func IsBuiltInUploader

func IsBuiltInUploader(dataMover string) bool

Types

type BackupMicroService

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

BackupMicroService process data mover backups inside the backup pod

func NewBackupMicroService

func NewBackupMicroService(ctx context.Context, client client.Client, kubeClient kubernetes.Interface, dataUploadName string, namespace string, nodeName string,
	sourceTargetPath datapath.AccessPoint, dataPathMgr *datapath.Manager, repoEnsurer *repository.Ensurer, cred *credentials.CredentialGetter,
	duInformer cache.Informer, log logrus.FieldLogger) *BackupMicroService

func (*BackupMicroService) Init

func (r *BackupMicroService) Init() error

func (*BackupMicroService) OnDataUploadCancelled

func (r *BackupMicroService) OnDataUploadCancelled(ctx context.Context, namespace string, duName string)

func (*BackupMicroService) OnDataUploadCompleted

func (r *BackupMicroService) OnDataUploadCompleted(ctx context.Context, namespace string, duName string, result datapath.Result)

func (*BackupMicroService) OnDataUploadFailed

func (r *BackupMicroService) OnDataUploadFailed(ctx context.Context, namespace string, duName string, err error)

func (*BackupMicroService) OnDataUploadProgress

func (r *BackupMicroService) OnDataUploadProgress(ctx context.Context, namespace string, duName string, progress *uploader.Progress)

func (*BackupMicroService) RunCancelableDataPath

func (r *BackupMicroService) RunCancelableDataPath(ctx context.Context) (string, error)

func (*BackupMicroService) Shutdown

func (r *BackupMicroService) Shutdown()

type DataUploadDeleteAction

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

func NewDataUploadDeleteAction

func NewDataUploadDeleteAction(logger logrus.FieldLogger, client client.Client) *DataUploadDeleteAction

func (*DataUploadDeleteAction) AppliesTo

func (d *DataUploadDeleteAction) AppliesTo() (velero.ResourceSelector, error)

func (*DataUploadDeleteAction) Execute

func (d *DataUploadDeleteAction) Execute(input *velero.DeleteItemActionExecuteInput) error

type RestoreMicroService

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

RestoreMicroService process data mover restores inside the restore pod

func NewRestoreMicroService

func NewRestoreMicroService(ctx context.Context, client client.Client, kubeClient kubernetes.Interface, dataDownloadName string, namespace string, nodeName string,
	sourceTargetPath datapath.AccessPoint, dataPathMgr *datapath.Manager, repoEnsurer *repository.Ensurer, cred *credentials.CredentialGetter,
	ddInformer cache.Informer, log logrus.FieldLogger) *RestoreMicroService

func (*RestoreMicroService) Init

func (r *RestoreMicroService) Init() error

func (*RestoreMicroService) OnDataDownloadCancelled

func (r *RestoreMicroService) OnDataDownloadCancelled(ctx context.Context, namespace string, ddName string)

func (*RestoreMicroService) OnDataDownloadCompleted

func (r *RestoreMicroService) OnDataDownloadCompleted(ctx context.Context, namespace string, ddName string, result datapath.Result)

func (*RestoreMicroService) OnDataDownloadFailed

func (r *RestoreMicroService) OnDataDownloadFailed(ctx context.Context, namespace string, ddName string, err error)

func (*RestoreMicroService) OnDataDownloadProgress

func (r *RestoreMicroService) OnDataDownloadProgress(ctx context.Context, namespace string, ddName string, progress *uploader.Progress)

func (*RestoreMicroService) RunCancelableDataPath

func (r *RestoreMicroService) RunCancelableDataPath(ctx context.Context) (string, error)

func (*RestoreMicroService) Shutdown

func (r *RestoreMicroService) Shutdown()