datasource

Dec 6, 2021

Changes in this version

+ const DsnFmt

+ const LoadBalanceTypeRandom

+ const LoadBalanceTypeRoundRobin

+ type ActualDataSource struct

+ Available bool

+ Dsn string

+ LastRetryTime int64

+ Name string

+ RetryTimes int

+ func NewActualDataSource(name string, datasource *config.DataSourceConfiguration) *ActualDataSource

+ type ClusterDataSource struct

+ Active string

+ DataSources map[string]*NodeDataSource

+ Region string

+ RouterConfiguration *config.RouterConfiguration

+ func NewClusterDataSource(clusterConfiguration *config.ClusterConfiguration) (*ClusterDataSource, error)

+ func (cd *ClusterDataSource) OnChanged(configuration *config.RouterConfiguration)

+ type DataSource interface

+ type LoadBalanceAlgorithm interface

+ GetActualDataSource func(int64, []*ActualDataSource) *ActualDataSource

+ func AlgorithmLoader(loadBalanceType string) LoadBalanceAlgorithm

+ type NodeDataSource struct

+ LoadBalanceAlgorithm LoadBalanceAlgorithm

+ MasterDataSource *ActualDataSource

+ Name string

+ Region string

+ SlavesDatasource []*ActualDataSource

+ func NewNodeDataSource(nodeName, loadBalanceType, masterName string, slavesName []string, ...) *NodeDataSource

+ type RandomLoadBalanceAlgorithm struct

+ func (ra *RandomLoadBalanceAlgorithm) GetActualDataSource(requestId int64, slavesDataSource []*ActualDataSource) *ActualDataSource

+ type RoundRobinLoadBalanceAlgorithm struct

+ func (ro *RoundRobinLoadBalanceAlgorithm) GetActualDataSource(requestId int64, slavesDataSource []*ActualDataSource) *ActualDataSource