dataMover

Documentation

Index

• type DataMover
  • func NewDataMoverFromCluster(params map[string]interface{}, logger logrus.FieldLogger) (*DataMover, error)
  • func (this *DataMover) CancelUpload(peID astrolabe.ProtectedEntityID) error
  • func (this *DataMover) CopyFromRepo(peID astrolabe.ProtectedEntityID, targetPEID astrolabe.ProtectedEntityID, ...) (astrolabe.ProtectedEntityID, error)
  • func (this *DataMover) CopyFromRepoWithBackupRepository(peID astrolabe.ProtectedEntityID, targetPEID astrolabe.ProtectedEntityID, ...) (astrolabe.ProtectedEntityID, error)
  • func (this *DataMover) CopyToRepo(peID astrolabe.ProtectedEntityID) (astrolabe.ProtectedEntityID, error)
  • func (this *DataMover) CopyToRepoWithBackupRepository(peID astrolabe.ProtectedEntityID, ...) (astrolabe.ProtectedEntityID, error)
  • func (this *DataMover) IsUploading(peID astrolabe.ProtectedEntityID) bool
  • func (this *DataMover) RegisterOngoingUpload(peID astrolabe.ProtectedEntityID, cancelFunc context.CancelFunc)
  • func (this *DataMover) ReloadDataMoverIvdPetmConfig(params map[string]interface{}) error
  • func (this *DataMover) UnregisterOngoingUpload(peID astrolabe.ProtectedEntityID)

Types

type DataMover

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

func NewDataMoverFromCluster

func NewDataMoverFromCluster(params map[string]interface{}, logger logrus.FieldLogger) (*DataMover, error)

func (*DataMover) CancelUpload

func (this *DataMover) CancelUpload(peID astrolabe.ProtectedEntityID) error

func (*DataMover) CopyFromRepo

func (this *DataMover) CopyFromRepo(peID astrolabe.ProtectedEntityID, targetPEID astrolabe.ProtectedEntityID, options astrolabe.CopyCreateOptions) (astrolabe.ProtectedEntityID, error)

func (*DataMover) CopyFromRepoWithBackupRepository

func (this *DataMover) CopyFromRepoWithBackupRepository(peID astrolabe.ProtectedEntityID, targetPEID astrolabe.ProtectedEntityID, backupRepository *backupdriverv1.BackupRepository, options astrolabe.CopyCreateOptions) (astrolabe.ProtectedEntityID, error)

func (*DataMover) CopyToRepo

func (this *DataMover) CopyToRepo(peID astrolabe.ProtectedEntityID) (astrolabe.ProtectedEntityID, error)

func (*DataMover) CopyToRepoWithBackupRepository

func (this *DataMover) CopyToRepoWithBackupRepository(peID astrolabe.ProtectedEntityID, backupRepository *backupdriverv1.BackupRepository) (astrolabe.ProtectedEntityID, error)

func (*DataMover) IsUploading

func (this *DataMover) IsUploading(peID astrolabe.ProtectedEntityID) bool

func (*DataMover) RegisterOngoingUpload

func (this *DataMover) RegisterOngoingUpload(peID astrolabe.ProtectedEntityID, cancelFunc context.CancelFunc)

func (*DataMover) ReloadDataMoverIvdPetmConfig

func (this *DataMover) ReloadDataMoverIvdPetmConfig(params map[string]interface{}) error

func (*DataMover) UnregisterOngoingUpload

func (this *DataMover) UnregisterOngoingUpload(peID astrolabe.ProtectedEntityID)