org.apache.shardingsphere.infra.datasource.state

类 DataSourceStateManager

java.lang.Object

org.apache.shardingsphere.infra.datasource.state.DataSourceStateManager

public final class DataSourceStateManager
extends Object

Data source state manager.

构造器概要

构造器

构造器和说明
DataSourceStateManager()

方法概要

限定符和类型	方法和说明
Map<String,DataSource>	getEnabledDataSourceMap(String databaseName, Map<String,DataSource> dataSources) Get enabled data source map.
Collection<DataSource>	getEnabledDataSources(String databaseName, DatabaseConfiguration databaseConfig) Get enabled data sources.
static DataSourceStateManager	getInstance() Get data source state manager.
void	initStates(String databaseName, Map<String,DataSource> dataSources, Map<String,DataSourceState> storageDataSourceStates, boolean forceStart) Set data source states when bootstrap.
void	updateState(String databaseName, String actualDataSourceName, DataSourceState dataSourceState) Update data source state.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

DataSourceStateManager

public DataSourceStateManager()

方法详细资料

getInstance

public static DataSourceStateManager getInstance()

Get data source state manager.

返回:

data source state manager

initStates

public void initStates(String databaseName,
                       Map<String,DataSource> dataSources,
                       Map<String,DataSourceState> storageDataSourceStates,
                       boolean forceStart)

Set data source states when bootstrap.

参数:

databaseName - database name

dataSources - data sources

storageDataSourceStates - storage node data source state

forceStart - whether to force start

getEnabledDataSources

public Collection<DataSource> getEnabledDataSources(String databaseName,
                                                    DatabaseConfiguration databaseConfig)

Get enabled data sources.

参数:

databaseName - database name

databaseConfig - database config

返回:

enabled data sources

getEnabledDataSourceMap

public Map<String,DataSource> getEnabledDataSourceMap(String databaseName,
                                                      Map<String,DataSource> dataSources)

Get enabled data source map.

参数:

databaseName - database name

dataSources - data sources

返回:

enabled data source map

updateState

public void updateState(String databaseName,
                        String actualDataSourceName,
                        DataSourceState dataSourceState)

Update data source state.

参数:

databaseName - database name

actualDataSourceName - actual data source name

dataSourceState - data source state