Documentation ¶
Index ¶
- type Evaluator
- type Scheduler
- func (s *Scheduler) IsNodeBad(peer *types.PeerTask) bool
- func (s *Scheduler) NeedAdjustParent(peer *types.PeerTask) bool
- func (s *Scheduler) ScheduleAdjustParentNode(peer *types.PeerTask) (primary *types.PeerTask, secondary []*types.PeerTask, err error)
- func (s *Scheduler) ScheduleBadNode(peer *types.PeerTask) (adjustNodes []*types.PeerTask, err error)
- func (s *Scheduler) ScheduleChildren(peer *types.PeerTask) (children []*types.PeerTask, err error)
- func (s *Scheduler) ScheduleDone(peer *types.PeerTask) (parent *types.PeerTask, err error)
- func (s *Scheduler) ScheduleLeaveNode(peer *types.PeerTask) (adjustNodes []*types.PeerTask, err error)
- func (s *Scheduler) ScheduleParent(peer *types.PeerTask) (primary *types.PeerTask, secondary []*types.PeerTask, err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Evaluator ¶
type Evaluator interface {
// contains filtered or unexported methods
}
type Scheduler ¶
type Scheduler struct {
// contains filtered or unexported fields
}
func New ¶
func New(cfg config.SchedulerConfig, taskManager *manager.TaskManager) *Scheduler
func (*Scheduler) NeedAdjustParent ¶
func (*Scheduler) ScheduleAdjustParentNode ¶
func (*Scheduler) ScheduleBadNode ¶
func (*Scheduler) ScheduleChildren ¶
scheduler children to a peer
func (*Scheduler) ScheduleDone ¶
func (*Scheduler) ScheduleLeaveNode ¶
Click to show internal directories.
Click to hide internal directories.