mongo

package

v1.5.1 Latest Latest Go to latest Published: Jul 13, 2018 License: Apache-2.0 Imports: 14 Imported by: 3

Details

View Source

const (
	MongoDefaultOffsetKey = "_id"
)

This section is empty.

func NewReader(meta *reader.Meta, conf conf.MapConf) (mr reader.Reader, err error)

type CollectionFilter map[string]interface{}

CollectionFilter is just a typed map of strings of map[string]interface{}

type Reader struct {
	Cron *cron.Cron //定时任务
	// contains filtered or unexported fields
}

func (mr *Reader) Close() (err error)

func (mr *Reader) LoopRun()

func (mr *Reader) Name() string

func (mr *Reader) ReadLine() (data string, err error)

func (mr *Reader) SetMode(mode string, v interface{}) error

func (mr *Reader) Source() string

func (mr *Reader) Start()

Start 仅调用一次，借用ReadLine启动，不能在new实例的时候启动，会有并发问题

func (mr *Reader) Status() StatsInfo

func (mr *Reader) SyncMeta()

SyncMeta 从队列取数据时同步队列，作用在于保证数据不重复。