The highest tagged major version is v2.

mycanal

package

v0.11.4 Latest Latest Go to latest Published: Jun 8, 2020 License: MIT Imports: 4 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

Repository

github.com/huangjunwen/nproto

Links

Open Source Insights

Documentation ¶

Overview ¶

Package mycanal is a CDC (Change Data Capture) library for MySQL8+

It provides helper functions for full dump (package fulldump) and incremental change capture (package incrdump). Prerequisites:

MySQL-8.0.2 and above
GTID mode enabled:
`--gtid-mode=ON`
`--enforce-gtid-consistency=ON`
binlog enabled with the following:
`--log-bin=xxxx`: enable bin log
`--server-id=xxx`: the server id
`--binlog-format=ROW`: binlog output row changes instead of statments
`--binlog-row-image=FULL`: before and after image of row changes
`--binlog-row-metadata=FULL`: extra optional meta for tables such as signedness for numeric columns/column names ...

ref:

Compatiable between fulldump/incrdump (see tst):

DECIMAL/NUMERIC fields are returned as string, but may have different trailing zeros.
BINARY fields are returned as string, but may have different trailing '\x00'.
JSON fields are returned as string, but elements inside may have different position.
BIT fields seems have some bugs in incrdump.
TIME with fraction seems have some bugs in incrdump too.

Index ¶

type Config
type FullDumpConfig
- func (cfg *FullDumpConfig) Client() (*sql.DB, error)
- func (cfg *FullDumpConfig) ToDriverCfg() *mysql.Config
type IncrDumpConfig
- func (cfg *IncrDumpConfig) ToDriverCfg() replication.BinlogSyncerConfig

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	// Host of MySQL server.
	Host string `json:"host"`

	// Port of MySQL server.
	Port uint16 `json:"port"`

	// User for connection.
	User string `json:"user"`

	// Password for connection.
	Password string `json:"password"`

	// Charset for connecting.
	Charset string `json:"charset"`
}

type FullDumpConfig ¶

type FullDumpConfig struct {
	Config
}

func (*FullDumpConfig) Client ¶

func (cfg *FullDumpConfig) Client() (*sql.DB, error)

func (*FullDumpConfig) ToDriverCfg ¶

func (cfg *FullDumpConfig) ToDriverCfg() *mysql.Config

type IncrDumpConfig ¶

type IncrDumpConfig struct {
	Config

	// ServerId is the server id for the slave.
	ServerId uint32 `json:"serverId"`
}

func (*IncrDumpConfig) ToDriverCfg ¶

func (cfg *IncrDumpConfig) ToDriverCfg() replication.BinlogSyncerConfig

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
fulldump Package fulldump provides helper functions for full dump.	Package fulldump provides helper functions for full dump.
incrdump Package incrdum provides helper functions for incremental change capture.	Package incrdum provides helper functions for incremental change capture.

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