public class StoreCallBack extends Object implements TCPCallBack
Modifier and Type | Field and Description |
---|---|
protected boolean |
delay |
protected Serializer |
embeddedSerializer |
protected static org.apache.commons.logging.Log |
logger |
protected com.fasterxml.jackson.databind.ObjectMapper |
mapper |
static int |
MAX_SIZE |
protected Serializer |
serializer |
protected Service.State |
serverState |
protected List<TupleThree<String,String,Integer>> |
storeList |
protected ConcurrentMap<String,RemoteStore> |
storeMaps |
protected ServerWSHandler |
WSHandler |
Constructor and Description |
---|
StoreCallBack() |
StoreCallBack(List<TupleThree<String,String,Integer>> storeList) |
StoreCallBack(List<TupleThree<String,String,Integer>> storeList,
Serializer serializer) |
StoreCallBack(List<TupleThree<String,String,Integer>> storeList,
Serializer serializer,
boolean delay) |
StoreCallBack(RemoteConfig remoteConfig) |
Modifier and Type | Method and Description |
---|---|
boolean |
addStore(RemoteStore remoteStore) |
boolean |
addStore(String storeName,
String path,
int mode) |
protected void |
checkValue(StoreParas paras) |
Serializer |
getEmbeddedSerializer() |
RemoteStore |
getRemoteStore(String store) |
Serializer |
getSerializer() |
ConcurrentMap<String,RemoteStore> |
getStoreMaps() |
ServerWSHandler |
getWSHandler() |
protected List<voldemort.store.cachestore.voldeimpl.KeyValue> |
processFullQuery(QueryIterator queryIterator,
String queryStr,
RemoteStore store) |
protected voldemort.store.cachestore.Value |
processGet(RemoteStore store,
voldemort.store.cachestore.Key key) |
protected voldemort.store.cachestore.Value |
processGetNoBlock(RemoteStore store,
StoreParas paras) |
protected voldemort.store.cachestore.Value |
processGetNoBlockInt(RemoteStore store,
StoreParas paras) |
protected voldemort.store.cachestore.Value |
processGetSeqNo(RemoteStore store,
voldemort.store.cachestore.Key key) |
protected voldemort.store.cachestore.Value |
processGetSeqNoInt(RemoteStore store,
voldemort.store.cachestore.Key key) |
protected void |
processInsert(RemoteStore store,
voldemort.store.cachestore.Key key,
voldemort.store.cachestore.Value value) |
protected Response |
processKeyIterator(Request request) |
protected void |
processParas(StoreParas paras,
RemoteStore store) |
protected void |
processPut(RemoteStore store,
voldemort.store.cachestore.Key key,
voldemort.store.cachestore.Value value) |
protected Response |
processQueryPut(KeyValueParas keyValueParas,
RemoteStore store)
will deprecate MultiSelectQuery.
|
protected KeyValueParas |
processQueryStr(RemoteStore store,
List<voldemort.store.cachestore.voldeimpl.KeyValue> list,
String queryStr) |
protected KeyValueParas |
processQueryStr(RemoteStore store,
List<voldemort.store.cachestore.voldeimpl.KeyValue> list,
String queryStr,
OpType opType) |
protected boolean |
processRemove(RemoteStore store,
voldemort.store.cachestore.Key key) |
Response |
processRequest(Request request) |
protected Response |
processScan(Request request) |
protected voldemort.store.cachestore.Value |
processSelectQuery(RemoteStore store,
voldemort.store.cachestore.Key key,
voldemort.store.cachestore.Value value) |
protected StoreParas |
processStoreParas(Request request) |
protected void |
processUpdateQuery(RemoteStore store,
voldemort.store.cachestore.Key key,
voldemort.store.cachestore.Value value) |
protected void |
serializerResponse(Header header,
Response response)
check type of header SerializableType
|
void |
setWSHandler(ServerWSHandler serverWSHandler)
provide an way to overwrite ServerWSHandler to
handle dynamic class loader
|
protected static final org.apache.commons.logging.Log logger
protected Serializer serializer
protected ConcurrentMap<String,RemoteStore> storeMaps
protected Service.State serverState
protected List<TupleThree<String,String,Integer>> storeList
protected ServerWSHandler WSHandler
protected boolean delay
protected Serializer embeddedSerializer
protected com.fasterxml.jackson.databind.ObjectMapper mapper
public static final int MAX_SIZE
public StoreCallBack()
public StoreCallBack(List<TupleThree<String,String,Integer>> storeList)
storeList
- : list public StoreCallBack(List<TupleThree<String,String,Integer>> storeList, Serializer serializer)
public StoreCallBack(RemoteConfig remoteConfig)
public StoreCallBack(List<TupleThree<String,String,Integer>> storeList, Serializer serializer, boolean delay)
storeList
- serializer
- delay
- public ConcurrentMap<String,RemoteStore> getStoreMaps()
public RemoteStore getRemoteStore(String store)
public void setWSHandler(ServerWSHandler serverWSHandler)
public ServerWSHandler getWSHandler()
public Serializer getSerializer()
public Serializer getEmbeddedSerializer()
public boolean addStore(RemoteStore remoteStore)
public Response processRequest(Request request)
processRequest
in interface TCPCallBack
protected void serializerResponse(Header header, Response response)
header
- response
- protected StoreParas processStoreParas(Request request)
protected void processParas(StoreParas paras, RemoteStore store)
protected void checkValue(StoreParas paras)
protected voldemort.store.cachestore.Value processGet(RemoteStore store, voldemort.store.cachestore.Key key)
protected void processInsert(RemoteStore store, voldemort.store.cachestore.Key key, voldemort.store.cachestore.Value value)
protected void processPut(RemoteStore store, voldemort.store.cachestore.Key key, voldemort.store.cachestore.Value value)
protected boolean processRemove(RemoteStore store, voldemort.store.cachestore.Key key)
protected voldemort.store.cachestore.Value processSelectQuery(RemoteStore store, voldemort.store.cachestore.Key key, voldemort.store.cachestore.Value value)
protected void processUpdateQuery(RemoteStore store, voldemort.store.cachestore.Key key, voldemort.store.cachestore.Value value)
protected voldemort.store.cachestore.Value processGetSeqNoInt(RemoteStore store, voldemort.store.cachestore.Key key)
protected voldemort.store.cachestore.Value processGetSeqNo(RemoteStore store, voldemort.store.cachestore.Key key)
protected voldemort.store.cachestore.Value processGetNoBlock(RemoteStore store, StoreParas paras)
protected voldemort.store.cachestore.Value processGetNoBlockInt(RemoteStore store, StoreParas paras)
protected List<voldemort.store.cachestore.voldeimpl.KeyValue> processFullQuery(QueryIterator queryIterator, String queryStr, RemoteStore store)
protected KeyValueParas processQueryStr(RemoteStore store, List<voldemort.store.cachestore.voldeimpl.KeyValue> list, String queryStr)
protected KeyValueParas processQueryStr(RemoteStore store, List<voldemort.store.cachestore.voldeimpl.KeyValue> list, String queryStr, OpType opType)
protected Response processQueryPut(KeyValueParas keyValueParas, RemoteStore store)
keyValueParas
- store
- Copyright © 2016. All rights reserved.