Versions in this module Expand all Collapse all v0 v0.1.3 Mar 19, 2024 v0.1.2 Mar 19, 2024 Changes in this version + var ErrNestedTagsWithSameNameNotImplemented = errors.New("nested tags not implemented") + type Processor struct + BatchSize int + F func([]byte) ([]byte, error) + NumWorkers int + R io.Reader + SplitFunc bufio.SplitFunc + Verbose bool + W io.Writer + func NewProcessor(r io.Reader, w io.Writer, f func([]byte) ([]byte, error)) *Processor + func (p *Processor) Run() error + func (p *Processor) Split(f bufio.SplitFunc) + type TagSplitter struct + BatchSize int + func NewTagSplitter(tag string) *TagSplitter + func (ts *TagSplitter) Split(data []byte, atEOF bool) (advance int, token []byte, err error)
Go to main page