rpcserver

Documentation

Index

• func NewSchedulerServer(service *core.SchedulerService) (server.SchedulerServer, error)
• type SchedulerServer
  • func (s *SchedulerServer) LeaveTask(ctx context.Context, target *scheduler.PeerTarget) (err error)
  • func (s *SchedulerServer) RegisterPeerTask(ctx context.Context, request *scheduler.PeerTaskRequest) (resp *scheduler.RegisterResult, err error)
  • func (s *SchedulerServer) ReportPeerResult(ctx context.Context, result *scheduler.PeerResult) (err error)
  • func (s *SchedulerServer) ReportPieceResult(stream scheduler.Scheduler_ReportPieceResultServer) error

Functions

func NewSchedulerServer

func NewSchedulerServer(service *core.SchedulerService) (server.SchedulerServer, error)

NewSchedulerServer returns a new transparent scheduler server from the given options

Types

type SchedulerServer

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

func (*SchedulerServer) LeaveTask

func (s *SchedulerServer) LeaveTask(ctx context.Context, target *scheduler.PeerTarget) (err error)

func (*SchedulerServer) RegisterPeerTask

func (s *SchedulerServer) RegisterPeerTask(ctx context.Context, request *scheduler.PeerTaskRequest) (resp *scheduler.RegisterResult, err error)

func (*SchedulerServer) ReportPeerResult

func (s *SchedulerServer) ReportPeerResult(ctx context.Context, result *scheduler.PeerResult) (err error)

func (*SchedulerServer) ReportPieceResult

func (s *SchedulerServer) ReportPieceResult(stream scheduler.Scheduler_ReportPieceResultServer) error