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)

Method Detail

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