anchor.diff:      Props = riak_pb_codec:decode_bucket_props(PbProps),
       {reply, {ok, Props}, State};
   
  +process_response(#request{msg = #rpbgetbuckettypereq{}},
  +                 #rpbgetbucketresp{props = PbProps}, State) ->
  +    Props = riak_pb_codec:decode_bucket_props(PbProps),
  +    {reply, {ok, Props}, State};
  +
   process_response(#request{msg = #rpbsetbucketreq{}},
  +                 rpbsetbucketresp, State) ->
  +    {reply, ok, State};
  +
  +process_response(#request{msg = #rpbsetbuckettypereq{}},
                    rpbsetbucketresp, State) ->
       {reply, ok, State};
   
  
positive.code: -spec counter_incr(pid(), bucket(), key(), integer(), [write_quorum()]) ->
      ok | {error, term()}.
  counter_incr(Pid, Bucket, Key, Amount, Options) ->
      Req = counter_incr_options(Options, #rpbcounterupdatereq{bucket=Bucket, key=Key, amount=Amount}),
      gen_server:call(Pid, {req, Req, default_timeout(put_timeout)}).
  
  %% @doc get the current value of the counter at `Bucket', `Key'.
  
negative.code: 
  %% @doc Delete the key/value with options and timeout. <em>Note that the rw quorum is deprecated, use r and w.</em>
  -spec delete(pid(), bucket(), key(), delete_options(), timeout()) -> ok | {error, term()}.
  delete(Pid, Bucket, Key, Options, Timeout) ->
      {T, B} = maybe_bucket_type(Bucket),
      Req = delete_options(Options, #rpbdelreq{type = T, bucket = B, key = Key}),
      gen_server:call(Pid, {req, Req, Timeout}, infinity).
  
  
  