mysql_cdc

Documentation

Index

• func NewMysqlSourcePlugin(config Config, sCh []schema.StreamSchema) sources.DataSource
• type Config
• type DataTableSchema
• type ProcessEventParams
• type SourcePlugin
  • 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()

Functions

func NewMysqlSourcePlugin

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

Types

type Config

type Config struct {
	Host           string `json:"host" yaml:"host"`
	Port           uint16 `json:"port" yaml:"port"`
	Database       string `json:"database" yaml:"database"`
	User           string `json:"user" yaml:"user"`
	Password       string `json:"password" yaml:"password"`
	Flavor         string `json:"flavor" yaml:"flavor"`
	StreamSnapshot bool   `json:"stream_snapshot" yaml:"stream_snapshot"`
}

type DataTableSchema

type DataTableSchema struct {
	TableName string
	Schema    *arrow.Schema
}

type ProcessEventParams

type ProcessEventParams struct {
	// contains filtered or unexported fields
}

type SourcePlugin

type SourcePlugin struct {
	canal.DummyEventHandler
	// contains filtered or unexported fields
}

func (*SourcePlugin) Connect

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

func (*SourcePlugin) Events

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

func (*SourcePlugin) OnRow

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

func (*SourcePlugin) Start

func (p *SourcePlugin) Start()

func (*SourcePlugin) Stop

func (p *SourcePlugin) Stop()