public class ClusterStoreServer extends Object implements Service
Service.State
Modifier and Type | Field and Description |
---|---|
protected ClusterStoreCallBack |
callBack |
protected int |
clusterNo |
protected static org.apache.commons.logging.Log |
logger |
protected ReplicaServer |
replicaServer |
protected Serializer |
serializer |
protected ClusterServerConfig |
serverConfig |
protected Service.State |
state |
protected ConcurrentMap<String,RemoteStore> |
storeMaps |
Constructor and Description |
---|
ClusterStoreServer(ClusterServerConfig serverConfig,
Serializer serializer) |
Modifier and Type | Method and Description |
---|---|
protected Map<String,voldemort.store.cachestore.impl.CacheStore> |
buildMap(Map<String,RemoteStore> storeMap) |
protected String |
findPath(String dataPath) |
List<String> |
getAllStoreNames() |
ClusterStoreCallBack |
getCallBack() |
int |
getClusterNo() |
ClusterServerHandler |
getHandler() |
ReplicaServer |
getReplicaServer() |
TCPServer |
getServer() |
ClusterServerConfig |
getServerConfig() |
Service.State |
getState() |
Service.State |
getStatus() |
ClusterStore |
getStore(String store) |
ConcurrentMap<String,RemoteStore> |
getStoreMaps() |
void |
hookShutdown() |
protected void |
init() |
void |
shutdown() |
void |
start() |
protected void |
startAdminStore() |
void |
startReplicaServer() |
void |
startServer() |
void |
stop() |
void |
stopReplicaServer() |
void |
stopServer() |
protected static final org.apache.commons.logging.Log logger
protected ClusterStoreCallBack callBack
protected Serializer serializer
protected ReplicaServer replicaServer
protected ConcurrentMap<String,RemoteStore> storeMaps
protected Service.State state
protected ClusterServerConfig serverConfig
protected int clusterNo
public ClusterStoreServer(ClusterServerConfig serverConfig, Serializer serializer)
protected void init()
protected void startAdminStore()
public ClusterStore getStore(String store)
public void hookShutdown()
protected Map<String,voldemort.store.cachestore.impl.CacheStore> buildMap(Map<String,RemoteStore> storeMap)
public void shutdown()
public void stopServer()
public void stopReplicaServer()
public void startReplicaServer()
public Service.State getStatus()
public void startServer()
public ConcurrentMap<String,RemoteStore> getStoreMaps()
public ReplicaServer getReplicaServer()
public TCPServer getServer()
public ClusterServerHandler getHandler()
public ClusterStoreCallBack getCallBack()
public Service.State getState()
public int getClusterNo()
public ClusterServerConfig getServerConfig()
Copyright © 2016. All rights reserved.