dataparser

package

v0.0.0-...-948e253 Latest Latest Go to latest Published: Jun 25, 2021 License: MIT Imports: 13 Imported by: 0

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

This section is empty.

View Source

var DDLTable []string

DDLTable 用来存放ddl变化的表，元素为db.tb

View Source

var (
	// XIDCommit 是否有XID 提交， 增量解析部分有XID event
	XIDCommit = false
)

func GetFilterTables() (map[string][]string, []string, []string)

GetFilterTables 为开源同步工具canal 收集需要同步的表信息，目前暂不支持配置exclude tables

func NewConsumerData()

NewConsumerData 重置 consumer 数据

type MyEventHandler struct {
	canal.DummyEventHandler
}

MyEventHandler 事件处理

func (h *MyEventHandler) OnDDL(nextPos mysql.Position, queryEvent *replication.QueryEvent) error

func (h *MyEventHandler) OnRow(e *canal.RowsEvent) error

OnRow 解析出来的binlog 事件结构，组装成数据发送给redisconsumer

func (h *MyEventHandler) OnTableChanged(schema string, table string) error

ddl的时候会先收到OnTableChanged事件，再收到上面的OnDDL事件，当一个ddl语句涉及到多个表时，会收到多个OnTableChanged事件，一个OnDDL事件

func (h *MyEventHandler) OnXID(pos mysql.Position) error

OnXID 填充RedisDataMap Binlog File 与binlog Pos 字段。将消息发送给消费者（redis 数据写入）

func (h *MyEventHandler) String() string

String 返回mysql event handler 的名称