Documentation
¶
Index ¶
Constants ¶
View Source
const (
Name = "mysql"
)
Variables ¶
This section is empty.
Functions ¶
func AddMissingColumn ¶
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 ¶ added in v0.9.17
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"`
}
Source Files
Click to show internal directories.
Click to hide internal directories.