Versions in this module Expand all Collapse all v1 v1.5.5 May 18, 2020 Changes in this version + func NewReader(meta *reader.Meta, conf conf.MapConf) (reader.Reader, error) + type ActiveReader struct + func NewActiveReader(originPath, realPath, whence, inode string, r *Reader) (ar *ActiveReader, err error) + func (ar *ActiveReader) Close() error + func (ar *ActiveReader) CloseNoSync() error + func (ar *ActiveReader) Lag() (rl *LagInfo, err error) + func (ar *ActiveReader) ReadDone() bool + func (ar *ActiveReader) ResetFileMeta() error + func (ar *ActiveReader) Run() + func (ar *ActiveReader) Start() + func (ar *ActiveReader) Status() StatsInfo + func (ar *ActiveReader) Stop() error + func (ar *ActiveReader) SyncMeta() string + type Reader struct + func (r *Reader) Close() error + func (r *Reader) Lag() (*LagInfo, error) + func (r *Reader) Name() string + func (r *Reader) ReadLine() (string, error) + func (r *Reader) Reset() error + func (r *Reader) SetMode(mode string, value interface{}) error + func (r *Reader) SetRunTime(mode string, value interface{}) error + func (r *Reader) Source() string + func (r *Reader) Start() error + func (r *Reader) Status() StatsInfo + func (r *Reader) SyncMeta() + func (r *Reader) SyncMetaClose() + type Result struct
Go to main page