mysql

type CDCConfig struct {
	SourceID       string            `json:"source_id" yaml:"source_id"`
	Host           string            `json:"host" yaml:"host"`
	Port           int               `json:"port" yaml:"port"`
	User           string            `json:"user" yaml:"user"`
	Password       string            `json:"password" yaml:"password"`
	Flavor         string            `json:"flavor" yaml:"flavor"` // mysql or mariadb
	ServerID       uint32            `json:"server_id" yaml:"server_id"`
	Database       string            `json:"database" yaml:"database"`
	Tables         []string          `json:"tables" yaml:"tables"`
	Operations     []string          `json:"operations" yaml:"operations"`
	SchemaMapping  map[string]string `json:"schema_mapping" yaml:"schema_mapping"`
	StartFile      string            `json:"start_file" yaml:"start_file"`
	StartPos       uint32            `json:"start_pos" yaml:"start_pos"`
	GTID           string            `json:"gtid" yaml:"gtid"`
	CheckpointPath string            `json:"checkpoint_path" yaml:"checkpoint_path"`
	DSN            string            `json:"dsn" yaml:"dsn"`
	BufferSize     int               `json:"buffer_size" yaml:"buffer_size"`
	Timeout        time.Duration     `json:"timeout" yaml:"timeout"`
}

type CDCFactory struct{}

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

type ChangeEvent struct {
	Operation string                 `json:"operation"`
	Schema    string                 `json:"schema"`
	Table     string                 `json:"table"`
	Before    map[string]interface{} `json:"before,omitempty"`
	After     map[string]interface{} `json:"after,omitempty"`
	Binlog    string                 `json:"binlog"`
	Pos       uint32                 `json:"pos"`
	Timestamp time.Time              `json:"timestamp"`
}