client

Documentation

Index

• Constants
• func GetDiskInfo(info *ptypes.DiskInfo) *types.DiskInfo
• func GetReplicaInfo(r *ptypes.Replica) *types.ReplicaInfo
• type ReplicaClient
  • func NewReplicaClient(address string) (*ReplicaClient, error)
  • func (c *ReplicaClient) Close() error
  • func (c *ReplicaClient) CreateBackup(snapshot, dest, volume string, labels []string, credential map[string]string) (*ptypes.BackupCreateReply, error)
  • func (c *ReplicaClient) ExpandReplica(size int64) (r *types.ReplicaInfo, err error)
  • func (c *ReplicaClient) GetBackupStatus(backupName string) (*ptypes.BackupStatusReply, error)
  • func (c *ReplicaClient) GetReplica() (*types.ReplicaInfo, error)
  • func (c *ReplicaClient) LaunchReceiver(toFilePath string) (string, int32, error)
  • func (c *ReplicaClient) MarkDiskAsRemoved(disk string) error
  • func (c *ReplicaClient) OpenReplica() error
  • func (c *ReplicaClient) PrepareRemoveDisk(disk string) ([]*types.PrepareRemoveAction, error)
  • func (c *ReplicaClient) ReloadReplica() (*types.ReplicaInfo, error)
  • func (c *ReplicaClient) RemoveDisk(disk string, force bool) error
  • func (c *ReplicaClient) RemoveFile(file string) error
  • func (c *ReplicaClient) RenameFile(oldFileName, newFileName string) error
  • func (c *ReplicaClient) ReplaceDisk(target, source string) error
  • func (c *ReplicaClient) ReplicaRebuildStatus() (*ptypes.ReplicaRebuildStatusReply, error)
  • func (c *ReplicaClient) Reset() error
  • func (c *ReplicaClient) RestoreBackup(backup, snapshotFile string, credential map[string]string) error
  • func (c *ReplicaClient) RestoreBackupIncrementally(backup, deltaFile, lastRestored, snapshotDiskName string, ...) error
  • func (c *ReplicaClient) RestoreStatus() (*ptypes.RestoreStatusReply, error)
  • func (c *ReplicaClient) Revert(name, created string) error
  • func (c *ReplicaClient) RmBackup(backup string) error
  • func (c *ReplicaClient) SendFile(from, host string, port int32) error
  • func (c *ReplicaClient) SetRebuilding(rebuilding bool) error
  • func (c *ReplicaClient) SnapshotPurge() error
  • func (c *ReplicaClient) SnapshotPurgeStatus() (*ptypes.SnapshotPurgeStatusReply, error)
  • func (c *ReplicaClient) SyncFiles(fromAddress string, list []types.SyncFileInfo) error

Constants

const (
	GRPCServiceCommonTimeout = 1 * time.Minute
	GRPCServiceLongTimeout   = 24 * time.Hour
)

Functions

func GetDiskInfo

func GetDiskInfo(info *ptypes.DiskInfo) *types.DiskInfo

func GetReplicaInfo

func GetReplicaInfo(r *ptypes.Replica) *types.ReplicaInfo

Types

type ReplicaClient

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

func NewReplicaClient

func NewReplicaClient(address string) (*ReplicaClient, error)

func (*ReplicaClient) Close

func (c *ReplicaClient) Close() error

func (*ReplicaClient) CreateBackup

func (c *ReplicaClient) CreateBackup(snapshot, dest, volume string, labels []string, credential map[string]string) (*ptypes.BackupCreateReply, error)

func (*ReplicaClient) ExpandReplica

func (c *ReplicaClient) ExpandReplica(size int64) (r *types.ReplicaInfo, err error)

func (*ReplicaClient) GetBackupStatus

func (c *ReplicaClient) GetBackupStatus(backupName string) (*ptypes.BackupStatusReply, error)

func (*ReplicaClient) GetReplica

func (c *ReplicaClient) GetReplica() (*types.ReplicaInfo, error)

func (*ReplicaClient) LaunchReceiver

func (c *ReplicaClient) LaunchReceiver(toFilePath string) (string, int32, error)

func (*ReplicaClient) MarkDiskAsRemoved

func (c *ReplicaClient) MarkDiskAsRemoved(disk string) error

func (*ReplicaClient) OpenReplica

func (c *ReplicaClient) OpenReplica() error

func (*ReplicaClient) PrepareRemoveDisk

func (c *ReplicaClient) PrepareRemoveDisk(disk string) ([]*types.PrepareRemoveAction, error)

func (*ReplicaClient) ReloadReplica

func (c *ReplicaClient) ReloadReplica() (*types.ReplicaInfo, error)

func (*ReplicaClient) RemoveDisk

func (c *ReplicaClient) RemoveDisk(disk string, force bool) error

func (*ReplicaClient) RemoveFile

func (c *ReplicaClient) RemoveFile(file string) error

func (*ReplicaClient) RenameFile

func (c *ReplicaClient) RenameFile(oldFileName, newFileName string) error

func (*ReplicaClient) ReplaceDisk

func (c *ReplicaClient) ReplaceDisk(target, source string) error

func (*ReplicaClient) ReplicaRebuildStatus

func (c *ReplicaClient) ReplicaRebuildStatus() (*ptypes.ReplicaRebuildStatusReply, error)

func (*ReplicaClient) Reset

func (c *ReplicaClient) Reset() error

func (*ReplicaClient) RestoreBackup

func (c *ReplicaClient) RestoreBackup(backup, snapshotFile string, credential map[string]string) error

func (*ReplicaClient) RestoreBackupIncrementally

func (c *ReplicaClient) RestoreBackupIncrementally(backup, deltaFile, lastRestored,
	snapshotDiskName string, credential map[string]string) error

func (*ReplicaClient) RestoreStatus

func (c *ReplicaClient) RestoreStatus() (*ptypes.RestoreStatusReply, error)

func (*ReplicaClient) Revert

func (c *ReplicaClient) Revert(name, created string) error

func (*ReplicaClient) RmBackup

func (c *ReplicaClient) RmBackup(backup string) error

func (*ReplicaClient) SendFile

func (c *ReplicaClient) SendFile(from, host string, port int32) error

func (*ReplicaClient) SetRebuilding

func (c *ReplicaClient) SetRebuilding(rebuilding bool) error

func (*ReplicaClient) SnapshotPurge

func (c *ReplicaClient) SnapshotPurge() error

func (*ReplicaClient) SnapshotPurgeStatus

func (c *ReplicaClient) SnapshotPurgeStatus() (*ptypes.SnapshotPurgeStatusReply, error)

func (*ReplicaClient) SyncFiles

func (c *ReplicaClient) SyncFiles(fromAddress string, list []types.SyncFileInfo) error