binlog_checker

Documentation

Index

• Constants
• func IsBinlogCheckerMsg(db string, table string) bool
• type BinlogChecker
  • func NewBinlogChecker(pipelineName string, dbConfig *utils.DBConfig, annotation string, ...) (BinlogChecker, error)
• type Row
  • func ParseMySQLRowEvent(event *replication.RowsEvent) (Row, error)
  • func ParseTiDBRow(row pb.Row) (Row, error)

Constants

const DRC_TIME_LAYOUT_VERSION_01 = "2006-01-02 15:04:05.999999999"

Functions

func IsBinlogCheckerMsg

func IsBinlogCheckerMsg(db string, table string) bool

Types

type BinlogChecker

type BinlogChecker interface {
	Start() error
	Stop()
	MarkActive(row Row)
	// IsEventBelongsToMySelf(event *replication.RowsEvent) bool
	IsEventBelongsToMySelf(row Row) bool
}

func NewBinlogChecker

func NewBinlogChecker(
	pipelineName string,
	dbConfig *utils.DBConfig,
	annotation string,
	interval time.Duration,
	disableChecker bool) (BinlogChecker, error)

type Row

type Row struct {
	GravityName         string
	Offset              int64
	UpdateTimeAtGravity time.Time
	UpdateTimeAtSource  time.Time
}

func ParseMySQLRowEvent

func ParseMySQLRowEvent(event *replication.RowsEvent) (Row, error)

func ParseTiDBRow

func ParseTiDBRow(row pb.Row) (Row, error)