engine

Documentation

Index

• func Worker(r types.Request) (types.ParseResult, error)
• type ConcurrentEngine
  • func (e *ConcurrentEngine) CreateWork(in chan types.Request, out chan types.ParseResult, ...)
  • func (e *ConcurrentEngine) Run(requests ...types.Request)
• type Processor
• type SimpleEngine
  • func (e *SimpleEngine) Run(requests ...types.Request)

Functions

func Worker

func Worker(r types.Request) (types.ParseResult, error)

Types

type ConcurrentEngine

type ConcurrentEngine struct {
	WorkCount        int
	Scheduler        scheduler.Scheduler
	ItemChan         chan types.Item
	RequestProcessor Processor
}

func (*ConcurrentEngine) CreateWork

func (e *ConcurrentEngine) CreateWork(in chan types.Request, out chan types.ParseResult, scheduler scheduler.Scheduler)

func (*ConcurrentEngine) Run

func (e *ConcurrentEngine) Run(requests ...types.Request)

type Processor

type Processor func(request types.Request) (types.ParseResult, error)

type SimpleEngine

type SimpleEngine struct {
}

func (*SimpleEngine) Run

func (e *SimpleEngine) Run(requests ...types.Request)