rpc

package
v1.1.3-rc1 Latest Latest
Warning

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

 Go to latest Published: Nov 18, 2021 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MaxBackupSize = 5

	PeriodicRefreshIntervalInSeconds = 2

	GRPCServiceCommonTimeout = 3 * time.Minute

	FileSyncTimeout = 120

	VolumeHeadName = "volume-head"
)

Variables

This section is empty.

Functions

func GetDiskInfo 

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

Types

type BackupInfo 

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

type BackupList 

type BackupList struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*BackupList) BackupAdd 

func (b *BackupList) BackupAdd(backupID string, backup *replica.BackupStatus) error

BackupAdd creates a new backupList object and appends to the end of the list maintained by backup object

func (*BackupList) BackupDelete 

func (b *BackupList) BackupDelete(backupID string) error

BackupDelete will delete the entry in the slice with the corresponding backupID

func (*BackupList) BackupGet 

func (b *BackupList) BackupGet(backupID string) (*replica.BackupStatus, error)

BackupGet takes backupID input and will return the backup object corresponding to that backupID or error if not found

func (*BackupList) Refresh 

func (b *BackupList) Refresh() error

Refresh deletes all the old completed backups from the front. Old backups are the completed backups that are created before MaxBackupSize completed backups

type PurgeStatus 

type PurgeStatus struct {
	sync.RWMutex
	Error    string
	Progress int
	State    types.ProcessState
	// contains filtered or unexported fields
}

func (*PurgeStatus) UpdateFoldFileProgress 

func (ps *PurgeStatus) UpdateFoldFileProgress(progress int, done bool, err error)

type RebuildStatus 

type RebuildStatus struct {
	sync.RWMutex
	Error              string
	Progress           int
	State              types.ProcessState
	FromReplicaAddress string
	// contains filtered or unexported fields
}

func (*RebuildStatus) UpdateSyncFileProgress 

func (rs *RebuildStatus) UpdateSyncFileProgress(size int64)

type SyncAgentServer 

type SyncAgentServer struct {
	sync.RWMutex

	BackupList    *BackupList
	RestoreInfo   *replica.RestoreStatus
	PurgeStatus   *PurgeStatus
	RebuildStatus *RebuildStatus
	// contains filtered or unexported fields
}

func NewSyncAgentServer 

func NewSyncAgentServer(startPort, endPort int, replicaAddress string) *SyncAgentServer

func (*SyncAgentServer) BackupCreate 

func (s *SyncAgentServer) BackupCreate(ctx context.Context, req *ptypes.BackupCreateRequest) (*ptypes.BackupCreateResponse, error)

func (*SyncAgentServer) BackupRemove 

func (*SyncAgentServer) BackupRemove(ctx context.Context, req *ptypes.BackupRemoveRequest) (*empty.Empty, error)

func (*SyncAgentServer) BackupRestore 

func (s *SyncAgentServer) BackupRestore(ctx context.Context, req *ptypes.BackupRestoreRequest) (e *empty.Empty, err error)

func (*SyncAgentServer) BackupStatus added in v1.0.1 

func (s *SyncAgentServer) BackupStatus(ctx context.Context, req *ptypes.BackupStatusRequest) (*ptypes.BackupStatusResponse, error)

func (*SyncAgentServer) FileRemove 

func (*SyncAgentServer) FileRemove(ctx context.Context, req *ptypes.FileRemoveRequest) (*empty.Empty, error)

func (*SyncAgentServer) FileRename 

func (*SyncAgentServer) FileRename(ctx context.Context, req *ptypes.FileRenameRequest) (*empty.Empty, error)

func (*SyncAgentServer) FileSend 

func (s *SyncAgentServer) FileSend(ctx context.Context, req *ptypes.FileSendRequest) (*empty.Empty, error)

func (*SyncAgentServer) FilesSync 

func (s *SyncAgentServer) FilesSync(ctx context.Context, req *ptypes.FilesSyncRequest) (res *empty.Empty, err error)

func (*SyncAgentServer) FinishPurge 

func (s *SyncAgentServer) FinishPurge() error

func (*SyncAgentServer) FinishRebuild 

func (s *SyncAgentServer) FinishRebuild() error

func (*SyncAgentServer) FinishRestore 

func (s *SyncAgentServer) FinishRestore(restoreErr error) (err error)

func (*SyncAgentServer) IsPurging 

func (s *SyncAgentServer) IsPurging() bool

func (*SyncAgentServer) IsRebuilding 

func (s *SyncAgentServer) IsRebuilding() bool

func (*SyncAgentServer) IsRestoring 

func (s *SyncAgentServer) IsRestoring() bool

func (*SyncAgentServer) PreparePurge 

func (s *SyncAgentServer) PreparePurge() error

func (*SyncAgentServer) PrepareRebuild 

func (s *SyncAgentServer) PrepareRebuild(list []*ptypes.SyncFileInfo, fromReplicaAddress string) error

func (*SyncAgentServer) ReceiverLaunch 

func (s *SyncAgentServer) ReceiverLaunch(ctx context.Context, req *ptypes.ReceiverLaunchRequest) (*ptypes.ReceiverLaunchResponse, error)

func (*SyncAgentServer) ReplicaRebuildStatus 

func (s *SyncAgentServer) ReplicaRebuildStatus(ctx context.Context, req *empty.Empty) (*ptypes.ReplicaRebuildStatusResponse, error)

func (*SyncAgentServer) Reset 

func (s *SyncAgentServer) Reset(ctx context.Context, req *empty.Empty) (*empty.Empty, error)

func (*SyncAgentServer) RestoreStatus 

func (s *SyncAgentServer) RestoreStatus(ctx context.Context, req *empty.Empty) (*ptypes.RestoreStatusResponse, error)

func (*SyncAgentServer) SnapshotPurge 

func (s *SyncAgentServer) SnapshotPurge(ctx context.Context, req *empty.Empty) (*empty.Empty, error)

func (*SyncAgentServer) SnapshotPurgeStatus 

func (s *SyncAgentServer) SnapshotPurgeStatus(ctx context.Context, req *empty.Empty) (*ptypes.SnapshotPurgeStatusResponse, error)

func (*SyncAgentServer) StartRestore added in v1.1.0 

func (s *SyncAgentServer) StartRestore(backupURL, requestedBackupName, snapshotDiskName string) (err 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.