mysql

package
v1.5.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 18, 2020 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

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

Variables

View Source
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 从队列取数据时同步队列,作用在于保证数据不重复

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL