mysql-binlog-filter/binlog/commands.go

package binlog

const DumpNonBlock = 0x00 // Set to 0 because we do want the binlog to block.

const CommandRegisterSlave = 0x15
const CommandBinLogDump = 0x12

type RegisterSlaveCommand struct {
	Status   uint64
	ServerId uint64
	Hostname string // Length Encoded
	User     string // Length Encoded
	Password string // Length Encoded
	Port     uint64
	ReplRank uint64
	MasterId uint64
}

func (c *Conn) writeBinlogRegisterSlaveCommand(brsc *RegisterSlaveCommand) error {
	c.putInt(TypeFixedInt, brsc.Status, 1)
	c.putInt(TypeFixedInt, brsc.ServerId, 4)
	c.putString(TypeLenEncString, brsc.Hostname)
	c.putString(TypeLenEncString, brsc.User)
	c.putString(TypeLenEncString, brsc.Password)
	c.putInt(TypeFixedInt, brsc.Port, 2)
	c.putInt(TypeFixedInt, brsc.ReplRank, 4)
	c.putInt(TypeFixedInt, brsc.MasterId, 4)

	if c.Flush() != nil {
		return c.Flush()
	}

	return nil
}

type DumpCommand struct {
	Status   uint64
	Position uint64
	Flags    uint64
	ServerId uint64
	Filename string
}

func (c *Conn) writeBinlogDumpCommand(bldc *DumpCommand) error {
	c.putInt(TypeFixedInt, bldc.Status, 1)
	c.putInt(TypeFixedInt, bldc.Position, 4)
	c.putInt(TypeFixedInt, bldc.Flags, 2)
	c.putInt(TypeFixedInt, bldc.ServerId, 4)
	c.putString(TypeRestOfPacketString, bldc.Filename)

	if c.Flush() != nil {
		return c.Flush()
	}

	return nil
}