Versions in this module Expand all Collapse all v1 v1.5.5 May 18, 2020 v1.5.4 Aug 20, 2019 Changes in this version + const DefaultBufSize + const MaxHeadPatternBufferSize + var ErrBufferFull = errors.New("bufio: buffer full") + var ErrInvalidUnreadByte = errors.New("bufio: invalid use of UnreadByte") + var ErrInvalidUnreadRune = errors.New("bufio: invalid use of UnreadRune") + var ErrNegativeCount = errors.New("bufio: negative count") + func NewFileDirReader(meta *reader.Meta, conf conf.MapConf) (reader reader.Reader, err error) + func NewSingleFileReader(meta *reader.Meta, conf conf.MapConf) (reader reader.Reader, err error) + type BufReader struct + Meta *reader.Meta + func NewReaderSize(rd reader.FileReader, meta *reader.Meta, size int) (*BufReader, error) + func (b *BufReader) Close() error + func (b *BufReader) FormMutiLine() []byte + func (b *BufReader) Lag() (rl *LagInfo, err error) + func (b *BufReader) Name() string + func (b *BufReader) ReadDone() bool + func (b *BufReader) ReadLine() (ret string, err error) + func (b *BufReader) ReadPattern() (string, error) + func (b *BufReader) ReadString(delim byte) (ret string, err error) + func (b *BufReader) SetMode(mode string, v interface{}) (err error) + func (b *BufReader) SetRunTime(mode string, v interface{}) (err error) + func (b *BufReader) Source() string + func (b *BufReader) Status() StatsInfo + func (b *BufReader) SyncMeta() + type LastSync struct + type LineCache struct + func NewLineCache() *LineCache + func (l *LineCache) Append(r string) + func (l *LineCache) Combine() []byte + func (l *LineCache) Set(r []string) + func (l *LineCache) Size() int + func (l *LineCache) TotalLen() int
Go to main page