service

Documentation

Index

• type Service
  • func New(cfg *config.Config, resource resource.Resource, scheduler scheduler.Scheduler, ...) *Service
  • func (s *Service) CDN() resource.CDN
  • func (s *Service) LeaveTask(ctx context.Context, req *rpcscheduler.PeerTarget) error
  • func (s *Service) RegisterPeerTask(ctx context.Context, req *rpcscheduler.PeerTaskRequest) (*rpcscheduler.RegisterResult, error)
  • func (s *Service) ReportPeerResult(ctx context.Context, req *rpcscheduler.PeerResult) error
  • func (s *Service) ReportPieceResult(stream rpcscheduler.Scheduler_ReportPieceResultServer) error

Types

type Service

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

func New

func New(
	cfg *config.Config,
	resource resource.Resource,
	scheduler scheduler.Scheduler,
	dynconfig config.DynconfigInterface,
) *Service

New service instance

func (*Service) CDN

func (s *Service) CDN() resource.CDN

CDN is cdn resource

func (*Service) LeaveTask

func (s *Service) LeaveTask(ctx context.Context, req *rpcscheduler.PeerTarget) error

LeaveTask makes the peer unschedulable

func (*Service) RegisterPeerTask

func (s *Service) RegisterPeerTask(ctx context.Context, req *rpcscheduler.PeerTaskRequest) (*rpcscheduler.RegisterResult, error)

RegisterPeerTask registers peer and triggers CDN download task

func (*Service) ReportPeerResult

func (s *Service) ReportPeerResult(ctx context.Context, req *rpcscheduler.PeerResult) error

ReportPeerResult handles peer result reported by dfdaemon

func (*Service) ReportPieceResult

func (s *Service) ReportPieceResult(stream rpcscheduler.Scheduler_ReportPieceResultServer) error

ReportPieceResult handles the piece information reported by dfdaemon