Versions in this module Expand all Collapse all v1 v1.5.5 May 18, 2020 Changes in this version + const DefaultOffsetKey + const EmptyOffsetKey + const NoRelease + const Release + func NewReader(meta *reader.Meta, conf conf.MapConf) (reader.Reader, error) + type CollectionFilter map[string]interface + type Reader struct + Cron *cron.Cron + func (*Reader) SetMode(_ string, _ interface{}) error + func (r *Reader) Close() (err error) + func (r *Reader) Name() string + func (r *Reader) ReadLine() (string, error) + func (r *Reader) Source() string + func (r *Reader) Start() error + func (r *Reader) Status() StatsInfo + func (r *Reader) SyncMeta()
Go to main page