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 Reader struct + HeadPattern *regexp.Regexp + IsSplitByLine bool + KeepAlivePeriod time.Duration + MaxConnections int + ReadBufferSize int + ReadTimeout time.Duration + ServiceAddress string + SocketRule string + func (*Reader) SetMode(_ string, _ interface{}) error + func (r *Reader) Close() error + func (r *Reader) FetchInitError() error + func (r *Reader) Name() string + func (r *Reader) ReadLine() (string, error) + func (r *Reader) Source() string + func (r *Reader) Start() (err error) + func (r *Reader) SyncMeta()
Go to main page