binlog_checker

package

v0.9.71 Latest Latest Go to latest Published: Jun 29, 2020 License: Apache-2.0 Imports: 14 Imported by: 3

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/moiot/gravity

Links

Open Source Insights

Documentation ¶

Index ¶

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

Constants ¶

View Source

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

Variables ¶

This section is empty.

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 *config.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)

Source Files ¶

View all Source files

checker.go

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