gocanalserver

GoCanalServer

This is a binlog subscriber

uage

GoCanalServer start hide # run in Background
GoCanalServer start show # 

File Structure

|--bin
   ---GoCanalServer
|--conf
   ---app.conf   
|---log

TCP Protocol

frist auth packet
type ServerProto struct {
	Sgin  string
	Mname string
	End   string
}

send msg packet

type Msg struct {
	Sgin [8]byte
	len  uint32
	Body []byte # json.Marshal(Packet)
	End  [8]byte
}
type Packet struct {
	Types       string
	Table       string
	ColumnsType map[string]string
	Columns     []string
	Action      string
	Rows        [][]interface{}
	ColumnsPK   []string
}