|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use NonblockingStoreCallback | |
---|---|
voldemort.store.nonblockingstore | Non-blocking store which deals with async requests. |
voldemort.store.socket | A store implementation that works remotely over a tcp/ip socket interacting with a SocketServer on the the other side. |
voldemort.store.socket.clientrequest | More classes related to how to parse client requests |
Uses of NonblockingStoreCallback in voldemort.store.nonblockingstore |
---|
Methods in voldemort.store.nonblockingstore with parameters of type NonblockingStoreCallback | |
---|---|
void |
NonblockingStoreRequest.submit(Node node,
NonblockingStore store,
NonblockingStoreCallback callback)
Submits the request to the given NonblockingStore . |
void |
ThreadPoolBasedNonblockingStoreImpl.submitDeleteRequest(ByteArray key,
Version version,
NonblockingStoreCallback callback,
long timeoutMs)
|
void |
NonblockingStore.submitDeleteRequest(ByteArray key,
Version version,
NonblockingStoreCallback callback,
long timeoutMs)
|
void |
ThreadPoolBasedNonblockingStoreImpl.submitGetAllRequest(java.lang.Iterable<ByteArray> keys,
java.util.Map<ByteArray,byte[]> transforms,
NonblockingStoreCallback callback,
long timeoutMs)
|
void |
NonblockingStore.submitGetAllRequest(java.lang.Iterable<ByteArray> keys,
java.util.Map<ByteArray,byte[]> transforms,
NonblockingStoreCallback callback,
long timeoutMs)
|
void |
ThreadPoolBasedNonblockingStoreImpl.submitGetRequest(ByteArray key,
byte[] transforms,
NonblockingStoreCallback callback,
long timeoutMs)
|
void |
NonblockingStore.submitGetRequest(ByteArray key,
byte[] transforms,
NonblockingStoreCallback callback,
long timeoutMs)
|
void |
ThreadPoolBasedNonblockingStoreImpl.submitGetVersionsRequest(ByteArray key,
NonblockingStoreCallback callback,
long timeoutMs)
|
void |
NonblockingStore.submitGetVersionsRequest(ByteArray key,
NonblockingStoreCallback callback,
long timeoutMs)
|
void |
ThreadPoolBasedNonblockingStoreImpl.submitPutRequest(ByteArray key,
Versioned<byte[]> value,
byte[] transforms,
NonblockingStoreCallback callback,
long timeoutMs)
|
void |
NonblockingStore.submitPutRequest(ByteArray key,
Versioned<byte[]> value,
byte[] transforms,
NonblockingStoreCallback callback,
long timeoutMs)
|
Uses of NonblockingStoreCallback in voldemort.store.socket |
---|
Methods in voldemort.store.socket with parameters of type NonblockingStoreCallback | |
---|---|
void |
SocketStore.submitDeleteRequest(ByteArray key,
Version version,
NonblockingStoreCallback callback,
long timeoutMs)
|
void |
SocketStore.submitGetAllRequest(java.lang.Iterable<ByteArray> keys,
java.util.Map<ByteArray,byte[]> transforms,
NonblockingStoreCallback callback,
long timeoutMs)
|
void |
SocketStore.submitGetRequest(ByteArray key,
byte[] transforms,
NonblockingStoreCallback callback,
long timeoutMs)
|
void |
SocketStore.submitGetVersionsRequest(ByteArray key,
NonblockingStoreCallback callback,
long timeoutMs)
|
void |
SocketStore.submitPutRequest(ByteArray key,
Versioned<byte[]> value,
byte[] transforms,
NonblockingStoreCallback callback,
long timeoutMs)
|
Uses of NonblockingStoreCallback in voldemort.store.socket.clientrequest |
---|
Methods in voldemort.store.socket.clientrequest with parameters of type NonblockingStoreCallback | ||
---|---|---|
|
ClientRequestExecutorPool.submitAsync(SocketDestination destination,
ClientRequest<T> delegate,
NonblockingStoreCallback callback,
long timeoutMs,
java.lang.String operationName)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |