public class RemoteStoreServer extends Object
Modifier and Type | Field and Description |
---|---|
protected StoreCallBack |
callBack |
protected boolean |
delay |
protected static org.apache.commons.logging.Log |
logger |
protected int |
maxQueue |
protected int |
maxThread |
protected int |
port |
protected ReplicaServer |
replicaServer |
protected Serializer |
serializer |
protected Service.State |
serverState |
protected List<TupleThree<String,String,Integer>> |
storeList |
Constructor and Description |
---|
RemoteStoreServer() |
RemoteStoreServer(int port,
List<TupleThree<String,String,Integer>> storeList) |
RemoteStoreServer(int port,
List<TupleThree<String,String,Integer>> storeList,
boolean delay) |
RemoteStoreServer(int port,
List<TupleThree<String,String,Integer>> storeList,
Serializer serializer,
boolean delay) |
RemoteStoreServer(int port,
List<TupleThree<String,String,Integer>> storeList,
Serializer serializer,
int maxThread,
int maxQueue,
boolean delay) |
RemoteStoreServer(RemoteConfig remoteConfig) |
Modifier and Type | Method and Description |
---|---|
boolean |
addRemoteStore(RemoteStore remoteStore) |
boolean |
addRemoteStore(String storeName,
String path,
int mode) |
List<String> |
getAllStoreNames() |
RemoteStore |
getRemoteStore(String store) |
StoreServerHandler |
getTCPHandler() |
protected TCPServer |
getTCPServer() |
void |
hookShutdown() |
protected void |
init(boolean useNio) |
protected void |
initConfig(RemoteConfig remoteConfig) |
protected void |
seTCPtServer(TCPServer server) |
protected void |
setTCPHandler(StoreServerHandler handler) |
void |
shutdown() |
void |
startReplica(RemoteConfig remoteConfig) |
void |
startServer() |
void |
stopServer() |
protected static final org.apache.commons.logging.Log logger
protected int port
protected List<TupleThree<String,String,Integer>> storeList
protected StoreCallBack callBack
protected Serializer serializer
protected int maxThread
protected int maxQueue
protected ReplicaServer replicaServer
protected boolean delay
protected Service.State serverState
public RemoteStoreServer()
public RemoteStoreServer(int port, List<TupleThree<String,String,Integer>> storeList)
public RemoteStoreServer(int port, List<TupleThree<String,String,Integer>> storeList, boolean delay)
public RemoteStoreServer(int port, List<TupleThree<String,String,Integer>> storeList, Serializer serializer, boolean delay)
public RemoteStoreServer(RemoteConfig remoteConfig)
public RemoteStoreServer(int port, List<TupleThree<String,String,Integer>> storeList, Serializer serializer, int maxThread, int maxQueue, boolean delay)
port
- storeList
- serializer
- maxThread
- maxQueue
- delay
- protected void initConfig(RemoteConfig remoteConfig)
protected void init(boolean useNio)
public void startReplica(RemoteConfig remoteConfig)
protected void seTCPtServer(TCPServer server)
protected TCPServer getTCPServer()
protected void setTCPHandler(StoreServerHandler handler)
public StoreServerHandler getTCPHandler()
public RemoteStore getRemoteStore(String store)
public boolean addRemoteStore(RemoteStore remoteStore)
public void shutdown()
public void stopServer()
public void startServer()
public void hookShutdown()
Copyright © 2016. All rights reserved.