anchor.diff:    end.
   
   %% @private
  -search_docs_by(DocName, Conn, Index, Query, Limit, Offset) ->
  -  case search(Conn, Index, Query, [], Limit, Offset) of
  -    {ok, {search_results, Results, _, Total}} ->
  -      F = fun({_, KV}, Acc) -> [kv_to_doc(DocName, KV) | Acc] end,
  -      NewRes = lists:reverse(lists:foldl(F, [], Results)),
  -      {ok, {Total, NewRes}};
  -    {error, Error} ->
  -      {error, Error}
  -  end.
  -
  -%% @private
  -delete_docs(Conn, Bucket, Docs, Opts) ->
  -  lists:foreach(fun(D) ->
  -    K = doc_id(D),
  +delete_keys(Conn, Bucket, Keys, Opts) ->
  +  lists:foreach(fun(K) ->
       delete_map(Conn, Bucket, K, Opts)
  -  end, Docs).
  +  end, Keys).
   
   %%%=============================================================================
   %%% Query Builder
  
positive.code:       end;
      _ ->
        Query = build_query(Conditions, Bucket),
        case search_docs_by(DocName, Conn, Index, Query, 0, 0) of
          {ok, {Total, Res}}  ->
            delete_docs(Conn, Bucket, Res, Opts),
            {ok, Total, State};
          {error, Error} ->
            {error, Error, State}
  
negative.code:     fun(R) -> riakc_register:set(sumo_utils:to_bin(V), R) end,
      RMap).
  
  
  
  %% @private
  stream_keys(Conn, Bucket, F, Acc) ->
  