output

type MQMessage struct {
	Schema      string                 `json:"schema"`
	Table       string                 `json:"table"`
	Operation   string                 `json:"operation"`
	Data        map[string]interface{} `json:"data"`
	OperateTime int64                  `json:"operateTime"`
}

type Output interface {
	// Handle row data
	Write(wal ...*model.WalData) error
	Close()
}