Package | Description |
---|---|
com.sm.store.cluster |
Modifier and Type | Method and Description |
---|---|
ClusterNodes |
ClusterServerConfig.findClusterNodes(int clusterNo) |
Modifier and Type | Method and Description |
---|---|
List<ClusterNodes> |
BuildClusterNodes.build() |
List<ClusterNodes> |
ClusterServerConfig.getClusterNodesList() |
List<ClusterNodes> |
ClusterConfig.getClusterNodesList() |
Modifier and Type | Method and Description |
---|---|
static ConcurrentMap<Integer,Short> |
Utils.buildPartitionMap(List<ClusterNodes> nodes) |
static ConcurrentMap<Short,String[]> |
Utils.buildServerMap(List<ClusterNodes> nodes) |
static short |
Utils.findClusterNo(String url,
List<ClusterNodes> clusterNodesList) |
static String |
Utils.validateCluster(List<ClusterNodes> nodes) |
static String |
Utils.validateId(List<ClusterNodes> nodes) |
static String |
Utils.validateServer(List<ClusterNodes> nodes) |
Constructor and Description |
---|
ClusterConfig(List<ClusterNodes> clusterNodesList,
RemoteConfig remoteConfig,
int clusterNo) |
ClusterServerConfig(List<ClusterNodes> clusterNodesList,
List<StoreConfig> storeConfigList,
int clusterNo,
String dataPath,
String configPath,
int maxQueue,
int maxThread,
int port,
int replicaPort,
String host,
int freq) |
ClusterServerConfig(List<ClusterNodes> clusterNodesList,
List<StoreConfig> storeConfigList,
int clusterNo,
String dataPath,
String configPath,
int port,
int replicaPort,
String host) |
ClusterServerConfig(List<ClusterNodes> clusterNodesList,
List<StoreConfig> storeConfigList,
int clusterNo,
String dataPath,
String configPath,
int port,
int replicaPort,
String host,
int maxQueue,
int maxThread) |
Copyright © 2016. All rights reserved.