anchor.diff:           mapred_bucket_stream/5, mapred_bucket_stream/6,
            search/3, search/4, search/5, search/6,
            get_index/4, get_index/5, get_index/6, get_index/7,
  -         default_timeout/1]).
  +         default_timeout/1,
  +         tunnel/4]).
   
   -export([init/1, handle_call/3, handle_cast/2, handle_info/2,
            terminate/2, code_change/3]).
  
positive.code:                     ?DEFAULT_TIMEOUT
              end
      end.
  
  %% ====================================================================
  %% gen_server callbacks
  
negative.code: process_response(#request{msg = #rpbindexreq{}}, #rpbindexresp{keys=Keys}, State) ->
      {reply, {ok, Keys}, State};
  
  process_response(#request{msg = #rpbsearchqueryreq{}}, prbsearchqueryresp, State) ->
      {reply, {error, notfound}, State};
  process_response(#request{msg = #rpbsearchqueryreq{index=Index}},
  