sync

Documentation

Index

• Constants
• func GetSnapshotsInfo(replicas []*types.ControllerReplicaInfo) (outputDisks map[string]types.DiskInfo, err error)
• type BackupCreateInfo
• type BackupStatusInfo
  • func FetchBackupStatus(client *replicaClient.ReplicaClient, backupID string, replicaAddr string) (*BackupStatusInfo, error)
• type ReplicaError
  • func NewReplicaError(address string, err error) ReplicaError
  • func (e ReplicaError) Error() string
• type ReplicaRebuildStatus
• type RestoreStatus
• type SnapshotPurgeStatus
• type Task
  • func NewTask(ctx context.Context, controllerAddress string) (*Task, error)
  • func (t *Task) AddReplica(replica string) error
  • func (t *Task) AddRestoreReplica(replica string) error
  • func (t *Task) CreateBackup(snapshot, dest, backingImageName, backingImageURL string, labels []string, ...) (*BackupCreateInfo, error)
  • func (t *Task) DeleteSnapshot(snapshot string) error
  • func (t *Task) FetchBackupStatus(backupID string, replicaAddr string) (*BackupStatusInfo, error)
  • func (t *Task) PurgeSnapshotStatus() (map[string]*SnapshotPurgeStatus, error)
  • func (t *Task) PurgeSnapshots(skip bool) error
  • func (t *Task) RebuildStatus() (map[string]*ReplicaRebuildStatus, error)
  • func (t *Task) Reset() error
  • func (t *Task) RestoreBackup(backup string, credential map[string]string) error
  • func (t *Task) RestoreStatus() (map[string]*RestoreStatus, error)
  • func (t *Task) StartWithReplicas(replicas []string) error
  • func (t *Task) VerifyRebuildReplica(address string) error
• type TaskError
  • func NewTaskError(res ...ReplicaError) *TaskError
  • func (e *TaskError) Append(re ReplicaError)
  • func (e *TaskError) Error() string
  • func (e *TaskError) HasError() bool

Constants

const (
	VolumeHeadName = "volume-head"
)

Functions

func GetSnapshotsInfo

func GetSnapshotsInfo(replicas []*types.ControllerReplicaInfo) (outputDisks map[string]types.DiskInfo, err error)

Types

type BackupCreateInfo

type BackupCreateInfo struct {
	BackupID      string `json:"backupID"`
	IsIncremental bool   `json:"isIncremental"`
}

type BackupStatusInfo

type BackupStatusInfo struct {
	Progress       int    `json:"progress"`
	BackupURL      string `json:"backupURL,omitempty"`
	Error          string `json:"error,omitempty"`
	SnapshotName   string `json:"snapshotName"`
	State          string `json:"state"`
	ReplicaAddress string `json:"replicaAddress"`
}

func FetchBackupStatus

func FetchBackupStatus(client *replicaClient.ReplicaClient, backupID string, replicaAddr string) (*BackupStatusInfo, error)

type ReplicaError

type ReplicaError struct {
	Address string
	Message string
}

func NewReplicaError

func NewReplicaError(address string, err error) ReplicaError

func (ReplicaError) Error

func (e ReplicaError) Error() string

type ReplicaRebuildStatus

type ReplicaRebuildStatus struct {
	Error              string `json:"error"`
	IsRebuilding       bool   `json:"isRebuilding"`
	Progress           int    `json:"progress"`
	State              string `json:"state"`
	FromReplicaAddress string `json:"fromReplicaAddress"`
}

type RestoreStatus

type RestoreStatus struct {
	IsRestoring            bool   `json:"isRestoring"`
	Progress               int    `json:"progress,omitempty"`
	Error                  string `json:"error,omitempty"`
	Filename               string `json:"filename,omitempty"`
	State                  string `json:"state"`
	BackupURL              string `json:"backupURL"`
	LastRestored           string `json:"lastRestored"`
	CurrentRestoringBackup string `json:"currentRestoringBackup"`
}

type SnapshotPurgeStatus

type SnapshotPurgeStatus struct {
	Error     string `json:"error"`
	IsPurging bool   `json:"isPurging"`
	Progress  int    `json:"progress"`
	State     string `json:"state"`
}

type Task

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

func NewTask

func NewTask(ctx context.Context, controllerAddress string) (*Task, error)

NewTask creates new task with an initialized ControllerClient The lifetime of the Task::client is bound to the context lifetime client calls have their own contexts with timeouts for the call

func (*Task) AddReplica

func (t *Task) AddReplica(replica string) error

func (*Task) AddRestoreReplica

func (t *Task) AddRestoreReplica(replica string) error

func (*Task) CreateBackup

func (t *Task) CreateBackup(snapshot, dest, backingImageName, backingImageURL string, labels []string, credential map[string]string) (*BackupCreateInfo, error)

func (*Task) DeleteSnapshot

func (t *Task) DeleteSnapshot(snapshot string) error

func (*Task) FetchBackupStatus

func (t *Task) FetchBackupStatus(backupID string, replicaAddr string) (*BackupStatusInfo, error)

FetchBackupStatus instance method is @deprecated use the free function FetchBackupStatus instead

func (*Task) PurgeSnapshotStatus

func (t *Task) PurgeSnapshotStatus() (map[string]*SnapshotPurgeStatus, error)

func (*Task) PurgeSnapshots

func (t *Task) PurgeSnapshots(skip bool) error

func (*Task) RebuildStatus

func (t *Task) RebuildStatus() (map[string]*ReplicaRebuildStatus, error)

func (*Task) Reset

func (t *Task) Reset() error

func (*Task) RestoreBackup

func (t *Task) RestoreBackup(backup string, credential map[string]string) error

func (*Task) RestoreStatus

func (t *Task) RestoreStatus() (map[string]*RestoreStatus, error)

func (*Task) StartWithReplicas

func (t *Task) StartWithReplicas(replicas []string) error

func (*Task) VerifyRebuildReplica

func (t *Task) VerifyRebuildReplica(address string) error

type TaskError

type TaskError struct {
	ReplicaErrors []ReplicaError
}

func NewTaskError

func NewTaskError(res ...ReplicaError) *TaskError

func (*TaskError) Append

func (e *TaskError) Append(re ReplicaError)

func (*TaskError) Error

func (e *TaskError) Error() string

func (*TaskError) HasError

func (e *TaskError) HasError() bool