config

type CDCConfig struct {
	Mysql          MySQLSourceConfig `toml:"mysql"`
	SourceRules    SourceRule        `toml:"source_rules"`
	TransformRules []TransformRule   `toml:"transform_rule"`
	KafkaSink      KafkaSink         `toml:"kafka_sink"`
	State          StateTracking     `toml:"state_tracking"`
}

type KafkaSink struct {
	Name           string `toml:"name"`
	Addr           string `toml:"addr"`
	Port           int16  `toml:"port"`
	BatchSizeBytes int16  `toml:"batch_size_bytes"`
}

type MySQLSourceConfig struct {
	Name     string `toml:"name"`
	Addr     string `toml:"addr"`
	Port     int16  `toml:"port"`
	User     string `toml:"user"`
	Pass     string `toml:"pass"`
	ServerId uint32 `toml:"server_id"`
}

type SourceRule struct {
	IncludeSchemas []string `toml:"include_schemas"`
	ExcludeSchemas []string `toml:"exclude_schemas"`
	IncludeTables  []string `toml:"include_tables"`
	ExcludeTables  []string `toml:"exclude_tables"`
}

type StateTracking struct {
	KafkaAddr string `toml:"kafka_addr"`
	Topic     string `toml:"state_topic"`
}

type TransformRule struct {
	Name          string
	MatchSchema   string `toml:"match_schema"`
	MatchTable    string `toml:"match_table"`
	TransformFunc string `toml:"transform_func,multiline"`
}