types

type Action int

type AuditLog struct {
	Time         time.Time `ch:"time"`
	Context      string    `ch:"context"`
	GTID         string    `ch:"gtid"`
	BinlogEvents []ChBinlogEvent
}

type BinlogEvent struct {
	Db     string       `json:"db"`
	Table  string       `json:"table"`
	Action Action       `json:"action"`
	GTID   string       `json:"gtid"`
	Time   int64        `json:"time"`
	Data   sql.RawBytes `json:"data"`
}

type ChBinlogEvent struct {
	Db     string `ch:"db"`
	Table  string `ch:"table"`
	Action int32  `ch:"action"`
	GTID   string `ch:"gtid"`
	Data   string `ch:"data"`
}

type ChTxInfo struct {
	Time    time.Time `json:"time" ch:"time"`
	Context string    `json:"context" ch:"context"`
	GTID    string    `json:"gtid" ch:"gtid"`
	Status  uint8     `json:"-" ch:"-"`
}

type FormatData struct {
	Before map[string]interface{} `json:"before"` // 变更前数据, insert 类型的 before 为空
	After  map[string]interface{} `json:"after"`  // 变更后数据, delete 类型的 after 为空
}

type TxInfo struct {
	Time    int64  `db:"time" json:"time"`
	Context string `db:"context" json:"context"`
	GTID    string `db:"gtid" json:"gtid"`
}