Merge pull request #232 from martinsumner/develop-2.9

Add rt_enqueue messages

src/riak_kv.proto

@@ -329,3 +329,21 @@ message RpbCoverageEntry {
     optional bytes keyspace_desc = 3; // Some human readable description of the keyspace covered
     required bytes cover_context = 4; // Opaque context to pass into 2I query.
 }
+
+// RT Enqueue Request - retrieve bucket/key and pop it on the RTQ
+// NOTE: this is just a GET request minus some meaningless (in this
+// context) options
+message RpbRTEReq {
+    required bytes bucket = 1;
+    required bytes key = 2;
+    optional uint32 r = 3;
+    optional uint32 pr = 4;
+    optional bool basic_quorum = 5;
+    optional bool notfound_ok = 6;
+    optional uint32 timeout = 10;
+    optional bool sloppy_quorum = 11;   // Experimental, may change/disappear
+    optional uint32 n_val = 12;         // Experimental, may change/disappear
+    optional bytes type = 13;           // Bucket type, if not set we assume the 'default' type
+}
+
+// RTE response - not defined, will return a RpbRTEResp on success or RpbErrorResp on failure

src/riak_pb_messages.csv

@@ -68,6 +68,8 @@
 102,TsCoverageEntry,riak_ts
 103,TsRange,riak_ts
 104,TsTtbMsg,riak_ts
+200,RpbRTEReq,riak_kv
+201,RpbRTEResp,riak_kv
 253,RpbAuthReq,riak
 254,RpbAuthResp,riak
 255,RpbStartTls,riak