client

package
v1.9.0-dev-20241229 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 28, 2024 License: Apache-2.0 Imports: 13 Imported by: 4

Documentation

Index

Constants

View Source 
const (
	GRPCServiceCommonTimeout = 3 * time.Minute
	GRPCServiceLongTimeout   = 24 * time.Hour
)

Variables

This section is empty.

Functions

func GetDiskInfo 

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

func GetReplicaInfo 

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

Types

type ReplicaClient 

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

func NewReplicaClient 

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

func (*ReplicaClient) BackupStatus added in v1.0.1 

func (c *ReplicaClient) BackupStatus(backupName string) (*enginerpc.BackupStatusResponse, error)

func (*ReplicaClient) CloneSnapshot added in v1.2.0 

func (c *ReplicaClient) CloneSnapshot(fromAddress, fromVolumeName, snapshotFileName string, exportBackingImageIfExist bool, fileSyncHTTPClientTimeout int, grpcTimeoutSeconds int64) error

func (*ReplicaClient) Close 

func (c *ReplicaClient) Close() error

func (*ReplicaClient) CloseReplica added in v1.1.3 

func (c *ReplicaClient) CloseReplica() error

func (*ReplicaClient) CreateBackup 

func (c *ReplicaClient) CreateBackup(backupName, snapshot, dest, volume, backingImageName, backingImageChecksum,
	compressionMethod string, concurrentLimit int, storageClassName string, labels []string, credential map[string]string, parameters map[string]string) (*enginerpc.BackupCreateResponse, error)

func (*ReplicaClient) ExpandReplica 

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

func (*ReplicaClient) ExportVolume added in v1.2.0 

func (c *ReplicaClient) ExportVolume(snapshotName, host string, port int32, exportBackingImageIfExist bool, fileSyncHTTPClientTimeout int) 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() (*enginerpc.ReplicaRebuildStatusResponse, error)

func (*ReplicaClient) Reset 

func (c *ReplicaClient) Reset() error

func (*ReplicaClient) RestoreBackup 

func (c *ReplicaClient) RestoreBackup(backup, snapshotDiskName string, credential map[string]string, concurrentLimit int) error

func (*ReplicaClient) RestoreStatus 

func (c *ReplicaClient) RestoreStatus() (*enginerpc.RestoreStatusResponse, 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, fileSyncHTTPClientTimeout int, fastSync bool, grpcTimeoutSeconds int64) error

func (*ReplicaClient) SetRebuilding 

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

func (*ReplicaClient) SetUnmapMarkDiskChainRemoved added in v1.4.0 

func (c *ReplicaClient) SetUnmapMarkDiskChainRemoved(enabled bool) error

func (*ReplicaClient) SnapshotCloneStatus added in v1.2.0 

func (c *ReplicaClient) SnapshotCloneStatus() (*enginerpc.SnapshotCloneStatusResponse, error)

func (*ReplicaClient) SnapshotHash added in v1.4.0 

func (c *ReplicaClient) SnapshotHash(snapshotName string, rehash bool) error

func (*ReplicaClient) SnapshotHashCancel added in v1.4.0 

func (c *ReplicaClient) SnapshotHashCancel(snapshotName string) error

func (*ReplicaClient) SnapshotHashLockState added in v1.4.0 

func (c *ReplicaClient) SnapshotHashLockState() (bool, error)

func (*ReplicaClient) SnapshotHashStatus added in v1.4.0 

func (c *ReplicaClient) SnapshotHashStatus(snapshotName string) (*enginerpc.SnapshotHashStatusResponse, error)

func (*ReplicaClient) SnapshotPurge 

func (c *ReplicaClient) SnapshotPurge() error

func (*ReplicaClient) SnapshotPurgeStatus 

func (c *ReplicaClient) SnapshotPurgeStatus() (*enginerpc.SnapshotPurgeStatusResponse, error)

func (*ReplicaClient) SyncFiles 

func (c *ReplicaClient) SyncFiles(fromAddress string, list []types.SyncFileInfo, fileSyncHTTPClientTimeout int, fastSync bool, grpcTimeoutSeconds int64, localSync *types.FileLocalSync) error

type ReplicaServiceContext added in v1.1.3 

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

func (*ReplicaServiceContext) Close added in v1.1.3 

func (c *ReplicaServiceContext) Close() error

type SyncServiceContext added in v1.1.3 

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

func (*SyncServiceContext) Close added in v1.1.3 

func (c *SyncServiceContext) Close() error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.