model

type Bytes []byte

type ConsumerMessage struct {
	*sarama.ConsumerMessage
}

type RowsEvent struct {
	Log           string `json:"log"`
	Position      uint32 `json:"pos"`
	Schema        string `json:"db"`
	Table         string `json:"tbl"`
	Action        string `json:"dml"`
	Timestamp     uint32 `json:"ts"` // timestamp of binlog from master
	DbusTimestamp int64  `json:"dt"` // timestamp of dbus receiving the binlog

	Columns []string `json:"cols"` // column names

	// binlog has three update event version, v0, v1 and v2.
	// for v1 and v2, the rows number must be even.
	// Two rows for one event, format is [before update row, after update row]
	// for update v0, only one row for a event, and we don't support this version.
	Rows [][]interface{} `json:"rows"`
	// contains filtered or unexported fields
}

type String string