input

Documentation

Index

• type MongoInputPlugin
  • 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, inSchema schema.Schema)
  • 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
  • func (mi *MysqlInputPlugin) AfterMsgCommit(msg *msg.Msg) error
  • func (mi *MysqlInputPlugin) Close()
  • func (mi *MysqlInputPlugin) NewInput(inputConfig interface{}, ruleRegex []string, inSchema schema2.Schema)
  • func (mi *MysqlInputPlugin) OnDDL(nextPos mysql.Position, queryEvent *replication.QueryEvent) error
  • func (mi *MysqlInputPlugin) OnPosSynced(pos mysql.Position, set mysql.GTIDSet, force bool) error
  • func (mi *MysqlInputPlugin) OnRow(e *canal.RowsEvent) error
  • func (mi *MysqlInputPlugin) OnTableChanged(schema string, table string) 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
• type Plugin

Types

type MongoInputPlugin

type MongoInputPlugin struct {
	*config.MongoConfig
	Client       *mongo.Client
	ChangeStream *mongo.ChangeStream
	// contains filtered or unexported fields
}

func (*MongoInputPlugin) AfterMsgCommit

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

func (*MongoInputPlugin) Close

func (mi *MongoInputPlugin) Close()

func (*MongoInputPlugin) GetDelay

func (mi *MongoInputPlugin) GetDelay() uint32

func (*MongoInputPlugin) NewInput

func (mi *MongoInputPlugin) NewInput(inputConfig interface{}, ruleRegex []string, inSchema schema.Schema)

func (*MongoInputPlugin) RemoveIncludeTableRegex

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

func (*MongoInputPlugin) SetIncludeTableRegex

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

func (*MongoInputPlugin) StartInput

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

func (*MongoInputPlugin) StartMetrics

func (mi *MongoInputPlugin) StartMetrics()

type MysqlInputPlugin

type MysqlInputPlugin struct {
	canal.DummyEventHandler
	*config.MysqlConfig
	// contains filtered or unexported fields
}

func (*MysqlInputPlugin) AfterMsgCommit

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

func (*MysqlInputPlugin) Close

func (mi *MysqlInputPlugin) Close()

func (*MysqlInputPlugin) NewInput

func (mi *MysqlInputPlugin) NewInput(inputConfig interface{}, ruleRegex []string, inSchema schema2.Schema)

func (*MysqlInputPlugin) OnDDL

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

func (*MysqlInputPlugin) OnPosSynced

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

func (*MysqlInputPlugin) OnRow

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

func (*MysqlInputPlugin) OnTableChanged

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

func (*MysqlInputPlugin) RemoveIncludeTableRegex

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

func (*MysqlInputPlugin) SetIncludeTableRegex

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

func (*MysqlInputPlugin) StartInput

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

func (*MysqlInputPlugin) StartMetrics

func (mi *MysqlInputPlugin) StartMetrics()

type NS

type NS struct {
	Database   string `bson:"db"`
	Collection string `bson:"coll"`
}

type Plugin

type Plugin interface {
	NewInput(config interface{}, ruleRegex []string, inSchema schema.Schema)
	StartInput(pos position.Position, syncChan *channel.SyncChannel) position.Position
	StartMetrics()
	Close()
	SetIncludeTableRegex(map[string]interface{}) (*regexp.Regexp, error)    // for add rule
	RemoveIncludeTableRegex(map[string]interface{}) (*regexp.Regexp, error) // for delete rule
}