binlog

Documentation

Index

• func B2S(bs []uint8) string
• type Binlog
  • func NewBinlog(tgt *client.Conn, serverId uint32, host string, port uint16, ...) *Binlog
  • func (b *Binlog) LoadColumnsForTable(schema, table string) ([]string, error)
  • func (b *Binlog) Run()

Functions

func B2S

func B2S(bs []uint8) string

Types

type Binlog

type Binlog struct {
	Target *client.Conn
	Tables map[string][]config.Table
	// contains filtered or unexported fields
}

func NewBinlog

func NewBinlog(tgt *client.Conn, serverId uint32, host string, port uint16, user, password string, t map[string][]config.Table, gtid, position string, logger *zap.Logger) *Binlog

func (*Binlog) LoadColumnsForTable

func (b *Binlog) LoadColumnsForTable(schema, table string) ([]string, error)

func (*Binlog) Run

func (b *Binlog) Run()