Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddMissingColumn ¶
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:"execution-engine" json:"execution-engine"`
}
Source Files
Click to show internal directories.
Click to hide internal directories.