manager

Documentation

Index

• func NewServer(parentCtx context.Context, ...) error
• func ParsePortRange(portRange string) (int32, int32, error)
• type Manager
  • func NewManager(ctx context.Context, syncAddress, diskUUID, diskPath, portRange string) (*Manager, error)
  • func (m *Manager) Delete(ctx context.Context, req *rpc.DeleteRequest) (resp *empty.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 *empty.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 *empty.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 *empty.Empty) (*rpc.VersionResponse, error)
  • func (m *Manager) Watch(req *empty.Empty, srv rpc.BackingImageManagerService_WatchServer) (err error)

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 Manager

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

func NewManager

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

func (*Manager) Delete

func (m *Manager) Delete(ctx context.Context, req *rpc.DeleteRequest) (resp *empty.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 *empty.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 *empty.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 *empty.Empty) (*rpc.VersionResponse, error)

func (*Manager) Watch

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