anchor.diff:  %% @doc Reset bucket properties back to the defaults.
   -spec reset_bucket(pid(), bucket, timeout(), timeout()) -> ok | {error, term()}.
   reset_bucket(Pid, Bucket, Timeout, CallTimeout) ->
  -    Req = #rpbresetbucketreq{bucket = Bucket},
  +    {T, B} = maybe_bucket_type(Bucket),
  +    Req = #rpbresetbucketreq{type = T, bucket = B},
       gen_server:call(Pid, {req, Req, Timeout}, CallTimeout).
  +
  +reset_bucket_type(Pid, BucketType) ->
  +    reset_bucket_type(Pid, BucketType, default_timeout(reset_bucket_timeout), default_timeout(reset_bucket_call_timeout)).
  +
  +reset_bucket_type(Pid, BucketType, Timeout) ->
  +    reset_bucket_type(Pid, BucketType, Timeout, default_timeout(reset_bucket_call_timeout)).
  +
  +reset_bucket_type(Pid, BucketType, Timeout, CallTimeout) ->
  +    Req = #rpbresetbuckettypereq{type = BucketType},
  +    gen_server:call(Pid, {req, Req, Timeout}, CallTimeout).
  +
   
   %% @doc Perform a MapReduce job across the cluster.
   %%      See the MapReduce documentation for explanation of behavior.
  
positive.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 = #rpbcounterupdatereq{returnvalue=true}},
  
negative.code:     Stream = proplists:get_value(stream, Opts, false),
      Continuation = proplists:get_value(continuation, Opts),
  
      {T, B} = maybe_bucket_type(Bucket),
  
      Req = #rpbindexreq{type=T, bucket=B, index=Index, qtype=eq,
                         key=encode_2i(Key),
                         max_results=MaxResults,
                         stream=Stream,
  