config

type ClusterConfiguration struct {
	Props        *mas.PropertiesConfiguration        `yaml:"props"`
	EtcdConfig   *etcd.EtcdConfiguration             `yaml:"etcd"`
	RouterConfig *RouterConfiguration                `yaml:"router"`
	DataSource   map[string]*DataSourceConfiguration `yaml:"datasource"`
}

type DataSourceConfiguration struct {
	URL      string `yaml:"url"` // dsn format, `protocol(address)/dbname?param=value`
	Username string `yaml:"username"`
	Password string `yaml:"password"`
	Region   string
	Server   string
	Schema   string
}

type IntegrationClusterConfiguration struct {
	ClusterConfiguration       *ClusterConfiguration
	RemoteClusterConfiguration *RemoteClusterConfiguration
}

type NodeConfiguration struct {
	Weight      int      `yaml:"weight"`
	Master      string   `yaml:"master"`
	LoadBalance string   `yaml:"loadBalance"`
	Slaves      []string `yaml:"slaves"`
}

type RemoteClusterConfiguration struct {
	DataSources  map[string]*RemoteDataSourceConfiguration
	RouterConfig *RouterConfiguration
}

type RemoteDataSourceConfiguration struct {
	Server   string
	Schema   string
	Username string
	Password string
	Region   string
	Cloud    string
}

type RetryConfiguration struct {
	Times string `yaml:"times"`
	Delay string `yaml:"delay"`
}

type RouterConfiguration struct {
	Retry          *RetryConfiguration           `yaml:"retry"`
	Nodes          map[string]*NodeConfiguration `yaml:"nodes"`
	Active         string                        `yaml:"active"`
	RouteAlgorithm string                        `yaml:"routeAlgorithm"`
}

type RouterConfigurationListener interface {
	// OnChanged when active data changes will call back
	OnChanged(configuration *RouterConfiguration)
}