openbilibili/app/infra/canal/model/model.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
}