engine

Documentation

Index

• type Option
  • func WithFetcher(fetcher collect.Fetcher) Option
  • func WithLogger(logger *zap.Logger) Option
  • func WithSeeds(seed []*collect.Request) Option
  • func WithWorkCount(workCount int) Option
• type Schedule
  • func NewSchedule(opts ...Option) *Schedule
  • func (s *Schedule) CreateWork()
  • func (s *Schedule) HandleResult()
  • func (s *Schedule) Run()
  • func (s *Schedule) Schedule()

Types

type Option

type Option func(option *options)

func WithFetcher

func WithFetcher(fetcher collect.Fetcher) Option

func WithLogger

func WithLogger(logger *zap.Logger) Option

func WithSeeds

func WithSeeds(seed []*collect.Request) Option

func WithWorkCount

func WithWorkCount(workCount int) Option

type Schedule

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

func NewSchedule

func NewSchedule(opts ...Option) *Schedule

func (*Schedule) CreateWork

func (s *Schedule) CreateWork()

func (*Schedule) HandleResult

func (s *Schedule) HandleResult()

func (*Schedule) Run

func (s *Schedule) Run()

func (*Schedule) Schedule

func (s *Schedule) Schedule()