Versions in this module Expand all Collapse all v1 v1.3.1 Sep 14, 2016 Changes in this version + type LimitProcessor struct + func NewLimitProcessor(in LineProcessor, maxBytes int) *LimitProcessor + func (p *LimitProcessor) Next() (Line, error) + type Line struct + Bytes int + Content []byte + Ts time.Time + type LineProcessor interface + Next func() (Line, error) + type LineSource struct + func NewLineSource(in io.Reader, codec encoding.Encoding, bufferSize int) (LineSource, error) + func (p LineSource) Next() (Line, error) + type MultiLine struct + func NewMultiline(r LineProcessor, maxBytes int, config *config.MultilineConfig) (*MultiLine, error) + func (mlr *MultiLine) Next() (Line, error) + type StripNewline struct + func NewStripNewline(r LineProcessor) *StripNewline + func (p *StripNewline) Next() (Line, error)
Go to main page