manager

Documentation

Index

• Constants
• func NewServer(parentCtx context.Context, ...) error
• func ParsePortRange(portRange string) (int32, int32, error)
• type BackupInfo
• type BackupList
  • func (b *BackupList) BackupAdd(backupID string, BackupStatus *backingimage.BackupStatus) error
  • func (b *BackupList) BackupGet(backupID string) (*backingimage.BackupStatus, error)
• type Manager
  • func NewManager(ctx context.Context, syncAddress, diskUUID, diskPath, portRange string) (*Manager, error)
  • func (m *Manager) BackupCreate(ctx context.Context, req *rpc.BackupCreateRequest) (resp *empty.Empty, err error)
  • func (m *Manager) BackupStatus(ctx context.Context, req *rpc.BackupStatusRequest) (resp *rpc.BackupStatusResponse, err error)
  • func (m *Manager) Delete(ctx context.Context, req *rpc.DeleteRequest) (resp *emptypb.Empty, err error)
  • func (m *Manager) Fetch(ctx context.Context, req *rpc.FetchRequest) (resp *rpc.BackingImageResponse, err error)
  • func (m *Manager) Get(ctx context.Context, req *rpc.GetRequest) (*rpc.BackingImageResponse, error)
  • func (m *Manager) List(ctx context.Context, req *emptypb.Empty) (*rpc.ListResponse, error)
  • func (m *Manager) PrepareDownload(ctx context.Context, req *rpc.PrepareDownloadRequest) (resp *rpc.PrepareDownloadResponse, err error)
  • func (m *Manager) Send(ctx context.Context, req *rpc.SendRequest) (resp *emptypb.Empty, err error)
  • func (m *Manager) Subscribe() (<-chan interface{}, error)
  • func (m *Manager) Sync(ctx context.Context, req *rpc.SyncRequest) (resp *rpc.BackingImageResponse, err error)
  • func (pm *Manager) VersionGet(ctx context.Context, empty *emptypb.Empty) (*rpc.VersionResponse, error)
  • func (m *Manager) Watch(req *emptypb.Empty, srv rpc.BackingImageManagerService_WatchServer) (err error)

Constants

const (
	MaxBackupSize = 5
)

Functions

func NewServer

func NewServer(parentCtx context.Context, listenAddr, syncListenAddr, diskUUID, diskPathInContainer, portRange string, syncHandler sync.Handler) error

func ParsePortRange

func ParsePortRange(portRange string) (int32, int32, error)

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, BackupStatus *backingimage.BackupStatus) error

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

func (*BackupList) BackupGet

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

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

type Manager

type Manager struct {
	rpc.UnimplementedBackingImageManagerServiceServer

	BackupList *BackupList
	// contains filtered or unexported fields
}

func NewManager

func NewManager(ctx context.Context, syncAddress, diskUUID, diskPath, portRange string) (*Manager, error)

func (*Manager) BackupCreate

func (m *Manager) BackupCreate(ctx context.Context, req *rpc.BackupCreateRequest) (resp *empty.Empty, err error)

func (*Manager) BackupStatus

func (m *Manager) BackupStatus(ctx context.Context, req *rpc.BackupStatusRequest) (resp *rpc.BackupStatusResponse, err error)

func (*Manager) Delete

func (m *Manager) Delete(ctx context.Context, req *rpc.DeleteRequest) (resp *emptypb.Empty, err error)

func (*Manager) Fetch

func (m *Manager) Fetch(ctx context.Context, req *rpc.FetchRequest) (resp *rpc.BackingImageResponse, err error)

func (*Manager) Get

func (m *Manager) Get(ctx context.Context, req *rpc.GetRequest) (*rpc.BackingImageResponse, error)

func (*Manager) List

func (m *Manager) List(ctx context.Context, req *emptypb.Empty) (*rpc.ListResponse, error)

func (*Manager) PrepareDownload

func (m *Manager) PrepareDownload(ctx context.Context, req *rpc.PrepareDownloadRequest) (resp *rpc.PrepareDownloadResponse, err error)

func (*Manager) Send

func (m *Manager) Send(ctx context.Context, req *rpc.SendRequest) (resp *emptypb.Empty, err error)

func (*Manager) Subscribe

func (m *Manager) Subscribe() (<-chan interface{}, error)

func (*Manager) Sync

func (m *Manager) Sync(ctx context.Context, req *rpc.SyncRequest) (resp *rpc.BackingImageResponse, err error)

func (*Manager) VersionGet

func (pm *Manager) VersionGet(ctx context.Context, empty *emptypb.Empty) (*rpc.VersionResponse, error)

func (*Manager) Watch

func (m *Manager) Watch(req *emptypb.Empty, srv rpc.BackingImageManagerService_WatchServer) (err error)