engine

Documentation

Index

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

Functions

func CreateWork

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

Types

type ConcurrentEngine

type ConcurrentEngine struct {
	WorkCount int
	Scheduler scheduler.Scheduler
}

func (*ConcurrentEngine) Run

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

type SimpleEngine

type SimpleEngine struct {
}

func (*SimpleEngine) Run

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