openbilibili/app/job/main/dm/model/job.go

package model

import (
	"encoding/json"
)

// All const variable used in job
const (
	// binlog type
	SyncInsert = "insert"
	SyncUpdate = "update"
	SyncDelete = "delete"
)

// BinlogMsg dm binlog msg
type BinlogMsg struct {
	Action string          `json:"action"`
	Table  string          `json:"table"`
	New    json.RawMessage `json:"new"`
	Old    json.RawMessage `json:"old"`
}