canal

package

Go to main page

Versions in this module

v1

v1.10.0

Nov 20, 2024

v1.9.1

Sep 18, 2024

Changes in this version

type Config

+ EventCacheCount int

v1.9.0

Aug 5, 2024

Changes in this version

type Config

+ DisableFlushBinlogWhileWaiting bool

v1.8.0

May 10, 2024

Changes in this version

type Config

+ Localhost string

type DummyEventHandler

+ func (h *DummyEventHandler) OnRowsQueryEvent(*replication.RowsQueryEvent) error

type EventHandler

+ OnRowsQueryEvent func(e *replication.RowsQueryEvent) error

v1.7.0

Jan 31, 2023

Changes in this version

type Canal

+ func (c *Canal) SetTableCache(db []byte, table []byte, schema *schema.Table)

type Config

+ Dialer client.Dialer

v1.6.0

Jun 16, 2022

Changes in this version

type Config

+ Logger *log.Logger

v1.5.0

Apr 30, 2022

v1.4.0

Dec 15, 2021

v1.3.0

Jun 10, 2021

v1.2.1

May 27, 2021

v1.2.0

May 15, 2021

v1.1.2

Apr 20, 2021

Changes in this version

+ const DeleteAction

+ const InsertAction

+ const UpdateAction

+ var ErrExcludedTable = errors.New("excluded table meta")

+ var UnknownTableRetryPeriod = time.Second * time.Duration(10)

+ type Canal struct

+ func NewCanal(cfg *Config) (*Canal, error)

+ func (c *Canal) AddDumpDatabases(dbs ...string)

+ func (c *Canal) AddDumpIgnoreTables(db string, tables ...string)

+ func (c *Canal) AddDumpTables(db string, tables ...string)

+ func (c *Canal) CatchMasterPos(timeout time.Duration) error

+ func (c *Canal) CheckBinlogRowImage(image string) error

+ func (c *Canal) ClearTableCache(db []byte, table []byte)

+ func (c *Canal) Close()

+ func (c *Canal) Ctx() context.Context

+ func (c *Canal) Dump() error

+ func (c *Canal) Execute(cmd string, args ...interface{}) (rr *mysql.Result, err error)

+ func (c *Canal) FlushBinlog() error

+ func (c *Canal) GetDelay() uint32

+ func (c *Canal) GetMasterGTIDSet() (mysql.GTIDSet, error)

+ func (c *Canal) GetMasterPos() (mysql.Position, error)

+ func (c *Canal) GetTable(db string, table string) (*schema.Table, error)

+ func (c *Canal) Run() error

+ func (c *Canal) RunFrom(pos mysql.Position) error

+ func (c *Canal) SetEventHandler(h EventHandler)

+ func (c *Canal) StartFromGTID(set mysql.GTIDSet) error

+ func (c *Canal) SyncedGTIDSet() mysql.GTIDSet

+ func (c *Canal) SyncedPosition() mysql.Position

+ func (c *Canal) SyncedTimestamp() uint32

+ func (c *Canal) WaitDumpDone() <-chan struct{}

+ func (c *Canal) WaitUntilPos(pos mysql.Position, timeout time.Duration) error

+ type Config struct

+ Addr string

+ Charset string

+ DisableRetrySync bool

+ DiscardNoMetaRowEvent bool

+ Dump DumpConfig

+ ExcludeTableRegex []string

+ Flavor string

+ HeartbeatPeriod time.Duration

+ IncludeTableRegex []string

+ MaxReconnectAttempts int

+ ParseTime bool

+ Password string

+ ReadTimeout time.Duration

+ SemiSyncEnabled bool

+ ServerID uint32

+ TLSConfig *tls.Config

+ TimestampStringLocation *time.Location

+ UseDecimal bool

+ User string

+ func NewConfig(data string) (*Config, error)

+ func NewConfigWithFile(name string) (*Config, error)

+ func NewDefaultConfig() *Config

+ type DummyEventHandler struct

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

+ func (h *DummyEventHandler) OnGTID(mysql.GTIDSet) error

+ func (h *DummyEventHandler) OnPosSynced(mysql.Position, mysql.GTIDSet, bool) error

+ func (h *DummyEventHandler) OnRotate(*replication.RotateEvent) error

+ func (h *DummyEventHandler) OnRow(*RowsEvent) error

+ func (h *DummyEventHandler) OnTableChanged(schema string, table string) error

+ func (h *DummyEventHandler) OnXID(mysql.Position) error

+ func (h *DummyEventHandler) String() string

+ type DumpConfig struct

+ Databases []string

+ DiscardErr bool

+ ExecutionPath string

+ ExtraOptions []string

+ IgnoreTables []string

+ MaxAllowedPacketMB int

+ Protocol string

+ SkipMasterData bool

+ TableDB string

+ Tables []string

+ Where string

+ type EventHandler interface

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

+ OnGTID func(gtid mysql.GTIDSet) error

+ OnPosSynced func(pos mysql.Position, set mysql.GTIDSet, force bool) error

+ OnRotate func(roateEvent *replication.RotateEvent) error

+ OnRow func(e *RowsEvent) error

+ OnTableChanged func(schema string, table string) error

+ OnXID func(nextPos mysql.Position) error

+ String func() string

+ type RowsEvent struct

+ Action string

+ Header *replication.EventHeader

+ Rows [][]interface{}

+ Table *schema.Table

+ func (r *RowsEvent) String() string

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