voldemort.client.protocol
Interface RequestFormat
- All Known Implementing Classes:
- ProtoBuffClientRequestFormat, VoldemortNativeClientRequestFormat
public interface RequestFormat
Abstracts the serialization mechanism used to write a client request. The
companion class on the server side is
RequestHandler
Method Summary |
boolean |
isCompleteDeleteResponse(java.nio.ByteBuffer buffer)
|
boolean |
isCompleteGetAllResponse(java.nio.ByteBuffer buffer)
|
boolean |
isCompleteGetResponse(java.nio.ByteBuffer buffer)
|
boolean |
isCompleteGetVersionResponse(java.nio.ByteBuffer buffer)
|
boolean |
isCompletePutResponse(java.nio.ByteBuffer buffer)
|
boolean |
readDeleteResponse(java.io.DataInputStream input)
|
java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>> |
readGetAllResponse(java.io.DataInputStream stream)
|
java.util.List<Versioned<byte[]>> |
readGetResponse(java.io.DataInputStream stream)
|
java.util.List<Version> |
readGetVersionResponse(java.io.DataInputStream stream)
|
void |
readPutResponse(java.io.DataInputStream stream)
|
void |
writeDeleteRequest(java.io.DataOutputStream output,
java.lang.String storeName,
ByteArray key,
VectorClock version,
RequestRoutingType routingType)
|
void |
writeGetAllRequest(java.io.DataOutputStream output,
java.lang.String storeName,
java.lang.Iterable<ByteArray> key,
java.util.Map<ByteArray,byte[]> transforms,
RequestRoutingType routingType)
|
void |
writeGetRequest(java.io.DataOutputStream output,
java.lang.String storeName,
ByteArray key,
byte[] transforms,
RequestRoutingType routingType)
|
void |
writeGetVersionRequest(java.io.DataOutputStream output,
java.lang.String storeName,
ByteArray key,
RequestRoutingType routingType)
|
void |
writePutRequest(java.io.DataOutputStream output,
java.lang.String storeName,
ByteArray key,
byte[] value,
byte[] transforms,
VectorClock version,
RequestRoutingType routingType)
|
writeGetRequest
void writeGetRequest(java.io.DataOutputStream output,
java.lang.String storeName,
ByteArray key,
byte[] transforms,
RequestRoutingType routingType)
throws java.io.IOException
- Throws:
java.io.IOException
isCompleteGetResponse
boolean isCompleteGetResponse(java.nio.ByteBuffer buffer)
readGetResponse
java.util.List<Versioned<byte[]>> readGetResponse(java.io.DataInputStream stream)
throws java.io.IOException
- Throws:
java.io.IOException
writeGetVersionRequest
void writeGetVersionRequest(java.io.DataOutputStream output,
java.lang.String storeName,
ByteArray key,
RequestRoutingType routingType)
throws java.io.IOException
- Throws:
java.io.IOException
isCompleteGetVersionResponse
boolean isCompleteGetVersionResponse(java.nio.ByteBuffer buffer)
readGetVersionResponse
java.util.List<Version> readGetVersionResponse(java.io.DataInputStream stream)
throws java.io.IOException
- Throws:
java.io.IOException
writeGetAllRequest
void writeGetAllRequest(java.io.DataOutputStream output,
java.lang.String storeName,
java.lang.Iterable<ByteArray> key,
java.util.Map<ByteArray,byte[]> transforms,
RequestRoutingType routingType)
throws java.io.IOException
- Throws:
java.io.IOException
isCompleteGetAllResponse
boolean isCompleteGetAllResponse(java.nio.ByteBuffer buffer)
readGetAllResponse
java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>> readGetAllResponse(java.io.DataInputStream stream)
throws java.io.IOException
- Throws:
java.io.IOException
writePutRequest
void writePutRequest(java.io.DataOutputStream output,
java.lang.String storeName,
ByteArray key,
byte[] value,
byte[] transforms,
VectorClock version,
RequestRoutingType routingType)
throws java.io.IOException
- Throws:
java.io.IOException
isCompletePutResponse
boolean isCompletePutResponse(java.nio.ByteBuffer buffer)
readPutResponse
void readPutResponse(java.io.DataInputStream stream)
throws java.io.IOException
- Throws:
java.io.IOException
writeDeleteRequest
void writeDeleteRequest(java.io.DataOutputStream output,
java.lang.String storeName,
ByteArray key,
VectorClock version,
RequestRoutingType routingType)
throws java.io.IOException
- Throws:
java.io.IOException
isCompleteDeleteResponse
boolean isCompleteDeleteResponse(java.nio.ByteBuffer buffer)
readDeleteResponse
boolean readDeleteResponse(java.io.DataInputStream input)
throws java.io.IOException
- Throws:
java.io.IOException
Jay Kreps, Roshan Sumbaly, Alex Feinberg, Bhupesh Bansal, Lei Gao, Chinmay Soman, Vinoth Chandar, Zhongjie Wu