rpcserver

Documentation

Index

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

Functions

func New

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

New returns a new transparent scheduler server from the given options

Types

type Server

type Server struct {

	// GRPC UnimplementedSchedulerServer interface
	scheduler.UnimplementedSchedulerServer
	// contains filtered or unexported fields
}

Server is grpc sercer

func (*Server) AnnounceTask

func (s *Server) AnnounceTask(ctx context.Context, req *scheduler.AnnounceTaskRequest) (*empty.Empty, error)

AnnounceTask informs scheduler a peer has completed task

func (*Server) LeaveTask

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

LeaveTask makes the peer unschedulable

func (*Server) RegisterPeerTask

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

RegisterPeerTask registers peer and triggers CDN download task

func (*Server) ReportPeerResult

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

ReportPeerResult handles peer result reported by dfdaemon

func (*Server) ReportPieceResult

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

ReportPieceResult handles the piece information reported by dfdaemon

func (*Server) StatTask

func (s *Server) StatTask(ctx context.Context, req *scheduler.StatTaskRequest) (*scheduler.Task, error)

StatTask checks if the given task exists