input

Nov 22, 2023

Changes in this version

+ const MongoName

+ const MysqlName

type MongoInputPlugin

+ func (mi *MongoInputPlugin) Configure(pipelineName string, configInput map[string]interface{}) error

type MysqlInputPlugin

+ func (mi *MysqlInputPlugin) Configure(pipelineName string, configInput map[string]interface{}) error

Jul 8, 2023

Changes in this version

type MysqlInputPlugin

+ func (mi *MysqlInputPlugin) OnDDL(nextPos mysql.Position, queryEvent *replication.QueryEvent) error

+ func (mi *MysqlInputPlugin) OnTableChanged(schema string, table string) error

Jun 30, 2023

Changes in this version

+ type MongoInputPlugin struct

+ ChangeStream *mongo.ChangeStream

+ Client *mongo.Client

+ func (mi *MongoInputPlugin) AfterMsgCommit(msg *msg.Msg) error

+ func (mi *MongoInputPlugin) Close()

+ func (mi *MongoInputPlugin) GetDelay() uint32

+ func (mi *MongoInputPlugin) NewInput(inputConfig interface{}, ruleRegex []string)

+ func (mi *MongoInputPlugin) RemoveIncludeTableRegex(config map[string]interface{}) (*regexp.Regexp, error)

+ func (mi *MongoInputPlugin) SetIncludeTableRegex(config map[string]interface{}) (*regexp.Regexp, error)

+ func (mi *MongoInputPlugin) StartInput(pos position.Position, syncChan *channel.SyncChannel) position.Position

+ func (mi *MongoInputPlugin) StartMetrics()

+ type MysqlInputPlugin struct

+ func (mi *MysqlInputPlugin) AfterMsgCommit(msg *msg.Msg) error

+ func (mi *MysqlInputPlugin) Close()

+ func (mi *MysqlInputPlugin) NewInput(inputConfig interface{}, ruleRegex []string)

+ func (mi *MysqlInputPlugin) OnPosSynced(pos mysql.Position, set mysql.GTIDSet, force bool) error

+ func (mi *MysqlInputPlugin) OnRow(e *canal.RowsEvent) error

+ func (mi *MysqlInputPlugin) RemoveIncludeTableRegex(config map[string]interface{}) (*regexp.Regexp, error)

+ func (mi *MysqlInputPlugin) SetIncludeTableRegex(config map[string]interface{}) (*regexp.Regexp, error)

+ func (mi *MysqlInputPlugin) StartInput(pos position.Position, syncChan *channel.SyncChannel) position.Position

+ func (mi *MysqlInputPlugin) StartMetrics()

+ type NS struct

+ Collection string

+ Database string

+ type Plugin interface

+ Close func()

+ NewInput func(config interface{}, ruleRegex []string)

+ RemoveIncludeTableRegex func(map[string]interface{}) (*regexp.Regexp, error)

+ SetIncludeTableRegex func(map[string]interface{}) (*regexp.Regexp, error)

+ StartInput func(pos position.Position, syncChan *channel.SyncChannel) position.Position

+ StartMetrics func()

Jun 16, 2023

Changes in this version

type MyEventHandler

+ func (h *MyEventHandler) RuleMap() map[string]*rule.MysqlToSrRule

Jun 7, 2023

Changes in this version

+ type Mongo struct

+ ChangeStream *mongo.ChangeStream

+ Client *mongo.Client

+ Config *config.MongoSrConfig

+ OutputType string

+ func NewMongo(conf *config.MongoSrConfig) *Mongo

+ func (m *Mongo) Cancel() context.CancelFunc

+ func (m *Mongo) Ctx() context.Context

+ func (m *Mongo) StartChangeStream()

+ type MyEventHandler struct

+ StartPosition string

+ func NewMysql(conf *config.MysqlSrConfig) *MyEventHandler

+ func (h *MyEventHandler) AckGTIDSet() mysql.GTIDSet

+ func (h *MyEventHandler) C() *canal.Canal

+ func (h *MyEventHandler) Cancel() context.CancelFunc

+ func (h *MyEventHandler) Ctx() context.Context

+ func (h *MyEventHandler) OnPosSynced(pos mysql.Position, set mysql.GTIDSet, force bool) error

+ func (h *MyEventHandler) OnRow(e *canal.RowsEvent) error

+ func (h *MyEventHandler) String() string

+ type Mysql struct

+ type StreamObject struct

+ ClusterTime primitive.Timestamp

+ DocumentKey map[string]interface{}

+ FullDocument map[string]interface{}

+ Id *msg.WatchId

+ Ns msg.NS

+ OperationType string

+ UpdateDescription map[string]interface{}