Documentation
¶
Overview ¶
Package scan accepts a bufio.SplitFunc and generalizes batches to non-line oriented input, e.g. XML.
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var New = NewProcessor
New is a preferred way to create a new parallel processor.
Functions ¶
This section is empty.
Types ¶
type Processor ¶
type Processor struct {
BatchSize int
SplitFunc bufio.SplitFunc
NumWorkers int
Verbose bool
R io.Reader
W io.Writer
F func([]byte) ([]byte, error)
}
Processor can process lines in parallel.
func NewProcessor ¶
NewProcessor creates a new line processor.
Source Files
Click to show internal directories.
Click to hide internal directories.