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 MysqlTimeFormat + var MysqlSystemDB = []string + func GetTimeStrFromArgs(offsetKeyIndex int, scanArgs []interface{}) (string, bool) + func NewMysqlReader(meta *reader.Meta, conf conf.MapConf) (reader.Reader, error) + type MysqlReader struct + Cron *cron.Cron + CurrentCount int64 + func (r *MysqlReader) Close() error + func (r *MysqlReader) Lag() (rl *models.LagInfo, err error) + func (r *MysqlReader) Name() string + func (r *MysqlReader) ReadData() (models.Data, int64, error) + func (r *MysqlReader) ReadLine() (string, error) + func (r *MysqlReader) SetMode(mode string, v interface{}) error + func (r *MysqlReader) Source() string + func (r *MysqlReader) Start() error + func (r *MysqlReader) Status() models.StatsInfo + func (r *MysqlReader) SyncMeta()
Go to main page