service

Documentation

Index

• type Service
  • func New(cfg *config.Config, resource resource.Resource, scheduler scheduler.Scheduler, ...) *Service
  • func (s *Service) AnnounceTask(ctx context.Context, req *rpcscheduler.AnnounceTaskRequest) error
  • 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
  • func (s *Service) StatTask(ctx context.Context, req *rpcscheduler.StatTaskRequest) (*rpcscheduler.Task, 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,
	storage storage.Storage,
) *Service

New service instance.

func (*Service) AnnounceTask

func (s *Service) AnnounceTask(ctx context.Context, req *rpcscheduler.AnnounceTaskRequest) error

AnnounceTask informs scheduler a peer has completed task.

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 seed peer 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.

func (*Service) StatTask

func (s *Service) StatTask(ctx context.Context, req *rpcscheduler.StatTaskRequest) (*rpcscheduler.Task, error)

StatTask checks the current state of the task.