anchor.diff:      EndIncl = proplists:get_value(end_incl, Opts, false),
       Continuation = proplists:get_value(continuation, Opts),
   
  -    Req = #rpbcsbucketreq{bucket=Bucket,
  +    {T, B} = maybe_bucket_type(Bucket),
  +
  +    Req = #rpbcsbucketreq{type=T, bucket=B,
                             start_key=StartKey,
                             end_key=EndKey,
                             start_incl=StartIncl,
  
positive.code: -spec set_bucket(pid(), bucket(), bucket_props(), timeout(), timeout()) -> ok | {error, term()}.
  set_bucket(Pid, Bucket, BucketProps, Timeout, CallTimeout) ->
      PbProps = riak_pb_codec:encode_bucket_props(BucketProps),
      Req = #rpbsetbucketreq{bucket = Bucket, props = PbProps},
      gen_server:call(Pid, {req, Req, Timeout}, CallTimeout).
  
  %% @doc Reset bucket properties back to the defaults.
  
negative.code:                || Doc <- PBDocs ],
      Result = #search_results{docs=Values, max_score=MaxScore, num_found=NumFound},
      {reply, {ok, Result}, State};
  
  process_response(#request{msg=#rpbresetbucketreq{}}, rpbresetbucketresp, State) ->
      {reply, ok, State};
  
  process_response(#request{msg=#rpbresetbuckettypereq{}}, rpbresetbucketresp, State) ->
      {reply, ok, State};
  
  process_response(#request{msg = #rpbcounterupdatereq{returnvalue=true}},
  