mysql-binlog-filter/binlog/binlog.go

package binlog

import "fmt"

func (c *Conn) startBinLogStream() error {
	bldc := &BinLogDumpCommand{
		Status:   COMMAND_BIN_LOG_DUMP,
		Position: 120,
		Flags:    BINLOG_DUMP_NON_BLOCK,
		ServerId: c.Config.ServerId,
		Filename: c.Config.BinLogFile,
	}

	return c.writeBinLogDumpCommand(bldc)
}

func (c *Conn) listenForBinlog() error {
	_, err := c.listen()
	if err != nil {
		return err
	}

	//fmt.Printf("res = %+v\n", res)
	fmt.Println("hello")
	err = c.listenForBinlog()
	fmt.Println("test")
	if err != nil {
		return err
	}

	return nil
}