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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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
Click to show internal directories.
Click to hide internal directories.