Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

canal

package

Go to main page

Versions in this module

v1

v1.1.1

Apr 8, 2021

Changes in this version

type Config

+ DisableRetrySync bool

v1.1.0

Jul 17, 2020

v1.0.0

Jun 22, 2020

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

+ 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