Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP

Loading…

Support reset bucket properties feature. #35

Merged
merged 1 commit into from

2 participants

@seancribbs

This only adds the protocol messages for the request and response. Corresponding PRs on riak_api and riak-erlang-client will implement the feature.

@seancribbs seancribbs was assigned
@seancribbs seancribbs referenced this pull request in basho/riak-erlang-client
Merged

Add support for reset bucket properties request. #91

@evanmcc evanmcc was assigned
@evanmcc

:+1: will push my riak_test pr in a few.

@evanmcc evanmcc referenced this pull request in basho/riak_test
Merged

test update for PBC bucket reset #264

@seancribbs seancribbs merged commit f9f6a7e into master
@seancribbs seancribbs deleted the sdc-reset-bucket-props branch
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Commits on Mar 14, 2013
  1. @seancribbs
This page is out of date. Refresh to see the latest.
Showing with 15 additions and 2 deletions.
  1. +8 −0 src/riak.proto
  2. +7 −2 src/riak_pb_codec.erl
View
8 src/riak.proto
@@ -68,6 +68,14 @@ message RpbSetBucketReq {
// Set bucket properties response - no message defined, just send
// RpbSetBucketResp
+// Reset bucket properties request
+message RpbResetBucketReq {
+ required bytes bucket = 1;
+}
+
+// Reset bucket properties response - no message defined, just send
+// RpbResetBucketResp
+
// Module-Function pairs for commit hooks and other bucket properties
// that take functions
message RpbModFun {
View
9 src/riak_pb_codec.erl
@@ -117,6 +117,8 @@ msg_type(25) -> rpbindexreq;
msg_type(26) -> rpbindexresp;
msg_type(27) -> rpbsearchqueryreq;
msg_type(28) -> rpbsearchqueryresp;
+msg_type(29) -> rpbresetbucketreq;
+msg_type(30) -> rpbresetbucketresp;
msg_type(_) -> undefined.
%% @doc Converts a symbolic message name into a message code. Replaces
@@ -150,12 +152,15 @@ msg_code(rpbmapredresp) -> 24;
msg_code(rpbindexreq) -> 25;
msg_code(rpbindexresp) -> 26;
msg_code(rpbsearchqueryreq) -> 27;
-msg_code(rpbsearchqueryresp) -> 28.
+msg_code(rpbsearchqueryresp) -> 28;
+msg_code(rpbresetbucketreq) -> 29;
+msg_code(rpbresetbucketresp) -> 30.
%% @doc Selects the appropriate PB decoder for a message code.
-spec decoder_for(pos_integer()) -> module().
decoder_for(N) when N >= 0, N < 3;
- N == 7; N == 8 ->
+ N == 7; N == 8;
+ N == 29; N == 30 ->
riak_pb;
decoder_for(N) when N >= 3, N < 7;
N >= 9, N =< 26->
Something went wrong with that request. Please try again.