Versions in this module Expand all Collapse all v0 v0.29.0 Mar 5, 2025 v0.28.0 Dec 27, 2024 Changes in this version + const KeyAction + const KeyColumnNames + const KeyLogPos + const KeyPkColumnNames + const KeyTableFullName + const KeyTableName + const KeyTableSchema + const MatchAll + const Type + type Config struct + Charset string + Dbs []string + ExcludeTables []string + ExecutionPath string + Flavor string + FromOldest bool + Heartbeat int + IncludeTables []string + Password string + ReadTimeout int + Server string + User string + type Endpoint = MySqlCDC + type EventHandler struct + func (h *EventHandler) OnRow(e *canal.RowsEvent) error + func (h *EventHandler) String() string + type MySqlCDC struct + Config Config + RuleConfig types.Config + func (x *MySqlCDC) AddRouter(router endpointApi.Router, params ...interface{}) (string, error) + func (x *MySqlCDC) Close() error + func (x *MySqlCDC) Destroy() + func (x *MySqlCDC) GetDefaultConfig(newConfig Config) *canal.Config + func (x *MySqlCDC) Id() string + func (x *MySqlCDC) Init(ruleConfig types.Config, configuration types.Configuration) error + func (x *MySqlCDC) New() types.Node + func (x *MySqlCDC) Printf(format string, v ...interface{}) + func (x *MySqlCDC) RemoveRouter(routerId string, params ...interface{}) error + func (x *MySqlCDC) Start() error + func (x *MySqlCDC) Type() string + type RegexpRouter struct + type RequestMessage struct + Action string + Header *replication.EventHeader + Table *schema.Table + func (r *RequestMessage) Body() []byte + func (r *RequestMessage) ColumnNames() []string + func (r *RequestMessage) From() string + func (r *RequestMessage) GetError() error + func (r *RequestMessage) GetMsg() *types.RuleMsg + func (r *RequestMessage) GetParam(key string) string + func (r *RequestMessage) Headers() textproto.MIMEHeader + func (r *RequestMessage) PKColumns() []string + func (r *RequestMessage) SetBody(body []byte) + func (r *RequestMessage) SetError(err error) + func (r *RequestMessage) SetMsg(msg *types.RuleMsg) + func (r *RequestMessage) SetStatusCode(statusCode int) + type ResponseMessage struct + Action string + Table *schema.Table + func (r *ResponseMessage) Body() []byte + func (r *ResponseMessage) From() string + func (r *ResponseMessage) GetError() error + func (r *ResponseMessage) GetMsg() *types.RuleMsg + func (r *ResponseMessage) GetParam(key string) string + func (r *ResponseMessage) Headers() textproto.MIMEHeader + func (r *ResponseMessage) SetBody(body []byte) + func (r *ResponseMessage) SetError(err error) + func (r *ResponseMessage) SetMsg(msg *types.RuleMsg) + func (r *ResponseMessage) SetStatusCode(statusCode int)
Go to main page