river

type Config struct {
	SrcMyAddr     string `toml:"src_my_addr"`
	SrcMyUser     string `toml:"src_my_user"`
	SrcMyPassword string `toml:"src_my_pass"`
	SrcMyCharset  string `toml:"src_my_charset"`

	DestMyAddr     string `toml:"dest_my_addr"`
	DestMyUser     string `toml:"dest_my_user"`
	DestMyPassword string `toml:"dest_my_pass"`
	DestMyCharset  string `toml:"dest_my_charset"`

	StatAddr string `toml:"stat_addr"`

	ServerID uint32 `toml:"server_id"`
	Flavor   string `toml:"flavor"`
	DataDir  string `toml:"data_dir"`

	DumpExec       string `toml:"mysqldump"`
	SkipMasterData bool   `toml:"skip_master_data"`

	Sources []SourceConfig `toml:"source"`

	Rules []*Rule `toml:"rule"`

	BulkSize int `toml:"bulk_size"`

	FlushBulkTime TomlDuration `toml:"flush_bulk_time"`

	SkipNoPkTable bool `toml:"skip_no_pk_table"`
}

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

type Rule struct {
	Schema string   `toml:"schema"`
	Table  string   `toml:"table"`
	Index  string   `toml:"index"`
	Type   string   `toml:"type"`
	Parent string   `toml:"parent"`
	ID     []string `toml:"id"`

	// Default, a MySQL table field name is mapped to Elasticsearch field name.
	// Sometimes, you want to use different name, e.g, the MySQL file name is title,
	// but in Elasticsearch, you want to name it my_title.
	FieldMapping map[string]string `toml:"field"`

	// MySQL table information
	TableInfo *schema.Table

	//only MySQL fields in filter will be synced , default sync all fields
	Filter []string `toml:"filter"`

	// Elasticsearch pipeline
	// To pre-process documents before indexing
	Pipeline string `toml:"pipeline"`
}

type SourceConfig struct {
	Schema     string   `toml:"schema"`
	DestSchema string   `toml:"dest_schema"`
	Tables     []string `toml:"tables"`
}

type TomlDuration struct {
	time.Duration
}