mysql

Documentation

Index

• Constants
• func AddMissingColumn(msg *core.Msg, targetTableDef *schema_store.Table) (bool, error)
• type MySQLOutput
  • func (output *MySQLOutput) Close()
  • func (output *MySQLOutput) Configure(pipelineName string, data map[string]interface{}) error
  • func (output *MySQLOutput) Execute(msgs []*core.Msg) error
  • func (output *MySQLOutput) GetRouter() core.Router
  • func (output *MySQLOutput) Start() error
• type MySQLPluginConfig

Constants

const (
	Name = "mysql"
)

Functions

func AddMissingColumn

func AddMissingColumn(msg *core.Msg, targetTableDef *schema_store.Table) (bool, error)

AddMissingColumn add data to msg if target table has extra columns. It is considered safe since this casting does not lose information.

Types

type MySQLOutput

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

func (*MySQLOutput) Close

func (output *MySQLOutput) Close()

func (*MySQLOutput) Configure

func (output *MySQLOutput) Configure(pipelineName string, data map[string]interface{}) error

func (*MySQLOutput) Execute

func (output *MySQLOutput) Execute(msgs []*core.Msg) error

msgs in the same batch should have the same table name

func (*MySQLOutput) GetRouter

func (output *MySQLOutput) GetRouter() core.Router

func (*MySQLOutput) Start

func (output *MySQLOutput) Start() error

type MySQLPluginConfig

type MySQLPluginConfig struct {
	DBConfig     *config.DBConfig            `mapstructure:"target"  json:"target"`
	Routes       []map[string]interface{}    `mapstructure:"routes"  json:"routes"`
	EnableDDL    bool                        `mapstructure:"enable-ddl" json:"enable-ddl"`
	EngineConfig *config.GenericPluginConfig `mapstructure:"sql-engine-config"  json:"sql-engine-config"`
}