mysql_cdc

May 13, 2024

Changes in this version

+ func NewMysqlSourcePlugin(config Config, sCh []schema.StreamSchema) sources.DataSource

+ type Config struct

+ Database string

+ Flavor string

+ Host string

+ Password string

+ Port uint16

+ StreamSnapshot bool

+ User string

+ type DataTableSchema struct

+ Schema *arrow.Schema

+ TableName string

+ type ProcessEventParams struct

+ type SourcePlugin struct

+ func (p *SourcePlugin) Connect(ctx context.Context) error

+ func (p *SourcePlugin) Events() chan sources.MessageEvent

+ func (p *SourcePlugin) OnRow(e *canal.RowsEvent) error

+ func (p *SourcePlugin) Start()

+ func (p *SourcePlugin) Stop()