Commits

Sean Cribbs  committed adcdda6

Add Java PBC stuff.

  • Participants
  • Parent commits db592f6

Comments (0)

Files changed (4)

File riak-client/ext/jruby/com/basho/riak/Riakclient.java

+// Generated by the protocol buffer compiler.  DO NOT EDIT!
+// source: riakclient.proto
+
+package com.basho.riak;
+
+public final class Riakclient {
+  private Riakclient() {}
+  public static void registerAllExtensions(
+      com.google.protobuf.ExtensionRegistry registry) {
+  }
+  public static final class RpbErrorResp extends
+      com.google.protobuf.GeneratedMessage {
+    // Use RpbErrorResp.newBuilder() to construct.
+    private RpbErrorResp() {
+      initFields();
+    }
+    private RpbErrorResp(boolean noInit) {}
+    
+    private static final RpbErrorResp defaultInstance;
+    public static RpbErrorResp getDefaultInstance() {
+      return defaultInstance;
+    }
+    
+    public RpbErrorResp getDefaultInstanceForType() {
+      return defaultInstance;
+    }
+    
+    public static final com.google.protobuf.Descriptors.Descriptor
+        getDescriptor() {
+      return com.basho.riak.Riakclient.internal_static_com_basho_riak_RpbErrorResp_descriptor;
+    }
+    
+    protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+        internalGetFieldAccessorTable() {
+      return com.basho.riak.Riakclient.internal_static_com_basho_riak_RpbErrorResp_fieldAccessorTable;
+    }
+    
+    // required bytes errmsg = 1;
+    public static final int ERRMSG_FIELD_NUMBER = 1;
+    private boolean hasErrmsg;
+    private com.google.protobuf.ByteString errmsg_ = com.google.protobuf.ByteString.EMPTY;
+    public boolean hasErrmsg() { return hasErrmsg; }
+    public com.google.protobuf.ByteString getErrmsg() { return errmsg_; }
+    
+    // required uint32 errcode = 2;
+    public static final int ERRCODE_FIELD_NUMBER = 2;
+    private boolean hasErrcode;
+    private int errcode_ = 0;
+    public boolean hasErrcode() { return hasErrcode; }
+    public int getErrcode() { return errcode_; }
+    
+    private void initFields() {
+    }
+    public final boolean isInitialized() {
+      if (!hasErrmsg) return false;
+      if (!hasErrcode) return false;
+      return true;
+    }
+    
+    public void writeTo(com.google.protobuf.CodedOutputStream output)
+                        throws java.io.IOException {
+      getSerializedSize();
+      if (hasErrmsg()) {
+        output.writeBytes(1, getErrmsg());
+      }
+      if (hasErrcode()) {
+        output.writeUInt32(2, getErrcode());
+      }
+      getUnknownFields().writeTo(output);
+    }
+    
+    private int memoizedSerializedSize = -1;
+    public int getSerializedSize() {
+      int size = memoizedSerializedSize;
+      if (size != -1) return size;
+    
+      size = 0;
+      if (hasErrmsg()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeBytesSize(1, getErrmsg());
+      }
+      if (hasErrcode()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeUInt32Size(2, getErrcode());
+      }
+      size += getUnknownFields().getSerializedSize();
+      memoizedSerializedSize = size;
+      return size;
+    }
+    
+    public static com.basho.riak.Riakclient.RpbErrorResp parseFrom(
+        com.google.protobuf.ByteString data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data).buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbErrorResp parseFrom(
+        com.google.protobuf.ByteString data,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data, extensionRegistry)
+               .buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbErrorResp parseFrom(byte[] data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data).buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbErrorResp parseFrom(
+        byte[] data,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data, extensionRegistry)
+               .buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbErrorResp parseFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input).buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbErrorResp parseFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input, extensionRegistry)
+               .buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbErrorResp parseDelimitedFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      Builder builder = newBuilder();
+      if (builder.mergeDelimitedFrom(input)) {
+        return builder.buildParsed();
+      } else {
+        return null;
+      }
+    }
+    public static com.basho.riak.Riakclient.RpbErrorResp parseDelimitedFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      Builder builder = newBuilder();
+      if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
+        return builder.buildParsed();
+      } else {
+        return null;
+      }
+    }
+    public static com.basho.riak.Riakclient.RpbErrorResp parseFrom(
+        com.google.protobuf.CodedInputStream input)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input).buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbErrorResp parseFrom(
+        com.google.protobuf.CodedInputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input, extensionRegistry)
+               .buildParsed();
+    }
+    
+    public static Builder newBuilder() { return Builder.create(); }
+    public Builder newBuilderForType() { return newBuilder(); }
+    public static Builder newBuilder(com.basho.riak.Riakclient.RpbErrorResp prototype) {
+      return newBuilder().mergeFrom(prototype);
+    }
+    public Builder toBuilder() { return newBuilder(this); }
+    
+    public static final class Builder extends
+        com.google.protobuf.GeneratedMessage.Builder<Builder> {
+      private com.basho.riak.Riakclient.RpbErrorResp result;
+      
+      // Construct using com.basho.riak.Riakclient.RpbErrorResp.newBuilder()
+      private Builder() {}
+      
+      private static Builder create() {
+        Builder builder = new Builder();
+        builder.result = new com.basho.riak.Riakclient.RpbErrorResp();
+        return builder;
+      }
+      
+      protected com.basho.riak.Riakclient.RpbErrorResp internalGetResult() {
+        return result;
+      }
+      
+      public Builder clear() {
+        if (result == null) {
+          throw new IllegalStateException(
+            "Cannot call clear() after build().");
+        }
+        result = new com.basho.riak.Riakclient.RpbErrorResp();
+        return this;
+      }
+      
+      public Builder clone() {
+        return create().mergeFrom(result);
+      }
+      
+      public com.google.protobuf.Descriptors.Descriptor
+          getDescriptorForType() {
+        return com.basho.riak.Riakclient.RpbErrorResp.getDescriptor();
+      }
+      
+      public com.basho.riak.Riakclient.RpbErrorResp getDefaultInstanceForType() {
+        return com.basho.riak.Riakclient.RpbErrorResp.getDefaultInstance();
+      }
+      
+      public boolean isInitialized() {
+        return result.isInitialized();
+      }
+      public com.basho.riak.Riakclient.RpbErrorResp build() {
+        if (result != null && !isInitialized()) {
+          throw newUninitializedMessageException(result);
+        }
+        return buildPartial();
+      }
+      
+      private com.basho.riak.Riakclient.RpbErrorResp buildParsed()
+          throws com.google.protobuf.InvalidProtocolBufferException {
+        if (!isInitialized()) {
+          throw newUninitializedMessageException(
+            result).asInvalidProtocolBufferException();
+        }
+        return buildPartial();
+      }
+      
+      public com.basho.riak.Riakclient.RpbErrorResp buildPartial() {
+        if (result == null) {
+          throw new IllegalStateException(
+            "build() has already been called on this Builder.");
+        }
+        com.basho.riak.Riakclient.RpbErrorResp returnMe = result;
+        result = null;
+        return returnMe;
+      }
+      
+      public Builder mergeFrom(com.google.protobuf.Message other) {
+        if (other instanceof com.basho.riak.Riakclient.RpbErrorResp) {
+          return mergeFrom((com.basho.riak.Riakclient.RpbErrorResp)other);
+        } else {
+          super.mergeFrom(other);
+          return this;
+        }
+      }
+      
+      public Builder mergeFrom(com.basho.riak.Riakclient.RpbErrorResp other) {
+        if (other == com.basho.riak.Riakclient.RpbErrorResp.getDefaultInstance()) return this;
+        if (other.hasErrmsg()) {
+          setErrmsg(other.getErrmsg());
+        }
+        if (other.hasErrcode()) {
+          setErrcode(other.getErrcode());
+        }
+        this.mergeUnknownFields(other.getUnknownFields());
+        return this;
+      }
+      
+      public Builder mergeFrom(
+          com.google.protobuf.CodedInputStream input,
+          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+          throws java.io.IOException {
+        com.google.protobuf.UnknownFieldSet.Builder unknownFields =
+          com.google.protobuf.UnknownFieldSet.newBuilder(
+            this.getUnknownFields());
+        while (true) {
+          int tag = input.readTag();
+          switch (tag) {
+            case 0:
+              this.setUnknownFields(unknownFields.build());
+              return this;
+            default: {
+              if (!parseUnknownField(input, unknownFields,
+                                     extensionRegistry, tag)) {
+                this.setUnknownFields(unknownFields.build());
+                return this;
+              }
+              break;
+            }
+            case 10: {
+              setErrmsg(input.readBytes());
+              break;
+            }
+            case 16: {
+              setErrcode(input.readUInt32());
+              break;
+            }
+          }
+        }
+      }
+      
+      
+      // required bytes errmsg = 1;
+      public boolean hasErrmsg() {
+        return result.hasErrmsg();
+      }
+      public com.google.protobuf.ByteString getErrmsg() {
+        return result.getErrmsg();
+      }
+      public Builder setErrmsg(com.google.protobuf.ByteString value) {
+        if (value == null) {
+    throw new NullPointerException();
+  }
+  result.hasErrmsg = true;
+        result.errmsg_ = value;
+        return this;
+      }
+      public Builder clearErrmsg() {
+        result.hasErrmsg = false;
+        result.errmsg_ = getDefaultInstance().getErrmsg();
+        return this;
+      }
+      
+      // required uint32 errcode = 2;
+      public boolean hasErrcode() {
+        return result.hasErrcode();
+      }
+      public int getErrcode() {
+        return result.getErrcode();
+      }
+      public Builder setErrcode(int value) {
+        result.hasErrcode = true;
+        result.errcode_ = value;
+        return this;
+      }
+      public Builder clearErrcode() {
+        result.hasErrcode = false;
+        result.errcode_ = 0;
+        return this;
+      }
+      
+      // @@protoc_insertion_point(builder_scope:com.basho.riak.RpbErrorResp)
+    }
+    
+    static {
+      defaultInstance = new RpbErrorResp(true);
+      com.basho.riak.Riakclient.internalForceInit();
+      defaultInstance.initFields();
+    }
+    
+    // @@protoc_insertion_point(class_scope:com.basho.riak.RpbErrorResp)
+  }
+  
+  public static final class RpbGetClientIdResp extends
+      com.google.protobuf.GeneratedMessage {
+    // Use RpbGetClientIdResp.newBuilder() to construct.
+    private RpbGetClientIdResp() {
+      initFields();
+    }
+    private RpbGetClientIdResp(boolean noInit) {}
+    
+    private static final RpbGetClientIdResp defaultInstance;
+    public static RpbGetClientIdResp getDefaultInstance() {
+      return defaultInstance;
+    }
+    
+    public RpbGetClientIdResp getDefaultInstanceForType() {
+      return defaultInstance;
+    }
+    
+    public static final com.google.protobuf.Descriptors.Descriptor
+        getDescriptor() {
+      return com.basho.riak.Riakclient.internal_static_com_basho_riak_RpbGetClientIdResp_descriptor;
+    }
+    
+    protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+        internalGetFieldAccessorTable() {
+      return com.basho.riak.Riakclient.internal_static_com_basho_riak_RpbGetClientIdResp_fieldAccessorTable;
+    }
+    
+    // required bytes client_id = 1;
+    public static final int CLIENT_ID_FIELD_NUMBER = 1;
+    private boolean hasClientId;
+    private com.google.protobuf.ByteString clientId_ = com.google.protobuf.ByteString.EMPTY;
+    public boolean hasClientId() { return hasClientId; }
+    public com.google.protobuf.ByteString getClientId() { return clientId_; }
+    
+    private void initFields() {
+    }
+    public final boolean isInitialized() {
+      if (!hasClientId) return false;
+      return true;
+    }
+    
+    public void writeTo(com.google.protobuf.CodedOutputStream output)
+                        throws java.io.IOException {
+      getSerializedSize();
+      if (hasClientId()) {
+        output.writeBytes(1, getClientId());
+      }
+      getUnknownFields().writeTo(output);
+    }
+    
+    private int memoizedSerializedSize = -1;
+    public int getSerializedSize() {
+      int size = memoizedSerializedSize;
+      if (size != -1) return size;
+    
+      size = 0;
+      if (hasClientId()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeBytesSize(1, getClientId());
+      }
+      size += getUnknownFields().getSerializedSize();
+      memoizedSerializedSize = size;
+      return size;
+    }
+    
+    public static com.basho.riak.Riakclient.RpbGetClientIdResp parseFrom(
+        com.google.protobuf.ByteString data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data).buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetClientIdResp parseFrom(
+        com.google.protobuf.ByteString data,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data, extensionRegistry)
+               .buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetClientIdResp parseFrom(byte[] data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data).buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetClientIdResp parseFrom(
+        byte[] data,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data, extensionRegistry)
+               .buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetClientIdResp parseFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input).buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetClientIdResp parseFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input, extensionRegistry)
+               .buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetClientIdResp parseDelimitedFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      Builder builder = newBuilder();
+      if (builder.mergeDelimitedFrom(input)) {
+        return builder.buildParsed();
+      } else {
+        return null;
+      }
+    }
+    public static com.basho.riak.Riakclient.RpbGetClientIdResp parseDelimitedFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      Builder builder = newBuilder();
+      if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
+        return builder.buildParsed();
+      } else {
+        return null;
+      }
+    }
+    public static com.basho.riak.Riakclient.RpbGetClientIdResp parseFrom(
+        com.google.protobuf.CodedInputStream input)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input).buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetClientIdResp parseFrom(
+        com.google.protobuf.CodedInputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input, extensionRegistry)
+               .buildParsed();
+    }
+    
+    public static Builder newBuilder() { return Builder.create(); }
+    public Builder newBuilderForType() { return newBuilder(); }
+    public static Builder newBuilder(com.basho.riak.Riakclient.RpbGetClientIdResp prototype) {
+      return newBuilder().mergeFrom(prototype);
+    }
+    public Builder toBuilder() { return newBuilder(this); }
+    
+    public static final class Builder extends
+        com.google.protobuf.GeneratedMessage.Builder<Builder> {
+      private com.basho.riak.Riakclient.RpbGetClientIdResp result;
+      
+      // Construct using com.basho.riak.Riakclient.RpbGetClientIdResp.newBuilder()
+      private Builder() {}
+      
+      private static Builder create() {
+        Builder builder = new Builder();
+        builder.result = new com.basho.riak.Riakclient.RpbGetClientIdResp();
+        return builder;
+      }
+      
+      protected com.basho.riak.Riakclient.RpbGetClientIdResp internalGetResult() {
+        return result;
+      }
+      
+      public Builder clear() {
+        if (result == null) {
+          throw new IllegalStateException(
+            "Cannot call clear() after build().");
+        }
+        result = new com.basho.riak.Riakclient.RpbGetClientIdResp();
+        return this;
+      }
+      
+      public Builder clone() {
+        return create().mergeFrom(result);
+      }
+      
+      public com.google.protobuf.Descriptors.Descriptor
+          getDescriptorForType() {
+        return com.basho.riak.Riakclient.RpbGetClientIdResp.getDescriptor();
+      }
+      
+      public com.basho.riak.Riakclient.RpbGetClientIdResp getDefaultInstanceForType() {
+        return com.basho.riak.Riakclient.RpbGetClientIdResp.getDefaultInstance();
+      }
+      
+      public boolean isInitialized() {
+        return result.isInitialized();
+      }
+      public com.basho.riak.Riakclient.RpbGetClientIdResp build() {
+        if (result != null && !isInitialized()) {
+          throw newUninitializedMessageException(result);
+        }
+        return buildPartial();
+      }
+      
+      private com.basho.riak.Riakclient.RpbGetClientIdResp buildParsed()
+          throws com.google.protobuf.InvalidProtocolBufferException {
+        if (!isInitialized()) {
+          throw newUninitializedMessageException(
+            result).asInvalidProtocolBufferException();
+        }
+        return buildPartial();
+      }
+      
+      public com.basho.riak.Riakclient.RpbGetClientIdResp buildPartial() {
+        if (result == null) {
+          throw new IllegalStateException(
+            "build() has already been called on this Builder.");
+        }
+        com.basho.riak.Riakclient.RpbGetClientIdResp returnMe = result;
+        result = null;
+        return returnMe;
+      }
+      
+      public Builder mergeFrom(com.google.protobuf.Message other) {
+        if (other instanceof com.basho.riak.Riakclient.RpbGetClientIdResp) {
+          return mergeFrom((com.basho.riak.Riakclient.RpbGetClientIdResp)other);
+        } else {
+          super.mergeFrom(other);
+          return this;
+        }
+      }
+      
+      public Builder mergeFrom(com.basho.riak.Riakclient.RpbGetClientIdResp other) {
+        if (other == com.basho.riak.Riakclient.RpbGetClientIdResp.getDefaultInstance()) return this;
+        if (other.hasClientId()) {
+          setClientId(other.getClientId());
+        }
+        this.mergeUnknownFields(other.getUnknownFields());
+        return this;
+      }
+      
+      public Builder mergeFrom(
+          com.google.protobuf.CodedInputStream input,
+          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+          throws java.io.IOException {
+        com.google.protobuf.UnknownFieldSet.Builder unknownFields =
+          com.google.protobuf.UnknownFieldSet.newBuilder(
+            this.getUnknownFields());
+        while (true) {
+          int tag = input.readTag();
+          switch (tag) {
+            case 0:
+              this.setUnknownFields(unknownFields.build());
+              return this;
+            default: {
+              if (!parseUnknownField(input, unknownFields,
+                                     extensionRegistry, tag)) {
+                this.setUnknownFields(unknownFields.build());
+                return this;
+              }
+              break;
+            }
+            case 10: {
+              setClientId(input.readBytes());
+              break;
+            }
+          }
+        }
+      }
+      
+      
+      // required bytes client_id = 1;
+      public boolean hasClientId() {
+        return result.hasClientId();
+      }
+      public com.google.protobuf.ByteString getClientId() {
+        return result.getClientId();
+      }
+      public Builder setClientId(com.google.protobuf.ByteString value) {
+        if (value == null) {
+    throw new NullPointerException();
+  }
+  result.hasClientId = true;
+        result.clientId_ = value;
+        return this;
+      }
+      public Builder clearClientId() {
+        result.hasClientId = false;
+        result.clientId_ = getDefaultInstance().getClientId();
+        return this;
+      }
+      
+      // @@protoc_insertion_point(builder_scope:com.basho.riak.RpbGetClientIdResp)
+    }
+    
+    static {
+      defaultInstance = new RpbGetClientIdResp(true);
+      com.basho.riak.Riakclient.internalForceInit();
+      defaultInstance.initFields();
+    }
+    
+    // @@protoc_insertion_point(class_scope:com.basho.riak.RpbGetClientIdResp)
+  }
+  
+  public static final class RpbSetClientIdReq extends
+      com.google.protobuf.GeneratedMessage {
+    // Use RpbSetClientIdReq.newBuilder() to construct.
+    private RpbSetClientIdReq() {
+      initFields();
+    }
+    private RpbSetClientIdReq(boolean noInit) {}
+    
+    private static final RpbSetClientIdReq defaultInstance;
+    public static RpbSetClientIdReq getDefaultInstance() {
+      return defaultInstance;
+    }
+    
+    public RpbSetClientIdReq getDefaultInstanceForType() {
+      return defaultInstance;
+    }
+    
+    public static final com.google.protobuf.Descriptors.Descriptor
+        getDescriptor() {
+      return com.basho.riak.Riakclient.internal_static_com_basho_riak_RpbSetClientIdReq_descriptor;
+    }
+    
+    protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+        internalGetFieldAccessorTable() {
+      return com.basho.riak.Riakclient.internal_static_com_basho_riak_RpbSetClientIdReq_fieldAccessorTable;
+    }
+    
+    // required bytes client_id = 1;
+    public static final int CLIENT_ID_FIELD_NUMBER = 1;
+    private boolean hasClientId;
+    private com.google.protobuf.ByteString clientId_ = com.google.protobuf.ByteString.EMPTY;
+    public boolean hasClientId() { return hasClientId; }
+    public com.google.protobuf.ByteString getClientId() { return clientId_; }
+    
+    private void initFields() {
+    }
+    public final boolean isInitialized() {
+      if (!hasClientId) return false;
+      return true;
+    }
+    
+    public void writeTo(com.google.protobuf.CodedOutputStream output)
+                        throws java.io.IOException {
+      getSerializedSize();
+      if (hasClientId()) {
+        output.writeBytes(1, getClientId());
+      }
+      getUnknownFields().writeTo(output);
+    }
+    
+    private int memoizedSerializedSize = -1;
+    public int getSerializedSize() {
+      int size = memoizedSerializedSize;
+      if (size != -1) return size;
+    
+      size = 0;
+      if (hasClientId()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeBytesSize(1, getClientId());
+      }
+      size += getUnknownFields().getSerializedSize();
+      memoizedSerializedSize = size;
+      return size;
+    }
+    
+    public static com.basho.riak.Riakclient.RpbSetClientIdReq parseFrom(
+        com.google.protobuf.ByteString data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data).buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbSetClientIdReq parseFrom(
+        com.google.protobuf.ByteString data,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data, extensionRegistry)
+               .buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbSetClientIdReq parseFrom(byte[] data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data).buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbSetClientIdReq parseFrom(
+        byte[] data,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data, extensionRegistry)
+               .buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbSetClientIdReq parseFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input).buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbSetClientIdReq parseFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input, extensionRegistry)
+               .buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbSetClientIdReq parseDelimitedFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      Builder builder = newBuilder();
+      if (builder.mergeDelimitedFrom(input)) {
+        return builder.buildParsed();
+      } else {
+        return null;
+      }
+    }
+    public static com.basho.riak.Riakclient.RpbSetClientIdReq parseDelimitedFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      Builder builder = newBuilder();
+      if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
+        return builder.buildParsed();
+      } else {
+        return null;
+      }
+    }
+    public static com.basho.riak.Riakclient.RpbSetClientIdReq parseFrom(
+        com.google.protobuf.CodedInputStream input)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input).buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbSetClientIdReq parseFrom(
+        com.google.protobuf.CodedInputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input, extensionRegistry)
+               .buildParsed();
+    }
+    
+    public static Builder newBuilder() { return Builder.create(); }
+    public Builder newBuilderForType() { return newBuilder(); }
+    public static Builder newBuilder(com.basho.riak.Riakclient.RpbSetClientIdReq prototype) {
+      return newBuilder().mergeFrom(prototype);
+    }
+    public Builder toBuilder() { return newBuilder(this); }
+    
+    public static final class Builder extends
+        com.google.protobuf.GeneratedMessage.Builder<Builder> {
+      private com.basho.riak.Riakclient.RpbSetClientIdReq result;
+      
+      // Construct using com.basho.riak.Riakclient.RpbSetClientIdReq.newBuilder()
+      private Builder() {}
+      
+      private static Builder create() {
+        Builder builder = new Builder();
+        builder.result = new com.basho.riak.Riakclient.RpbSetClientIdReq();
+        return builder;
+      }
+      
+      protected com.basho.riak.Riakclient.RpbSetClientIdReq internalGetResult() {
+        return result;
+      }
+      
+      public Builder clear() {
+        if (result == null) {
+          throw new IllegalStateException(
+            "Cannot call clear() after build().");
+        }
+        result = new com.basho.riak.Riakclient.RpbSetClientIdReq();
+        return this;
+      }
+      
+      public Builder clone() {
+        return create().mergeFrom(result);
+      }
+      
+      public com.google.protobuf.Descriptors.Descriptor
+          getDescriptorForType() {
+        return com.basho.riak.Riakclient.RpbSetClientIdReq.getDescriptor();
+      }
+      
+      public com.basho.riak.Riakclient.RpbSetClientIdReq getDefaultInstanceForType() {
+        return com.basho.riak.Riakclient.RpbSetClientIdReq.getDefaultInstance();
+      }
+      
+      public boolean isInitialized() {
+        return result.isInitialized();
+      }
+      public com.basho.riak.Riakclient.RpbSetClientIdReq build() {
+        if (result != null && !isInitialized()) {
+          throw newUninitializedMessageException(result);
+        }
+        return buildPartial();
+      }
+      
+      private com.basho.riak.Riakclient.RpbSetClientIdReq buildParsed()
+          throws com.google.protobuf.InvalidProtocolBufferException {
+        if (!isInitialized()) {
+          throw newUninitializedMessageException(
+            result).asInvalidProtocolBufferException();
+        }
+        return buildPartial();
+      }
+      
+      public com.basho.riak.Riakclient.RpbSetClientIdReq buildPartial() {
+        if (result == null) {
+          throw new IllegalStateException(
+            "build() has already been called on this Builder.");
+        }
+        com.basho.riak.Riakclient.RpbSetClientIdReq returnMe = result;
+        result = null;
+        return returnMe;
+      }
+      
+      public Builder mergeFrom(com.google.protobuf.Message other) {
+        if (other instanceof com.basho.riak.Riakclient.RpbSetClientIdReq) {
+          return mergeFrom((com.basho.riak.Riakclient.RpbSetClientIdReq)other);
+        } else {
+          super.mergeFrom(other);
+          return this;
+        }
+      }
+      
+      public Builder mergeFrom(com.basho.riak.Riakclient.RpbSetClientIdReq other) {
+        if (other == com.basho.riak.Riakclient.RpbSetClientIdReq.getDefaultInstance()) return this;
+        if (other.hasClientId()) {
+          setClientId(other.getClientId());
+        }
+        this.mergeUnknownFields(other.getUnknownFields());
+        return this;
+      }
+      
+      public Builder mergeFrom(
+          com.google.protobuf.CodedInputStream input,
+          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+          throws java.io.IOException {
+        com.google.protobuf.UnknownFieldSet.Builder unknownFields =
+          com.google.protobuf.UnknownFieldSet.newBuilder(
+            this.getUnknownFields());
+        while (true) {
+          int tag = input.readTag();
+          switch (tag) {
+            case 0:
+              this.setUnknownFields(unknownFields.build());
+              return this;
+            default: {
+              if (!parseUnknownField(input, unknownFields,
+                                     extensionRegistry, tag)) {
+                this.setUnknownFields(unknownFields.build());
+                return this;
+              }
+              break;
+            }
+            case 10: {
+              setClientId(input.readBytes());
+              break;
+            }
+          }
+        }
+      }
+      
+      
+      // required bytes client_id = 1;
+      public boolean hasClientId() {
+        return result.hasClientId();
+      }
+      public com.google.protobuf.ByteString getClientId() {
+        return result.getClientId();
+      }
+      public Builder setClientId(com.google.protobuf.ByteString value) {
+        if (value == null) {
+    throw new NullPointerException();
+  }
+  result.hasClientId = true;
+        result.clientId_ = value;
+        return this;
+      }
+      public Builder clearClientId() {
+        result.hasClientId = false;
+        result.clientId_ = getDefaultInstance().getClientId();
+        return this;
+      }
+      
+      // @@protoc_insertion_point(builder_scope:com.basho.riak.RpbSetClientIdReq)
+    }
+    
+    static {
+      defaultInstance = new RpbSetClientIdReq(true);
+      com.basho.riak.Riakclient.internalForceInit();
+      defaultInstance.initFields();
+    }
+    
+    // @@protoc_insertion_point(class_scope:com.basho.riak.RpbSetClientIdReq)
+  }
+  
+  public static final class RpbGetServerInfoResp extends
+      com.google.protobuf.GeneratedMessage {
+    // Use RpbGetServerInfoResp.newBuilder() to construct.
+    private RpbGetServerInfoResp() {
+      initFields();
+    }
+    private RpbGetServerInfoResp(boolean noInit) {}
+    
+    private static final RpbGetServerInfoResp defaultInstance;
+    public static RpbGetServerInfoResp getDefaultInstance() {
+      return defaultInstance;
+    }
+    
+    public RpbGetServerInfoResp getDefaultInstanceForType() {
+      return defaultInstance;
+    }
+    
+    public static final com.google.protobuf.Descriptors.Descriptor
+        getDescriptor() {
+      return com.basho.riak.Riakclient.internal_static_com_basho_riak_RpbGetServerInfoResp_descriptor;
+    }
+    
+    protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+        internalGetFieldAccessorTable() {
+      return com.basho.riak.Riakclient.internal_static_com_basho_riak_RpbGetServerInfoResp_fieldAccessorTable;
+    }
+    
+    // optional bytes node = 1;
+    public static final int NODE_FIELD_NUMBER = 1;
+    private boolean hasNode;
+    private com.google.protobuf.ByteString node_ = com.google.protobuf.ByteString.EMPTY;
+    public boolean hasNode() { return hasNode; }
+    public com.google.protobuf.ByteString getNode() { return node_; }
+    
+    // optional bytes server_version = 2;
+    public static final int SERVER_VERSION_FIELD_NUMBER = 2;
+    private boolean hasServerVersion;
+    private com.google.protobuf.ByteString serverVersion_ = com.google.protobuf.ByteString.EMPTY;
+    public boolean hasServerVersion() { return hasServerVersion; }
+    public com.google.protobuf.ByteString getServerVersion() { return serverVersion_; }
+    
+    private void initFields() {
+    }
+    public final boolean isInitialized() {
+      return true;
+    }
+    
+    public void writeTo(com.google.protobuf.CodedOutputStream output)
+                        throws java.io.IOException {
+      getSerializedSize();
+      if (hasNode()) {
+        output.writeBytes(1, getNode());
+      }
+      if (hasServerVersion()) {
+        output.writeBytes(2, getServerVersion());
+      }
+      getUnknownFields().writeTo(output);
+    }
+    
+    private int memoizedSerializedSize = -1;
+    public int getSerializedSize() {
+      int size = memoizedSerializedSize;
+      if (size != -1) return size;
+    
+      size = 0;
+      if (hasNode()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeBytesSize(1, getNode());
+      }
+      if (hasServerVersion()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeBytesSize(2, getServerVersion());
+      }
+      size += getUnknownFields().getSerializedSize();
+      memoizedSerializedSize = size;
+      return size;
+    }
+    
+    public static com.basho.riak.Riakclient.RpbGetServerInfoResp parseFrom(
+        com.google.protobuf.ByteString data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data).buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetServerInfoResp parseFrom(
+        com.google.protobuf.ByteString data,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data, extensionRegistry)
+               .buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetServerInfoResp parseFrom(byte[] data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data).buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetServerInfoResp parseFrom(
+        byte[] data,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data, extensionRegistry)
+               .buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetServerInfoResp parseFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input).buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetServerInfoResp parseFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input, extensionRegistry)
+               .buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetServerInfoResp parseDelimitedFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      Builder builder = newBuilder();
+      if (builder.mergeDelimitedFrom(input)) {
+        return builder.buildParsed();
+      } else {
+        return null;
+      }
+    }
+    public static com.basho.riak.Riakclient.RpbGetServerInfoResp parseDelimitedFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      Builder builder = newBuilder();
+      if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
+        return builder.buildParsed();
+      } else {
+        return null;
+      }
+    }
+    public static com.basho.riak.Riakclient.RpbGetServerInfoResp parseFrom(
+        com.google.protobuf.CodedInputStream input)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input).buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetServerInfoResp parseFrom(
+        com.google.protobuf.CodedInputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input, extensionRegistry)
+               .buildParsed();
+    }
+    
+    public static Builder newBuilder() { return Builder.create(); }
+    public Builder newBuilderForType() { return newBuilder(); }
+    public static Builder newBuilder(com.basho.riak.Riakclient.RpbGetServerInfoResp prototype) {
+      return newBuilder().mergeFrom(prototype);
+    }
+    public Builder toBuilder() { return newBuilder(this); }
+    
+    public static final class Builder extends
+        com.google.protobuf.GeneratedMessage.Builder<Builder> {
+      private com.basho.riak.Riakclient.RpbGetServerInfoResp result;
+      
+      // Construct using com.basho.riak.Riakclient.RpbGetServerInfoResp.newBuilder()
+      private Builder() {}
+      
+      private static Builder create() {
+        Builder builder = new Builder();
+        builder.result = new com.basho.riak.Riakclient.RpbGetServerInfoResp();
+        return builder;
+      }
+      
+      protected com.basho.riak.Riakclient.RpbGetServerInfoResp internalGetResult() {
+        return result;
+      }
+      
+      public Builder clear() {
+        if (result == null) {
+          throw new IllegalStateException(
+            "Cannot call clear() after build().");
+        }
+        result = new com.basho.riak.Riakclient.RpbGetServerInfoResp();
+        return this;
+      }
+      
+      public Builder clone() {
+        return create().mergeFrom(result);
+      }
+      
+      public com.google.protobuf.Descriptors.Descriptor
+          getDescriptorForType() {
+        return com.basho.riak.Riakclient.RpbGetServerInfoResp.getDescriptor();
+      }
+      
+      public com.basho.riak.Riakclient.RpbGetServerInfoResp getDefaultInstanceForType() {
+        return com.basho.riak.Riakclient.RpbGetServerInfoResp.getDefaultInstance();
+      }
+      
+      public boolean isInitialized() {
+        return result.isInitialized();
+      }
+      public com.basho.riak.Riakclient.RpbGetServerInfoResp build() {
+        if (result != null && !isInitialized()) {
+          throw newUninitializedMessageException(result);
+        }
+        return buildPartial();
+      }
+      
+      private com.basho.riak.Riakclient.RpbGetServerInfoResp buildParsed()
+          throws com.google.protobuf.InvalidProtocolBufferException {
+        if (!isInitialized()) {
+          throw newUninitializedMessageException(
+            result).asInvalidProtocolBufferException();
+        }
+        return buildPartial();
+      }
+      
+      public com.basho.riak.Riakclient.RpbGetServerInfoResp buildPartial() {
+        if (result == null) {
+          throw new IllegalStateException(
+            "build() has already been called on this Builder.");
+        }
+        com.basho.riak.Riakclient.RpbGetServerInfoResp returnMe = result;
+        result = null;
+        return returnMe;
+      }
+      
+      public Builder mergeFrom(com.google.protobuf.Message other) {
+        if (other instanceof com.basho.riak.Riakclient.RpbGetServerInfoResp) {
+          return mergeFrom((com.basho.riak.Riakclient.RpbGetServerInfoResp)other);
+        } else {
+          super.mergeFrom(other);
+          return this;
+        }
+      }
+      
+      public Builder mergeFrom(com.basho.riak.Riakclient.RpbGetServerInfoResp other) {
+        if (other == com.basho.riak.Riakclient.RpbGetServerInfoResp.getDefaultInstance()) return this;
+        if (other.hasNode()) {
+          setNode(other.getNode());
+        }
+        if (other.hasServerVersion()) {
+          setServerVersion(other.getServerVersion());
+        }
+        this.mergeUnknownFields(other.getUnknownFields());
+        return this;
+      }
+      
+      public Builder mergeFrom(
+          com.google.protobuf.CodedInputStream input,
+          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+          throws java.io.IOException {
+        com.google.protobuf.UnknownFieldSet.Builder unknownFields =
+          com.google.protobuf.UnknownFieldSet.newBuilder(
+            this.getUnknownFields());
+        while (true) {
+          int tag = input.readTag();
+          switch (tag) {
+            case 0:
+              this.setUnknownFields(unknownFields.build());
+              return this;
+            default: {
+              if (!parseUnknownField(input, unknownFields,
+                                     extensionRegistry, tag)) {
+                this.setUnknownFields(unknownFields.build());
+                return this;
+              }
+              break;
+            }
+            case 10: {
+              setNode(input.readBytes());
+              break;
+            }
+            case 18: {
+              setServerVersion(input.readBytes());
+              break;
+            }
+          }
+        }
+      }
+      
+      
+      // optional bytes node = 1;
+      public boolean hasNode() {
+        return result.hasNode();
+      }
+      public com.google.protobuf.ByteString getNode() {
+        return result.getNode();
+      }
+      public Builder setNode(com.google.protobuf.ByteString value) {
+        if (value == null) {
+    throw new NullPointerException();
+  }
+  result.hasNode = true;
+        result.node_ = value;
+        return this;
+      }
+      public Builder clearNode() {
+        result.hasNode = false;
+        result.node_ = getDefaultInstance().getNode();
+        return this;
+      }
+      
+      // optional bytes server_version = 2;
+      public boolean hasServerVersion() {
+        return result.hasServerVersion();
+      }
+      public com.google.protobuf.ByteString getServerVersion() {
+        return result.getServerVersion();
+      }
+      public Builder setServerVersion(com.google.protobuf.ByteString value) {
+        if (value == null) {
+    throw new NullPointerException();
+  }
+  result.hasServerVersion = true;
+        result.serverVersion_ = value;
+        return this;
+      }
+      public Builder clearServerVersion() {
+        result.hasServerVersion = false;
+        result.serverVersion_ = getDefaultInstance().getServerVersion();
+        return this;
+      }
+      
+      // @@protoc_insertion_point(builder_scope:com.basho.riak.RpbGetServerInfoResp)
+    }
+    
+    static {
+      defaultInstance = new RpbGetServerInfoResp(true);
+      com.basho.riak.Riakclient.internalForceInit();
+      defaultInstance.initFields();
+    }
+    
+    // @@protoc_insertion_point(class_scope:com.basho.riak.RpbGetServerInfoResp)
+  }
+  
+  public static final class RpbGetReq extends
+      com.google.protobuf.GeneratedMessage {
+    // Use RpbGetReq.newBuilder() to construct.
+    private RpbGetReq() {
+      initFields();
+    }
+    private RpbGetReq(boolean noInit) {}
+    
+    private static final RpbGetReq defaultInstance;
+    public static RpbGetReq getDefaultInstance() {
+      return defaultInstance;
+    }
+    
+    public RpbGetReq getDefaultInstanceForType() {
+      return defaultInstance;
+    }
+    
+    public static final com.google.protobuf.Descriptors.Descriptor
+        getDescriptor() {
+      return com.basho.riak.Riakclient.internal_static_com_basho_riak_RpbGetReq_descriptor;
+    }
+    
+    protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+        internalGetFieldAccessorTable() {
+      return com.basho.riak.Riakclient.internal_static_com_basho_riak_RpbGetReq_fieldAccessorTable;
+    }
+    
+    // required bytes bucket = 1;
+    public static final int BUCKET_FIELD_NUMBER = 1;
+    private boolean hasBucket;
+    private com.google.protobuf.ByteString bucket_ = com.google.protobuf.ByteString.EMPTY;
+    public boolean hasBucket() { return hasBucket; }
+    public com.google.protobuf.ByteString getBucket() { return bucket_; }
+    
+    // required bytes key = 2;
+    public static final int KEY_FIELD_NUMBER = 2;
+    private boolean hasKey;
+    private com.google.protobuf.ByteString key_ = com.google.protobuf.ByteString.EMPTY;
+    public boolean hasKey() { return hasKey; }
+    public com.google.protobuf.ByteString getKey() { return key_; }
+    
+    // optional uint32 r = 3;
+    public static final int R_FIELD_NUMBER = 3;
+    private boolean hasR;
+    private int r_ = 0;
+    public boolean hasR() { return hasR; }
+    public int getR() { return r_; }
+    
+    private void initFields() {
+    }
+    public final boolean isInitialized() {
+      if (!hasBucket) return false;
+      if (!hasKey) return false;
+      return true;
+    }
+    
+    public void writeTo(com.google.protobuf.CodedOutputStream output)
+                        throws java.io.IOException {
+      getSerializedSize();
+      if (hasBucket()) {
+        output.writeBytes(1, getBucket());
+      }
+      if (hasKey()) {
+        output.writeBytes(2, getKey());
+      }
+      if (hasR()) {
+        output.writeUInt32(3, getR());
+      }
+      getUnknownFields().writeTo(output);
+    }
+    
+    private int memoizedSerializedSize = -1;
+    public int getSerializedSize() {
+      int size = memoizedSerializedSize;
+      if (size != -1) return size;
+    
+      size = 0;
+      if (hasBucket()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeBytesSize(1, getBucket());
+      }
+      if (hasKey()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeBytesSize(2, getKey());
+      }
+      if (hasR()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeUInt32Size(3, getR());
+      }
+      size += getUnknownFields().getSerializedSize();
+      memoizedSerializedSize = size;
+      return size;
+    }
+    
+    public static com.basho.riak.Riakclient.RpbGetReq parseFrom(
+        com.google.protobuf.ByteString data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data).buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetReq parseFrom(
+        com.google.protobuf.ByteString data,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data, extensionRegistry)
+               .buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetReq parseFrom(byte[] data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data).buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetReq parseFrom(
+        byte[] data,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data, extensionRegistry)
+               .buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetReq parseFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input).buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetReq parseFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input, extensionRegistry)
+               .buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetReq parseDelimitedFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      Builder builder = newBuilder();
+      if (builder.mergeDelimitedFrom(input)) {
+        return builder.buildParsed();
+      } else {
+        return null;
+      }
+    }
+    public static com.basho.riak.Riakclient.RpbGetReq parseDelimitedFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      Builder builder = newBuilder();
+      if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
+        return builder.buildParsed();
+      } else {
+        return null;
+      }
+    }
+    public static com.basho.riak.Riakclient.RpbGetReq parseFrom(
+        com.google.protobuf.CodedInputStream input)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input).buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetReq parseFrom(
+        com.google.protobuf.CodedInputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input, extensionRegistry)
+               .buildParsed();
+    }
+    
+    public static Builder newBuilder() { return Builder.create(); }
+    public Builder newBuilderForType() { return newBuilder(); }
+    public static Builder newBuilder(com.basho.riak.Riakclient.RpbGetReq prototype) {
+      return newBuilder().mergeFrom(prototype);
+    }
+    public Builder toBuilder() { return newBuilder(this); }
+    
+    public static final class Builder extends
+        com.google.protobuf.GeneratedMessage.Builder<Builder> {
+      private com.basho.riak.Riakclient.RpbGetReq result;
+      
+      // Construct using com.basho.riak.Riakclient.RpbGetReq.newBuilder()
+      private Builder() {}
+      
+      private static Builder create() {
+        Builder builder = new Builder();
+        builder.result = new com.basho.riak.Riakclient.RpbGetReq();
+        return builder;
+      }
+      
+      protected com.basho.riak.Riakclient.RpbGetReq internalGetResult() {
+        return result;
+      }
+      
+      public Builder clear() {
+        if (result == null) {
+          throw new IllegalStateException(
+            "Cannot call clear() after build().");
+        }
+        result = new com.basho.riak.Riakclient.RpbGetReq();
+        return this;
+      }
+      
+      public Builder clone() {
+        return create().mergeFrom(result);
+      }
+      
+      public com.google.protobuf.Descriptors.Descriptor
+          getDescriptorForType() {
+        return com.basho.riak.Riakclient.RpbGetReq.getDescriptor();
+      }
+      
+      public com.basho.riak.Riakclient.RpbGetReq getDefaultInstanceForType() {
+        return com.basho.riak.Riakclient.RpbGetReq.getDefaultInstance();
+      }
+      
+      public boolean isInitialized() {
+        return result.isInitialized();
+      }
+      public com.basho.riak.Riakclient.RpbGetReq build() {
+        if (result != null && !isInitialized()) {
+          throw newUninitializedMessageException(result);
+        }
+        return buildPartial();
+      }
+      
+      private com.basho.riak.Riakclient.RpbGetReq buildParsed()
+          throws com.google.protobuf.InvalidProtocolBufferException {
+        if (!isInitialized()) {
+          throw newUninitializedMessageException(
+            result).asInvalidProtocolBufferException();
+        }
+        return buildPartial();
+      }
+      
+      public com.basho.riak.Riakclient.RpbGetReq buildPartial() {
+        if (result == null) {
+          throw new IllegalStateException(
+            "build() has already been called on this Builder.");
+        }
+        com.basho.riak.Riakclient.RpbGetReq returnMe = result;
+        result = null;
+        return returnMe;
+      }
+      
+      public Builder mergeFrom(com.google.protobuf.Message other) {
+        if (other instanceof com.basho.riak.Riakclient.RpbGetReq) {
+          return mergeFrom((com.basho.riak.Riakclient.RpbGetReq)other);
+        } else {
+          super.mergeFrom(other);
+          return this;
+        }
+      }
+      
+      public Builder mergeFrom(com.basho.riak.Riakclient.RpbGetReq other) {
+        if (other == com.basho.riak.Riakclient.RpbGetReq.getDefaultInstance()) return this;
+        if (other.hasBucket()) {
+          setBucket(other.getBucket());
+        }
+        if (other.hasKey()) {
+          setKey(other.getKey());
+        }
+        if (other.hasR()) {
+          setR(other.getR());
+        }
+        this.mergeUnknownFields(other.getUnknownFields());
+        return this;
+      }
+      
+      public Builder mergeFrom(
+          com.google.protobuf.CodedInputStream input,
+          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+          throws java.io.IOException {
+        com.google.protobuf.UnknownFieldSet.Builder unknownFields =
+          com.google.protobuf.UnknownFieldSet.newBuilder(
+            this.getUnknownFields());
+        while (true) {
+          int tag = input.readTag();
+          switch (tag) {
+            case 0:
+              this.setUnknownFields(unknownFields.build());
+              return this;
+            default: {
+              if (!parseUnknownField(input, unknownFields,
+                                     extensionRegistry, tag)) {
+                this.setUnknownFields(unknownFields.build());
+                return this;
+              }
+              break;
+            }
+            case 10: {
+              setBucket(input.readBytes());
+              break;
+            }
+            case 18: {
+              setKey(input.readBytes());
+              break;
+            }
+            case 24: {
+              setR(input.readUInt32());
+              break;
+            }
+          }
+        }
+      }
+      
+      
+      // required bytes bucket = 1;
+      public boolean hasBucket() {
+        return result.hasBucket();
+      }
+      public com.google.protobuf.ByteString getBucket() {
+        return result.getBucket();
+      }
+      public Builder setBucket(com.google.protobuf.ByteString value) {
+        if (value == null) {
+    throw new NullPointerException();
+  }
+  result.hasBucket = true;
+        result.bucket_ = value;
+        return this;
+      }
+      public Builder clearBucket() {
+        result.hasBucket = false;
+        result.bucket_ = getDefaultInstance().getBucket();
+        return this;
+      }
+      
+      // required bytes key = 2;
+      public boolean hasKey() {
+        return result.hasKey();
+      }
+      public com.google.protobuf.ByteString getKey() {
+        return result.getKey();
+      }
+      public Builder setKey(com.google.protobuf.ByteString value) {
+        if (value == null) {
+    throw new NullPointerException();
+  }
+  result.hasKey = true;
+        result.key_ = value;
+        return this;
+      }
+      public Builder clearKey() {
+        result.hasKey = false;
+        result.key_ = getDefaultInstance().getKey();
+        return this;
+      }
+      
+      // optional uint32 r = 3;
+      public boolean hasR() {
+        return result.hasR();
+      }
+      public int getR() {
+        return result.getR();
+      }
+      public Builder setR(int value) {
+        result.hasR = true;
+        result.r_ = value;
+        return this;
+      }
+      public Builder clearR() {
+        result.hasR = false;
+        result.r_ = 0;
+        return this;
+      }
+      
+      // @@protoc_insertion_point(builder_scope:com.basho.riak.RpbGetReq)
+    }
+    
+    static {
+      defaultInstance = new RpbGetReq(true);
+      com.basho.riak.Riakclient.internalForceInit();
+      defaultInstance.initFields();
+    }
+    
+    // @@protoc_insertion_point(class_scope:com.basho.riak.RpbGetReq)
+  }
+  
+  public static final class RpbGetResp extends
+      com.google.protobuf.GeneratedMessage {
+    // Use RpbGetResp.newBuilder() to construct.
+    private RpbGetResp() {
+      initFields();
+    }
+    private RpbGetResp(boolean noInit) {}
+    
+    private static final RpbGetResp defaultInstance;
+    public static RpbGetResp getDefaultInstance() {
+      return defaultInstance;
+    }
+    
+    public RpbGetResp getDefaultInstanceForType() {
+      return defaultInstance;
+    }
+    
+    public static final com.google.protobuf.Descriptors.Descriptor
+        getDescriptor() {
+      return com.basho.riak.Riakclient.internal_static_com_basho_riak_RpbGetResp_descriptor;
+    }
+    
+    protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+        internalGetFieldAccessorTable() {
+      return com.basho.riak.Riakclient.internal_static_com_basho_riak_RpbGetResp_fieldAccessorTable;
+    }
+    
+    // repeated .com.basho.riak.RpbContent content = 1;
+    public static final int CONTENT_FIELD_NUMBER = 1;
+    private java.util.List<com.basho.riak.Riakclient.RpbContent> content_ =
+      java.util.Collections.emptyList();
+    public java.util.List<com.basho.riak.Riakclient.RpbContent> getContentList() {
+      return content_;
+    }
+    public int getContentCount() { return content_.size(); }
+    public com.basho.riak.Riakclient.RpbContent getContent(int index) {
+      return content_.get(index);
+    }
+    
+    // optional bytes vclock = 2;
+    public static final int VCLOCK_FIELD_NUMBER = 2;
+    private boolean hasVclock;
+    private com.google.protobuf.ByteString vclock_ = com.google.protobuf.ByteString.EMPTY;
+    public boolean hasVclock() { return hasVclock; }
+    public com.google.protobuf.ByteString getVclock() { return vclock_; }
+    
+    private void initFields() {
+    }
+    public final boolean isInitialized() {
+      for (com.basho.riak.Riakclient.RpbContent element : getContentList()) {
+        if (!element.isInitialized()) return false;
+      }
+      return true;
+    }
+    
+    public void writeTo(com.google.protobuf.CodedOutputStream output)
+                        throws java.io.IOException {
+      getSerializedSize();
+      for (com.basho.riak.Riakclient.RpbContent element : getContentList()) {
+        output.writeMessage(1, element);
+      }
+      if (hasVclock()) {
+        output.writeBytes(2, getVclock());
+      }
+      getUnknownFields().writeTo(output);
+    }
+    
+    private int memoizedSerializedSize = -1;
+    public int getSerializedSize() {
+      int size = memoizedSerializedSize;
+      if (size != -1) return size;
+    
+      size = 0;
+      for (com.basho.riak.Riakclient.RpbContent element : getContentList()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeMessageSize(1, element);
+      }
+      if (hasVclock()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeBytesSize(2, getVclock());
+      }
+      size += getUnknownFields().getSerializedSize();
+      memoizedSerializedSize = size;
+      return size;
+    }
+    
+    public static com.basho.riak.Riakclient.RpbGetResp parseFrom(
+        com.google.protobuf.ByteString data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data).buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetResp parseFrom(
+        com.google.protobuf.ByteString data,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data, extensionRegistry)
+               .buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetResp parseFrom(byte[] data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data).buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetResp parseFrom(
+        byte[] data,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return newBuilder().mergeFrom(data, extensionRegistry)
+               .buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetResp parseFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input).buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetResp parseFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input, extensionRegistry)
+               .buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetResp parseDelimitedFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      Builder builder = newBuilder();
+      if (builder.mergeDelimitedFrom(input)) {
+        return builder.buildParsed();
+      } else {
+        return null;
+      }
+    }
+    public static com.basho.riak.Riakclient.RpbGetResp parseDelimitedFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      Builder builder = newBuilder();
+      if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
+        return builder.buildParsed();
+      } else {
+        return null;
+      }
+    }
+    public static com.basho.riak.Riakclient.RpbGetResp parseFrom(
+        com.google.protobuf.CodedInputStream input)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input).buildParsed();
+    }
+    public static com.basho.riak.Riakclient.RpbGetResp parseFrom(
+        com.google.protobuf.CodedInputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      return newBuilder().mergeFrom(input, extensionRegistry)
+               .buildParsed();
+    }
+    
+    public static Builder newBuilder() { return Builder.create(); }
+    public Builder newBuilderForType() { return newBuilder(); }
+    public static Builder newBuilder(com.basho.riak.Riakclient.RpbGetResp prototype) {
+      return newBuilder().mergeFrom(prototype);
+    }
+    public Builder toBuilder() { return newBuilder(this); }
+    
+    public static final class Builder extends
+        com.google.protobuf.GeneratedMessage.Builder<Builder> {
+      private com.basho.riak.Riakclient.RpbGetResp result;
+      
+      // Construct using com.basho.riak.Riakclient.RpbGetResp.newBuilder()
+      private Builder() {}
+      
+      private static Builder create() {
+        Builder builder = new Builder();
+        builder.result = new com.basho.riak.Riakclient.RpbGetResp();
+        return builder;
+      }
+      
+      protected com.basho.riak.Riakclient.RpbGetResp internalGetResult() {
+        return result;
+      }
+      
+      public Builder clear() {
+        if (result == null) {
+          throw new IllegalStateException(
+            "Cannot call clear() after build().");
+        }
+        result = new com.basho.riak.Riakclient.RpbGetResp();
+        return this;
+      }
+      
+      public Builder clone() {
+        return create().mergeFrom(result);
+      }
+      
+      public com.google.protobuf.Descriptors.Descriptor
+          getDescriptorForType() {
+        return com.basho.riak.Riakclient.RpbGetResp.getDescriptor();
+      }
+      
+      public com.basho.riak.Riakclient.RpbGetResp getDefaultInstanceForType() {
+        return com.basho.riak.Riakclient.RpbGetResp.getDefaultInstance();
+      }
+      
+      public boolean isInitialized() {
+        return result.isInitialized();
+      }
+      public com.basho.riak.Riakclient.RpbGetResp build() {
+        if (result != null && !isInitialized()) {
+          throw newUninitializedMessageException(result);
+        }
+        return buildPartial();
+      }
+      
+      private com.basho.riak.Riakclient.RpbGetResp buildParsed()
+          throws com.google.protobuf.InvalidProtocolBufferException {
+        if (!isInitialized()) {
+          throw newUninitializedMessageException(
+            result).asInvalidProtocolBufferException();
+        }
+        return buildPartial();
+      }
+      
+      public com.basho.riak.Riakclient.RpbGetResp buildPartial() {
+        if (result == null) {
+          throw new IllegalStateException(
+            "build() has already been called on this Builder.");
+        }
+        if (result.content_ != java.util.Collections.EMPTY_LIST) {
+          result.content_ =
+            java.util.Collections.unmodifiableList(result.content_);
+        }
+        com.basho.riak.Riakclient.RpbGetResp returnMe = result;
+        result = null;
+        return returnMe;
+      }
+      
+      public Builder mergeFrom(com.google.protobuf.Message other) {
+        if (other instanceof com.basho.riak.Riakclient.RpbGetResp) {
+          return mergeFrom((com.basho.riak.Riakclient.RpbGetResp)other);
+        } else {
+          super.mergeFrom(other);
+          return this;
+        }
+      }
+      
+      public Builder mergeFrom(com.basho.riak.Riakclient.RpbGetResp other) {
+        if (other == com.basho.riak.Riakclient.RpbGetResp.getDefaultInstance()) return this;
+        if (!other.content_.isEmpty()) {
+          if (result.content_.isEmpty()) {
+            result.content_ = new java.util.ArrayList<com.basho.riak.Riakclient.RpbContent>();
+          }
+          result.content_.addAll(other.content_);
+        }
+        if (other.hasVclock()) {
+          setVclock(other.getVclock());
+        }
+        this.mergeUnknownFields(other.getUnknownFields());
+        return this;
+      }
+      
+      public Builder mergeFrom(
+          com.google.protobuf.CodedInputStream input,
+          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+          throws java.io.IOException {
+        com.google.protobuf.UnknownFieldSet.Builder unknownFields =
+          com.google.protobuf.UnknownFieldSet.newBuilder(
+            this.getUnknownFields());
+        while (true) {
+          int tag = input.readTag();
+          switch (tag) {
+            case 0:
+              this.setUnknownFields(unknownFields.build());
+              return this;
+            default: {
+              if (!parseUnknownField(input, unknownFields,
+                                     extensionRegistry, tag)) {
+                this.setUnknownFields(unknownFields.build());
+                return this;
+              }
+              break;
+            }
+            case 10: {
+              com.basho.riak.Riakclient.RpbContent.Builder subBuilder = com.basho.riak.Riakclient.RpbContent.newBuilder();
+              input.readMessage(subBuilder, extensionRegistry);
+              addContent(subBuilder.buildPartial());