scheduler

Documentation

Index

• type Manager
  • func NewManager(cfg *config.Config, progressMgr mgr.ProgressMgr) (*Manager, error)
  • func (sm *Manager) Schedule(ctx context.Context, taskID, clientID, peerID string) ([]*mgr.PieceResult, error)

Types

type Manager

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

Manager is an implement of the interface of SchedulerMgr.

func NewManager

func NewManager(cfg *config.Config, progressMgr mgr.ProgressMgr) (*Manager, error)

NewManager returns a new Manager.

func (*Manager) Schedule

func (sm *Manager) Schedule(ctx context.Context, taskID, clientID, peerID string) ([]*mgr.PieceResult, error)

Schedule gets scheduler result with specified taskID, clientID and peerID through some rules.