services

Documentation

Index

• func NewSeederWithMetaRemoteGrpc(client v1.SeederWithMetaClient) (*services.SeederRemote, *remotes.SeederWithMetaRemote)
• type Agent
  • func NewAgent(beforeSuspend func(ctx context.Context) error, ...) *Agent
  • func (a *Agent) AfterResume(ctx context.Context) error
  • func (a *Agent) BeforeSuspend(ctx context.Context) error
• type AgentServer
  • func NewAgentServer(vsockCID uint32, vsockPort uint32, ...) *AgentServer
  • func (s *AgentServer) Close() error
  • func (s *AgentServer) Open(ctx context.Context) error
  • func (s *AgentServer) Wait() error
• type SeederWithMetaRemoteGrpc
  • func (l *SeederWithMetaRemoteGrpc) Close(ctx context.Context) error
  • func (l *SeederWithMetaRemoteGrpc) Meta(ctx context.Context) (size int64, err error)
  • func (l *SeederWithMetaRemoteGrpc) ReadAt(ctx context.Context, length int, off int64) (r services.ReadAtResponse, err error)
  • func (l *SeederWithMetaRemoteGrpc) Sync(ctx context.Context) ([]int64, error)
  • func (l *SeederWithMetaRemoteGrpc) Track(ctx context.Context) error
• type SeederWithMetaService
  • func NewSeederWithMetaService(base *services.SeederService, b backend.Backend, verbose bool) *SeederWithMetaService
  • func (b *SeederWithMetaService) Close(context context.Context) error
  • func (b *SeederWithMetaService) Meta(context context.Context) (size int64, err error)
  • func (b *SeederWithMetaService) ReadAt(context context.Context, length int, off int64) (r services.ReadAtResponse, err error)
  • func (b *SeederWithMetaService) Sync(context context.Context) ([]int64, error)
  • func (b *SeederWithMetaService) Track(context context.Context) error
• type SeederWithMetaServiceGrpc
  • func NewSeederWithMetaServiceGrpc(svc *SeederWithMetaService) *SeederWithMetaServiceGrpc
  • func (s *SeederWithMetaServiceGrpc) Close(ctx context.Context, args *v1.CloseArgs) (*v1.CloseReply, error)
  • func (s *SeederWithMetaServiceGrpc) Meta(ctx context.Context, args *v1.MetaArgs) (*v1.MetaReply, error)
  • func (s *SeederWithMetaServiceGrpc) ReadAt(ctx context.Context, args *v1.ReadAtArgs) (*v1.ReadAtReply, error)
  • func (s *SeederWithMetaServiceGrpc) Sync(ctx context.Context, args *v1.SyncArgs) (*v1.SyncReply, error)
  • func (s *SeederWithMetaServiceGrpc) Track(ctx context.Context, args *v1.TrackArgs) (*v1.TrackReply, error)

Functions

func NewSeederWithMetaRemoteGrpc

func NewSeederWithMetaRemoteGrpc(
	client v1.SeederWithMetaClient,
) (*services.SeederRemote, *remotes.SeederWithMetaRemote)

Types

type Agent

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

func NewAgent

func NewAgent(
	beforeSuspend func(ctx context.Context) error,
	afterResume func(ctx context.Context) error,

	verbose bool,
) *Agent

func (*Agent) AfterResume

func (a *Agent) AfterResume(ctx context.Context) error

func (*Agent) BeforeSuspend

func (a *Agent) BeforeSuspend(ctx context.Context) error

type AgentServer

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

func NewAgentServer

func NewAgentServer(
	vsockCID uint32,
	vsockPort uint32,

	beforeSuspend func(ctx context.Context) error,
	afterResume func(ctx context.Context) error,

	verbose bool,
) *AgentServer

func (*AgentServer) Close

func (s *AgentServer) Close() error

func (*AgentServer) Open

func (s *AgentServer) Open(ctx context.Context) error

func (*AgentServer) Wait

func (s *AgentServer) Wait() error

type SeederWithMetaRemoteGrpc

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

func (*SeederWithMetaRemoteGrpc) Close

func (l *SeederWithMetaRemoteGrpc) Close(ctx context.Context) error

func (*SeederWithMetaRemoteGrpc) Meta

func (l *SeederWithMetaRemoteGrpc) Meta(ctx context.Context) (size int64, err error)

func (*SeederWithMetaRemoteGrpc) ReadAt

func (l *SeederWithMetaRemoteGrpc) ReadAt(ctx context.Context, length int, off int64) (r services.ReadAtResponse, err error)

func (*SeederWithMetaRemoteGrpc) Sync

func (l *SeederWithMetaRemoteGrpc) Sync(ctx context.Context) ([]int64, error)

func (*SeederWithMetaRemoteGrpc) Track

func (l *SeederWithMetaRemoteGrpc) Track(ctx context.Context) error

type SeederWithMetaService

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

func NewSeederWithMetaService

func NewSeederWithMetaService(
	base *services.SeederService,
	b backend.Backend,
	verbose bool,
) *SeederWithMetaService

func (*SeederWithMetaService) Close

func (b *SeederWithMetaService) Close(context context.Context) error

func (*SeederWithMetaService) Meta

func (b *SeederWithMetaService) Meta(context context.Context) (size int64, err error)

func (*SeederWithMetaService) ReadAt

func (b *SeederWithMetaService) ReadAt(context context.Context, length int, off int64) (r services.ReadAtResponse, err error)

func (*SeederWithMetaService) Sync

func (b *SeederWithMetaService) Sync(context context.Context) ([]int64, error)

func (*SeederWithMetaService) Track

func (b *SeederWithMetaService) Track(context context.Context) error

type SeederWithMetaServiceGrpc

type SeederWithMetaServiceGrpc struct {
	v1.UnimplementedSeederWithMetaServer
	// contains filtered or unexported fields
}

func NewSeederWithMetaServiceGrpc

func NewSeederWithMetaServiceGrpc(svc *SeederWithMetaService) *SeederWithMetaServiceGrpc

func (*SeederWithMetaServiceGrpc) Close

func (s *SeederWithMetaServiceGrpc) Close(ctx context.Context, args *v1.CloseArgs) (*v1.CloseReply, error)

func (*SeederWithMetaServiceGrpc) Meta

func (s *SeederWithMetaServiceGrpc) Meta(ctx context.Context, args *v1.MetaArgs) (*v1.MetaReply, error)

func (*SeederWithMetaServiceGrpc) ReadAt

func (s *SeederWithMetaServiceGrpc) ReadAt(ctx context.Context, args *v1.ReadAtArgs) (*v1.ReadAtReply, error)

func (*SeederWithMetaServiceGrpc) Sync

func (s *SeederWithMetaServiceGrpc) Sync(ctx context.Context, args *v1.SyncArgs) (*v1.SyncReply, error)

func (*SeederWithMetaServiceGrpc) Track

func (s *SeederWithMetaServiceGrpc) Track(ctx context.Context, args *v1.TrackArgs) (*v1.TrackReply, error)