anchor.diff:  counter_incr(Pid, Bucket, Key, Amount, Options) ->
       {_, B} = maybe_bucket_type(Bucket),
       Req = counter_incr_options(Options, #rpbcounterupdatereq{bucket=B, key=Key, amount=Amount}),
  -    gen_server:call(Pid, {req, Req, default_timeout(put_timeout)}, infinity).
  +    call_infinity(Pid, {req, Req, default_timeout(put_timeout)}).
   
   %% @doc get the current value of the counter at `Bucket', `Key'.
   -spec counter_val(pid(), bucket(), key()) ->
  
positive.code:                     {ok, [search_index()]} | {error, term()}.
  list_search_indexes(Pid, Opts) ->
      Timeout = proplists:get_value(timeout, Opts, default_timeout(search_timeout)),
      CallTimeout = proplists:get_value(call_timeout, Opts, default_timeout(search_call_timeout)),
      gen_server:call(Pid, {req, #rpbyokozunaindexgetreq{}, Timeout}, CallTimeout).
  
  -spec list_search_indexes(pid()) ->
                      {ok, [search_index()]} | {error, term()}.
  
negative.code:     get_index_eq(Pid, Bucket, Index, BinKey, Opts);
  get_index_eq(Pid, Bucket, Index, Key, Opts) ->
      Timeout = proplists:get_value(timeout, Opts),
      MaxResults = proplists:get_value(max_results, Opts),
      PgSort = proplists:get_value(pagination_sort, Opts),
      Stream = proplists:get_value(stream, Opts, false),
  