NewEncode creates a new Encode reader from input reader by applying the given codec.

NewJSONReader creates a new reader that can decode JSON.

NewLimit creates a new reader limiting the line length.

NewLine creates a new Line reader object.

NewMultiline creates a new multi-line reader combining stream of line events into stream of multi-line events.

NewStripNewline creates a new line reader stripping the last tailing newline.

NewTimeout returns a new timeout reader from an input line reader.

Encode reader produces lines by reading lines from an io.Reader through a decoder converting the reader it's encoding to utf-8.

LimitProcessor sets an upper limited on line length.

lineReader reads lines from underlying reader, decoding the input stream using the configured codec.

Message represents a reader event with timestamp, content and actual number of bytes read from input before decoding.

MultiLine reader combining multiple line events into one multi-line event.

StripNewline reader removes the last trailing newline characters from read lines.

timeoutProcessor will signal some configurable timeout error if no new line can be returned in time.

Reader is the interface that wraps the basic Next method for getting a new message.