mysql-binlog-filter/binlog/binlog.go

package binlog

import "fmt"

func (c *Conn) registerAsSlave() error {
	brsc := &RegisterSlaveCommand{
		Status:   CommandRegisterSlave,
		ServerId: c.Config.ServerID,
		Hostname: "",
		User:     "",
		Password: "",
		Port:     0,
		ReplRank: 0,
		MasterId: 0,
	}

	return c.writeBinlogRegisterSlaveCommand(brsc)
}

func (c *Conn) startBinlogStream() error {
	bldc := &DumpCommand{
		Status:   CommandBinLogDump,
		Position: 120,
		Flags:    DumpNonBlock,
		ServerId: c.Config.ServerID,
		Filename: c.Config.BinlogFile,
	}

	return c.writeBinlogDumpCommand(bldc)
}

func (c *Conn) listenForBinlog() error {
	for {
		p, err := c.readPacket()
		fmt.Printf("p = %+v\n", p)
		fmt.Printf("err = %+v\n", err)
		if err != nil || p == nil {
			return err
		}

		kp := p.(*OKPacket)
		c.getEventHeader(kp)
	}
}

func (c *Conn) getEventHeader(p *OKPacket) {
	/*
		4              timestamp
		1              event type
		4              server-id
		4              event-size
		   if binlog-version > 1:
		4              log pos
		2              flags
	*/

	_ = c.getInt(TypeFixedInt, 4)
}