20 lines
410 B
Go
20 lines
410 B
Go
package model
|
|
|
|
// Data msg will be push to databus
|
|
type Data struct {
|
|
Action string `json:"action"`
|
|
Table string `json:"table"`
|
|
// kafka key
|
|
Key string `json:"-"`
|
|
Old map[string]interface{} `json:"old,omitempty"`
|
|
New map[string]interface{} `json:"new,omitempty"`
|
|
}
|
|
|
|
// TiDBInfo tidb db model
|
|
type TiDBInfo struct {
|
|
Name string
|
|
ClusterID string
|
|
Offset int64
|
|
CommitTS int64
|
|
}
|