voldemort.client.protocol.pb
Class ProtoBuffClientRequestFormat

java.lang.Object
  voldemort.client.protocol.pb.ProtoBuffClientRequestFormat

All Implemented Interfaces:

RequestFormat

public class ProtoBuffClientRequestFormat
extends java.lang.Object
implements RequestFormat

The client side of the protocol buffers request format

Field Summary

voldemort.store.ErrorCodeMapper

mapper

Constructor Summary

ProtoBuffClientRequestFormat()

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<voldemort.utils.ByteArray,java.util.List<Versioned<byte[]>>>	readGetAllResponse(java.io.DataInputStream input)
java.util.List<Versioned<byte[]>>	readGetResponse(java.io.DataInputStream input)
java.util.List<Version>	readGetVersionResponse(java.io.DataInputStream stream)
void	readPutResponse(java.io.DataInputStream input)
void	throwException(VProto.Error error)
void	writeDeleteRequest(java.io.DataOutputStream output, java.lang.String storeName, voldemort.utils.ByteArray key, VectorClock version, voldemort.server.RequestRoutingType routingType)
void	writeGetAllRequest(java.io.DataOutputStream output, java.lang.String storeName, java.lang.Iterable<voldemort.utils.ByteArray> keys, java.util.Map<voldemort.utils.ByteArray,byte[]> transforms, voldemort.server.RequestRoutingType routingType)
void	writeGetRequest(java.io.DataOutputStream output, java.lang.String storeName, voldemort.utils.ByteArray key, byte[] transforms, voldemort.server.RequestRoutingType routingType)
void	writeGetVersionRequest(java.io.DataOutputStream output, java.lang.String storeName, voldemort.utils.ByteArray key, voldemort.server.RequestRoutingType routingType)
void	writePutRequest(java.io.DataOutputStream output, java.lang.String storeName, voldemort.utils.ByteArray key, byte[] value, byte[] transforms, VectorClock version, voldemort.server.RequestRoutingType routingType)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

mapper

public final voldemort.store.ErrorCodeMapper mapper

Constructor Detail

ProtoBuffClientRequestFormat

public ProtoBuffClientRequestFormat()

Method Detail

writeDeleteRequest

public void writeDeleteRequest(java.io.DataOutputStream output,
                               java.lang.String storeName,
                               voldemort.utils.ByteArray key,
                               VectorClock version,
                               voldemort.server.RequestRoutingType routingType)
                        throws java.io.IOException

Specified by:

writeDeleteRequest in interface RequestFormat

Throws:

java.io.IOException

isCompleteDeleteResponse

public boolean isCompleteDeleteResponse(java.nio.ByteBuffer buffer)

Specified by:

isCompleteDeleteResponse in interface RequestFormat

readDeleteResponse

public boolean readDeleteResponse(java.io.DataInputStream input)
                           throws java.io.IOException

Specified by:

readDeleteResponse in interface RequestFormat

Throws:

java.io.IOException

writeGetRequest

public void writeGetRequest(java.io.DataOutputStream output,
                            java.lang.String storeName,
                            voldemort.utils.ByteArray key,
                            byte[] transforms,
                            voldemort.server.RequestRoutingType routingType)
                     throws java.io.IOException

Specified by:

writeGetRequest in interface RequestFormat

Throws:

java.io.IOException

isCompleteGetResponse

public boolean isCompleteGetResponse(java.nio.ByteBuffer buffer)

Specified by:

isCompleteGetResponse in interface RequestFormat

readGetResponse

public java.util.List<Versioned<byte[]>> readGetResponse(java.io.DataInputStream input)
                                                  throws java.io.IOException

Specified by:

readGetResponse in interface RequestFormat

Throws:

java.io.IOException

writeGetAllRequest

public void writeGetAllRequest(java.io.DataOutputStream output,
                               java.lang.String storeName,
                               java.lang.Iterable<voldemort.utils.ByteArray> keys,
                               java.util.Map<voldemort.utils.ByteArray,byte[]> transforms,
                               voldemort.server.RequestRoutingType routingType)
                        throws java.io.IOException

Specified by:

writeGetAllRequest in interface RequestFormat

Throws:

java.io.IOException

isCompleteGetAllResponse

public boolean isCompleteGetAllResponse(java.nio.ByteBuffer buffer)

Specified by:

isCompleteGetAllResponse in interface RequestFormat

readGetAllResponse

public java.util.Map<voldemort.utils.ByteArray,java.util.List<Versioned<byte[]>>> readGetAllResponse(java.io.DataInputStream input)
                                                                                              throws java.io.IOException

Specified by:

readGetAllResponse in interface RequestFormat

Throws:

java.io.IOException

writePutRequest

public void writePutRequest(java.io.DataOutputStream output,
                            java.lang.String storeName,
                            voldemort.utils.ByteArray key,
                            byte[] value,
                            byte[] transforms,
                            VectorClock version,
                            voldemort.server.RequestRoutingType routingType)
                     throws java.io.IOException

Specified by:

writePutRequest in interface RequestFormat

Throws:

java.io.IOException

isCompletePutResponse

public boolean isCompletePutResponse(java.nio.ByteBuffer buffer)

Specified by:

isCompletePutResponse in interface RequestFormat

readPutResponse

public void readPutResponse(java.io.DataInputStream input)
                     throws java.io.IOException

Specified by:

readPutResponse in interface RequestFormat

Throws:

java.io.IOException

throwException

public void throwException(VProto.Error error)

isCompleteGetVersionResponse

public boolean isCompleteGetVersionResponse(java.nio.ByteBuffer buffer)

Specified by:

isCompleteGetVersionResponse in interface RequestFormat

readGetVersionResponse

public java.util.List<Version> readGetVersionResponse(java.io.DataInputStream stream)
                                               throws java.io.IOException

Specified by:

readGetVersionResponse in interface RequestFormat

Throws:

java.io.IOException

writeGetVersionRequest

public void writeGetVersionRequest(java.io.DataOutputStream output,
                                   java.lang.String storeName,
                                   voldemort.utils.ByteArray key,
                                   voldemort.server.RequestRoutingType routingType)
                            throws java.io.IOException

Specified by:

writeGetVersionRequest in interface RequestFormat

Throws:

java.io.IOException