mysql

Documentation

Index

• 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) Start() error
• type MySQLPluginConfig

Functions

func AddMissingColumn

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

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) Start

func (output *MySQLOutput) Start() error

type MySQLPluginConfig

type MySQLPluginConfig struct {
	DBConfig     *utils.DBConfig                                 `mapstructure:"target"  json:"target"`
	Routes       []map[string]interface{}                        `mapstructure:"routes"  json:"routes"`
	EngineConfig sql_execution_engine.MySQLExecutionEngineConfig `mapstructure:"sql-engine-config"  json:"sql-engine-config"`
}