rpcserver

Documentation

Index

• type Server
  • func New(service service.Service, opts ...grpc.ServerOption) *Server
  • func (s *Server) LeaveTask(ctx context.Context, req *scheduler.PeerTarget) (err error)
  • func (s *Server) RegisterPeerTask(ctx context.Context, req *scheduler.PeerTaskRequest) (*scheduler.RegisterResult, error)
  • func (s *Server) ReportPeerResult(ctx context.Context, req *scheduler.PeerResult) (err error)
  • func (s *Server) ReportPieceResult(stream scheduler.Scheduler_ReportPieceResultServer) error

Types

type Server

type Server struct {
	*grpc.Server
	// contains filtered or unexported fields
}

func New

func New(service service.Service, opts ...grpc.ServerOption) *Server

New returns a new transparent scheduler server from the given options

func (*Server) LeaveTask

func (s *Server) LeaveTask(ctx context.Context, req *scheduler.PeerTarget) (err error)

func (*Server) RegisterPeerTask

func (s *Server) RegisterPeerTask(ctx context.Context, req *scheduler.PeerTaskRequest) (*scheduler.RegisterResult, error)

func (*Server) ReportPeerResult

func (s *Server) ReportPeerResult(ctx context.Context, req *scheduler.PeerResult) (err error)

func (*Server) ReportPieceResult

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