core

Nov 22, 2023

Changes in this version

+ type Input interface

+ Close func()

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

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

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

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

+ StartMetrics func()

+ type Output interface

+ AddRule func(map[string]interface{}) error

+ Close func()

+ DeleteRule func(map[string]interface{}) error

+ Execute func(msgs []*msg.Msg, tableObj *schema.Table, targetSchema string, ...) error

+ GetRules func() interface{}

+ IsPaused func() bool

+ NewOutput func(config interface{}, rulesMap map[string]interface{}, inSchema Schema)

+ Pause func() error

+ Resume func() error

+ StartOutput func(outputChan *channel.OutputChannel)

+ type Position interface

+ Close func()

+ LoadPosition func(config *config.BaseConfig) string

+ ModifyPosition func(v string) error

+ SavePosition func() error

+ StartPosition func()

+ type Rule interface

+ GetRule func(key string) interface{}

+ GetRuleToMap func() map[string]interface{}

+ GetRuleToRegex func() []string

+ NewRule func(map[string]interface{})

+ TargetString func() string

+ type Schema interface

+ AddTable func(db string, table string) (*schema.Table, error)

+ AddTableForMsg func(msg *msg.Msg) error

+ Close func()

+ DelTable func(db string, table string) error

+ GetTable func(db string, table string) (*schema.Table, error)

+ NewSchemaTables func(config *config.BaseConfig, pluginConfig map[string]interface{}, ...)

+ RefreshTable func(db string, table string)

+ SaveMeta func(data string) error

+ UpdateTable func(db string, table string, args interface{}, pos string, index int) error