snapshotmgr

Documentation

Index

• Constants
• type DataManagerProtectedEntity
  • func (this DataManagerProtectedEntity) Overwrite(ctx context.Context, sourcePE astrolabe.ProtectedEntity, ...) error
• type DataManagerProtectedEntityTypeManager
  • func NewDataManagerProtectedEntityTypeManager(sourcePETM astrolabe.ProtectedEntityTypeManager, snapshotMGR *SnapshotManager, ...) DataManagerProtectedEntityTypeManager
  • func (this DataManagerProtectedEntityTypeManager) Copy(ctx context.Context, pe astrolabe.ProtectedEntity, ...) (astrolabe.ProtectedEntity, error)
  • func (this DataManagerProtectedEntityTypeManager) CopyFromInfo(ctx context.Context, info astrolabe.ProtectedEntityInfo, ...) (astrolabe.ProtectedEntity, error)
  • func (this DataManagerProtectedEntityTypeManager) GetProtectedEntity(ctx context.Context, id astrolabe.ProtectedEntityID) (astrolabe.ProtectedEntity, error)
  • func (this DataManagerProtectedEntityTypeManager) ReloadDmIvdPetm(ctx context.Context, ivdParams map[string]interface{}, ...) error
• type SnapshotManager
  • func NewSnapshotManagerFromCluster(params map[string]interface{}, config map[string]string, ...) (*SnapshotManager, error)
  • func NewSnapshotManagerFromConfig(configInfo server.ConfigInfo, s3RepoParams map[string]interface{}, ...) (*SnapshotManager, error)
  • func (this *SnapshotManager) CreateSnapshot(peID astrolabe.ProtectedEntityID, tags map[string]string) (astrolabe.ProtectedEntityID, error)
  • func (this *SnapshotManager) CreateSnapshotWithBackupRepository(peID astrolabe.ProtectedEntityID, tags map[string]string, ...) (astrolabe.ProtectedEntityID, string, error)
  • func (this *SnapshotManager) CreateVolumeFromSnapshot(sourcePEID astrolabe.ProtectedEntityID, ...) (updatedID astrolabe.ProtectedEntityID, err error)
  • func (this *SnapshotManager) CreateVolumeFromSnapshotWithMetadata(peID astrolabe.ProtectedEntityID, metadata []byte, snapshotIDStr string, ...) (astrolabe.ProtectedEntityID, error)
  • func (this *SnapshotManager) DeleteLocalSnapshot(peID astrolabe.ProtectedEntityID) error
  • func (this *SnapshotManager) DeleteRemoteSnapshot(peID astrolabe.ProtectedEntityID) error
  • func (this *SnapshotManager) DeleteRemoteSnapshotFromRepo(peID astrolabe.ProtectedEntityID, ...) error
  • func (this *SnapshotManager) DeleteSnapshot(peID astrolabe.ProtectedEntityID) error
  • func (this *SnapshotManager) DeleteSnapshotWithBackupRepository(peID astrolabe.ProtectedEntityID, backupRepository string, ...) error
  • func (this *SnapshotManager) ReloadSnapshotManagerIvdPetmConfig(ivdParams map[string]interface{}) error
  • func (this *SnapshotManager) UploadSnapshot(uploadPE astrolabe.ProtectedEntity, ctx context.Context, ...) (*v1api.Upload, error)

Constants

const PollLogInterval = time.Minute

Types

type DataManagerProtectedEntity

type DataManagerProtectedEntity struct {
	astrolabe.ProtectedEntity
	// contains filtered or unexported fields
}

func (DataManagerProtectedEntity) Overwrite

func (this DataManagerProtectedEntity) Overwrite(ctx context.Context, sourcePE astrolabe.ProtectedEntity, params map[string]map[string]interface{}, overwriteComponents bool) error

type DataManagerProtectedEntityTypeManager

type DataManagerProtectedEntityTypeManager struct {
	astrolabe.ProtectedEntityTypeManager
	// contains filtered or unexported fields
}

func NewDataManagerProtectedEntityTypeManager

func NewDataManagerProtectedEntityTypeManager(sourcePETM astrolabe.ProtectedEntityTypeManager,
	snapshotMGR *SnapshotManager, upload bool) DataManagerProtectedEntityTypeManager

Creates a DataManagerProtectedEntityTypeManager that wrappers the sourcePETM (and by extension, the PEs managed by the source PETM). Data Manager currently has upload and download CRs. If upload is set, Copy, CopyFromInfo and Overwrite will generate Upload CRs to the source PETM type. If not set, Download CRs will be generated

func (DataManagerProtectedEntityTypeManager) Copy

func (this DataManagerProtectedEntityTypeManager) Copy(ctx context.Context, pe astrolabe.ProtectedEntity,
	params map[string]map[string]interface{}, options astrolabe.CopyCreateOptions) (astrolabe.ProtectedEntity, error)

func (DataManagerProtectedEntityTypeManager) CopyFromInfo

func (this DataManagerProtectedEntityTypeManager) CopyFromInfo(ctx context.Context, info astrolabe.ProtectedEntityInfo, params map[string]map[string]interface{}, options astrolabe.CopyCreateOptions) (astrolabe.ProtectedEntity, error)

func (DataManagerProtectedEntityTypeManager) GetProtectedEntity

func (this DataManagerProtectedEntityTypeManager) GetProtectedEntity(ctx context.Context, id astrolabe.ProtectedEntityID) (astrolabe.ProtectedEntity, error)

func (DataManagerProtectedEntityTypeManager) ReloadDmIvdPetm

func (this DataManagerProtectedEntityTypeManager) ReloadDmIvdPetm(ctx context.Context, ivdParams map[string]interface{}, logger logrus.FieldLogger) error

type SnapshotManager

type SnapshotManager struct {
	logrus.FieldLogger

	Pem astrolabe.ProtectedEntityManager
	// contains filtered or unexported fields
}

func NewSnapshotManagerFromCluster

func NewSnapshotManagerFromCluster(params map[string]interface{}, config map[string]string, logger logrus.FieldLogger) (*SnapshotManager, error)

TODO - remove in favor of NewSnapshotManagerFromConfig when callers have been converted

func NewSnapshotManagerFromConfig

func NewSnapshotManagerFromConfig(configInfo server.ConfigInfo, s3RepoParams map[string]interface{},
	config map[string]string, k8sRestConfig *rest.Config, logger logrus.FieldLogger) (*SnapshotManager, error)

func (*SnapshotManager) CreateSnapshot

func (this *SnapshotManager) CreateSnapshot(peID astrolabe.ProtectedEntityID, tags map[string]string) (astrolabe.ProtectedEntityID, error)

func (*SnapshotManager) CreateSnapshotWithBackupRepository

func (this *SnapshotManager) CreateSnapshotWithBackupRepository(peID astrolabe.ProtectedEntityID, tags map[string]string,
	backupRepositoryName string, snapshotRef string, backupName string) (astrolabe.ProtectedEntityID, string, error)

func (*SnapshotManager) CreateVolumeFromSnapshot

func (this *SnapshotManager) CreateVolumeFromSnapshot(sourcePEID astrolabe.ProtectedEntityID, destinationPEID astrolabe.ProtectedEntityID, params map[string]map[string]interface{}) (updatedID astrolabe.ProtectedEntityID, err error)

func (*SnapshotManager) CreateVolumeFromSnapshotWithMetadata

func (this *SnapshotManager) CreateVolumeFromSnapshotWithMetadata(peID astrolabe.ProtectedEntityID, metadata []byte,
	snapshotIDStr string, backupRepositoryName string, cloneFromSnapshotNamespace string, cloneFromSnapshotName string) (astrolabe.ProtectedEntityID, error)

func (*SnapshotManager) DeleteLocalSnapshot

func (this *SnapshotManager) DeleteLocalSnapshot(peID astrolabe.ProtectedEntityID) error

func (*SnapshotManager) DeleteRemoteSnapshot

func (this *SnapshotManager) DeleteRemoteSnapshot(peID astrolabe.ProtectedEntityID) error

Will be deleted eventually. Use S3PETM created from backup repository instead of hard coding S3PETM which is initialized when NewSnapshotManagerFromCluster Eventually will use DeleteRemoteSnapshotFromRepo instead of this

func (*SnapshotManager) DeleteRemoteSnapshotFromRepo

func (this *SnapshotManager) DeleteRemoteSnapshotFromRepo(peID astrolabe.ProtectedEntityID, backupRepository *backupdriverv1.BackupRepository) error

func (*SnapshotManager) DeleteSnapshot

func (this *SnapshotManager) DeleteSnapshot(peID astrolabe.ProtectedEntityID) error

func (*SnapshotManager) DeleteSnapshotWithBackupRepository

func (this *SnapshotManager) DeleteSnapshotWithBackupRepository(peID astrolabe.ProtectedEntityID,
	backupRepository string, deleteSnapshotCRName string) error

func (*SnapshotManager) ReloadSnapshotManagerIvdPetmConfig

func (this *SnapshotManager) ReloadSnapshotManagerIvdPetmConfig(ivdParams map[string]interface{}) error

func (*SnapshotManager) UploadSnapshot

func (this *SnapshotManager) UploadSnapshot(uploadPE astrolabe.ProtectedEntity, ctx context.Context, backupRepositoryName string,
	snapshotRef string) (*v1api.Upload, error)

Creates an Upload CR