msg

Documentation

Index

• Constants
• type ActionType
• type DDLMsg
• type DMLMsg
• type Msg
• type MsgCallbackFunc
• type MsgType
• type PluginName
• type WatchId

Constants

const (
	MsgDML MsgType = "dml"
	MsgDDL MsgType = "ddl"
	MsgCtl MsgType = "ctl" // control operate

	InsertAction  ActionType = "insert"
	UpdateAction  ActionType = "update"
	DeleteAction  ActionType = "delete"
	ReplaceAction ActionType = "replace"

	MysqlPlugin PluginName = "Mysql"
	MongoPlugin PluginName = "Mongo"
)

Types

type ActionType

type ActionType string

type DDLMsg

type DDLMsg struct {
	Statement string
	AST       ast.StmtNode
}

type DMLMsg

type DMLMsg struct {
	Action ActionType
	Data   map[string]interface{}
	Old    map[string]interface{}
}

type Msg

type Msg struct {
	Database            string
	Table               string
	Type                MsgType
	DmlMsg              *DMLMsg
	DdlMsg              *DDLMsg
	PluginName          PluginName
	ResumeToken         *WatchId `bson:"_id"`
	Timestamp           time.Time
	InputContext        interface{}
	AfterCommitCallback MsgCallbackFunc
}

type MsgCallbackFunc

type MsgCallbackFunc func(m *Msg) error

type MsgType

type MsgType string

type PluginName

type PluginName string

type WatchId

type WatchId struct {
	Data string `bson:"_data"`
}