Permalink
Browse files

Bucket properties encode/decode moved to riak_pb_codec.

All known bucket properties are now supported. See basho/riak_pb#30
basho/riak_kv#488 basho/riak_api#21
  • Loading branch information...
seancribbs committed Feb 15, 2013
1 parent 6cc20aa commit 6b1e79eddc1ed4bf7854fce32340f4a7f2e49420
Showing with 2 additions and 2 deletions.
  1. +2 −2 src/riakc_pb_socket.erl
View
@@ -448,7 +448,7 @@ set_bucket(Pid, Bucket, BucketProps, Timeout) ->
%% @doc Set bucket properties specifying a server side and local call timeout.
-spec set_bucket(pid(), bucket(), bucket_props(), timeout(), timeout()) -> ok | {error, term()}.
set_bucket(Pid, Bucket, BucketProps, Timeout, CallTimeout) ->
- PbProps = riak_pb_kv_codec:encode_bucket_props(BucketProps),
+ PbProps = riak_pb_codec:encode_bucket_props(BucketProps),
Req = #rpbsetbucketreq{bucket = Bucket, props = PbProps},
gen_server:call(Pid, {req, Req, Timeout}, CallTimeout).
@@ -1117,7 +1117,7 @@ process_response(#request{msg = #rpblistkeysreq{}}=Request,
process_response(#request{msg = #rpbgetbucketreq{}},
#rpbgetbucketresp{props = PbProps}, State) ->
- Props = riak_pb_kv_codec:decode_bucket_props(PbProps),
+ Props = riak_pb_codec:decode_bucket_props(PbProps),
{reply, {ok, Props}, State};
process_response(#request{msg = #rpbsetbucketreq{}},

0 comments on commit 6b1e79e

Please sign in to comment.