engine

Documentation

Index

• type ScheduleEngine
  • func (s *ScheduleEngine) CreateWork()
  • func (s *ScheduleEngine) HandleResult()
  • func (s *ScheduleEngine) Run()
  • func (s *ScheduleEngine) Schedule()

Types

type ScheduleEngine

type ScheduleEngine struct {
	WorkCount int //为执行任务的数量，可以灵活地去配置。
	Fetcher   collect.Fetcher
	Logger    *zap.Logger

	Seeds []*collect.Request
	// contains filtered or unexported fields
}

func (*ScheduleEngine) CreateWork

func (s *ScheduleEngine) CreateWork()

func (*ScheduleEngine) HandleResult

func (s *ScheduleEngine) HandleResult()

func (*ScheduleEngine) Run

func (s *ScheduleEngine) Run()

func (*ScheduleEngine) Schedule

func (s *ScheduleEngine) Schedule()