processor

Sep 14, 2016 GO-2022-0643

  GO-2022-0643: Denial of service in github.com/elastic/beats

Aug 30, 2016 GO-2022-0643

  GO-2022-0643: Denial of service in github.com/elastic/beats

May 18, 2016 GO-2022-0643

  GO-2022-0643: Denial of service in github.com/elastic/beats

Apr 26, 2016 GO-2022-0643

  GO-2022-0643: Denial of service in github.com/elastic/beats

Apr 7, 2016 GO-2022-0643

  GO-2022-0643: Denial of service in github.com/elastic/beats

Mar 30, 2016 GO-2022-0643

  GO-2022-0643: Denial of service in github.com/elastic/beats

Mar 8, 2016 GO-2022-0643

  GO-2022-0643: Denial of service in github.com/elastic/beats

Feb 11, 2016 GO-2022-0643

  GO-2022-0643: Denial of service in github.com/elastic/beats

Feb 2, 2016 GO-2022-0643

  GO-2022-0643: Denial of service in github.com/elastic/beats

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)