anchor.diff:      {error, max_retries};
   send_request(Host, Url, Headers, Method, Body, Options, Count) ->
       Pid = connect(Host),
  -    case catch(ibrowse_http_client:send_req(Pid, Url, Headers, Method, Body, Options, basho_bench_config:get(moss_request_timeout, 5000))) of
  +    HeadersWithAuth = [{'Authorization', basho_bench_config:get(moss_authorization)}|Headers],
  +    case catch(ibrowse_http_client:send_req(Pid, Url, HeadersWithAuth, Method, Body, Options, basho_bench_config:get(moss_request_timeout, 5000))) of
           {ok, Status, RespHeaders, RespBody} ->
               maybe_disconnect(Host),
               {ok, Status, RespHeaders, RespBody};
  
positive.code:                       delete, <<>>, [{response_format, binary}]) of
          {ok, "200", _Header, _Body} ->
              ok;
          {ok, Code, _Header, _Body} ->
              {error, {http_error, Code}};
          {error, Reason} ->
  
negative.code: %% Internal functions
  %% ====================================================================
  
  insert(KeyGen, ValueGen, {Host, Port}) ->
      %% TODO:
      %% bucket needs to be
      %% configurable/generatable
      Bucket = "test",
      Key = KeyGen(),
      Url = url(Host, Port, Bucket, Key),
      Value = ValueGen(),
      do_put({Host, Port}, Url, [], Value).
  
  url(Host, Port, Bucket, Key) ->
      UnparsedUrl = lists:concat(["http://", Host, ":", Port, "/", Bucket, "/", Key]),
  