common

type Consumer interface {
	Accept(e *canal.RowsEvent) error
	Name() string
}

type MySQLInstance struct {
	Host     string `json:"host" yaml:"host"`
	Port     int    `json:"port" yaml:"port"`
	Username string `json:"username" yaml:"username"`
	Password string `json:"password" yaml:"password"`
	Database string `json:"database,omitempty" yaml:"database"`
}

type Sinker interface {
	// Enable 是否开启
	Enable() bool

	// Disable 设置停止
	Disable()

	// OnEvent 处理事件
	OnEvent(*canal.RowsEvent) error

	// ContinueOnError 错误是否继续
	ContinueOnError() bool
}