input

package
v0.3.8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 18, 2023 License: GPL-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MongoInputPlugin added in v0.3.0

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

func (*MongoInputPlugin) AfterMsgCommit added in v0.3.0

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

func (*MongoInputPlugin) Close added in v0.3.0

func (mi *MongoInputPlugin) Close()

func (*MongoInputPlugin) GetDelay added in v0.3.0

func (mi *MongoInputPlugin) GetDelay() uint32

func (*MongoInputPlugin) NewInput added in v0.3.0

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

func (*MongoInputPlugin) RemoveIncludeTableRegex added in v0.3.0

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

func (*MongoInputPlugin) SetIncludeTableRegex added in v0.3.0

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

func (*MongoInputPlugin) StartInput added in v0.3.0

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

func (*MongoInputPlugin) StartMetrics added in v0.3.0

func (mi *MongoInputPlugin) StartMetrics()

type MysqlInputPlugin added in v0.3.0

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

func (*MysqlInputPlugin) AfterMsgCommit added in v0.3.0

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

func (*MysqlInputPlugin) Close added in v0.3.0

func (mi *MysqlInputPlugin) Close()

func (*MysqlInputPlugin) NewInput added in v0.3.0

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

func (*MysqlInputPlugin) OnDDL added in v0.3.2

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

func (*MysqlInputPlugin) OnPosSynced added in v0.3.0

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

func (*MysqlInputPlugin) OnRow added in v0.3.0

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

func (*MysqlInputPlugin) OnTableChanged added in v0.3.2

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

func (*MysqlInputPlugin) RemoveIncludeTableRegex added in v0.3.0

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

func (*MysqlInputPlugin) SetIncludeTableRegex added in v0.3.0

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

func (*MysqlInputPlugin) StartInput added in v0.3.0

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

func (*MysqlInputPlugin) StartMetrics added in v0.3.0

func (mi *MysqlInputPlugin) StartMetrics()

type NS added in v0.3.0

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

type Plugin added in v0.3.0

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL