mysql

Documentation

Index

• Constants
• Variables
• func GetTimeStrFromArgs(offsetKeyIndex int, scanArgs []interface{}) (string, bool)
• func NewMysqlReader(meta *reader.Meta, conf conf.MapConf) (reader.Reader, error)
• type MysqlReader
  • 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()

Constants

const MysqlTimeFormat = "2006-01-02 15:04:05.000000"

Variables

var MysqlSystemDB = []string{"information_schema", "performance_schema", "mysql", "sys"}

Functions

func GetTimeStrFromArgs

func GetTimeStrFromArgs(offsetKeyIndex int, scanArgs []interface{}) (string, bool)

func NewMysqlReader

func NewMysqlReader(meta *reader.Meta, conf conf.MapConf) (reader.Reader, error)

Types

type MysqlReader

type MysqlReader struct {
	Cron *cron.Cron //定时任务

	CurrentCount int64
	// contains filtered or unexported fields
}

func (*MysqlReader) Close

func (r *MysqlReader) Close() error

func (*MysqlReader) Lag

func (r *MysqlReader) Lag() (rl *models.LagInfo, err error)

func (*MysqlReader) Name

func (r *MysqlReader) Name() string

func (*MysqlReader) ReadData

func (r *MysqlReader) ReadData() (models.Data, int64, error)

func (*MysqlReader) ReadLine

func (r *MysqlReader) ReadLine() (string, error)

func (*MysqlReader) SetMode

func (r *MysqlReader) SetMode(mode string, v interface{}) error

func (*MysqlReader) Source

func (r *MysqlReader) Source() string

func (*MysqlReader) Start

func (r *MysqlReader) Start() error

func (*MysqlReader) Status

func (r *MysqlReader) Status() models.StatsInfo

func (*MysqlReader) SyncMeta

func (r *MysqlReader) SyncMeta()

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