encoding

type DDLJson_2_0 struct {
	MysqlJson_2_0_header
	SQL string `json:"sql"`
}

type DDLMsg_0_1 struct {
	MysqlJson_0_1_header
	SQL string `json:"sql"`
}

type DmlJson_2_0 struct {
	MysqlJson_2_0_header
	Data map[string]interface{}
	Old  map[string]interface{}
	Pks  map[string]interface{}
}

type DmlStringMsg_0_1 struct {
	MysqlJson_0_1_header
	Data map[string]*string `json:"data"`
	Old  map[string]*string `json:"old"`
	Pks  map[string]*string `json:"pks,omitempty"`
}

type Encoder interface {
	Serialize(msg *core.Msg, version string) ([]byte, error)
	Deserialize(b []byte) (core.Msg, error)
}

type JsonMsg01 struct {
	Version          string  `json:"version"`
	Database         string  `json:"database"`
	Collection       string  `json:"collection"`
	UniqueSourceName string  `json:"unique_source_name"`
	Oplog            *gtm.Op `json:"oplog"`
}

type JsonMsgVersion20 struct {
	Version    string                 `json:"version"`
	Database   string                 `json:"database"`
	Collection string                 `json:"collection"`
	Data       map[string]interface{} `json:"data"`
	Row        map[string]interface{} `json:"row"`
}

type MysqlJson_0_1_header struct {
	Version   string `json:"version"`
	Database  string `json:"database"`
	Table     string `json:"table"`
	Type      string `json:"type"`
	Timestamp int64  `json:"ts"`
	TimeZone  string `json:"time_zone"`
	Host      string `json:"host"`
}

type MysqlJson_2_0_header struct {
	Version  string `json:"version"`
	Database string `json:"database"`
	Table    string `json:"table"`
	Type     string `json:"type"`
}