input

Documentation

Index

• Constants
• type MongoInputPlugin
  • func (mi *MongoInputPlugin) AfterMsgCommit(msg *msg.Msg) error
  • func (mi *MongoInputPlugin) Close()
  • func (mi *MongoInputPlugin) Configure(pipelineName string, configInput map[string]interface{}) error
  • func (mi *MongoInputPlugin) GetDelay() uint32
  • func (mi *MongoInputPlugin) NewInput(inputConfig interface{}, ruleRegex []string, inSchema core.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 core.Position, syncChan *channel.SyncChannel) core.Position
  • func (mi *MongoInputPlugin) StartMetrics()
• type MysqlInputPlugin
  • func (mi *MysqlInputPlugin) AfterMsgCommit(msg *msg.Msg) error
  • func (mi *MysqlInputPlugin) Close()
  • func (mi *MysqlInputPlugin) Configure(pipelineName string, configInput map[string]interface{}) error
  • func (mi *MysqlInputPlugin) NewInput(inputConfig interface{}, ruleRegex []string, inSchema core.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 core.Position, syncChan *channel.SyncChannel) core.Position
  • func (mi *MysqlInputPlugin) StartMetrics()
• type NS

Constants

const MongoName = "mongo"

const MysqlName = "mysql"

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) Configure

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

func (*MongoInputPlugin) GetDelay

func (mi *MongoInputPlugin) GetDelay() uint32

func (*MongoInputPlugin) NewInput

func (mi *MongoInputPlugin) NewInput(inputConfig interface{}, ruleRegex []string, inSchema core.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 core.Position, syncChan *channel.SyncChannel) core.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) Configure

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

func (*MysqlInputPlugin) NewInput

func (mi *MysqlInputPlugin) NewInput(inputConfig interface{}, ruleRegex []string, inSchema core.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 core.Position, syncChan *channel.SyncChannel) core.Position

func (*MysqlInputPlugin) StartMetrics

func (mi *MysqlInputPlugin) StartMetrics()

type NS

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