Attempt at HTTP based bench GET

Author: martinsumner

examples/riakc_nhs_clinicals.config

@@ -15,7 +15,7 @@
 %% For alwaysget operations what is:
 %% - the maximum number of keys per worker (max number of keys = this * concurrent)
 %% - whether the inserts should be in key_order
-{alwaysget, {300000, 120000, skew_order}}.
+{alwaysget, {400000, 120000, skew_order}}.
 {unique, {7000, skew_order}}.
 
 {pb_ips, [{127,0,0,1}]}.

src/basho_bench_driver_nhs.erl

@@ -167,14 +167,38 @@ run(get_pb, KeyGen, _ValueGen, State) ->
             {error, Reason, State}
     end;
 
+run(alwaysget_http, _KeyGen, _ValueGen, State) ->
+    Host = inet_parse:ntoa(State#state.http_host),
+    Port = State#state.http_port,
+    Bucket = State#state.recordBucket,
+    AGKC = State#state.alwaysget_key_count,
+    case AGKC > State#state.alwaysget_perworker_minkeycount of 
+        true ->
+            KeyInt = eightytwenty_keycount(AGKC),    
+            Key = generate_uniquekey(KeyInt, State#state.rand_keyid, 
+                                        State#state.alwaysget_keyorder),
+            URL = 
+                io_lib:format("http://~s:~p/buckets/~s/keys/~s", 
+                                [Host, Port, Bucket, Key]),
+
+            case get_existing(URL, State#state.http_timeout) of
+                ok ->
+                    {ok, State};
+                {error, Reason} ->
+                    % not_found is not OK
+                    {error, Reason, State}
+            end;
+        false ->
+            {silent, State}
+    end;
+
 run(alwaysget_pb, _KeyGen, _ValueGen, State) ->
     % Get one of the objects with unique keys
     Pid = State#state.pb_pid,
     Bucket = State#state.recordBucket,
     AGKC = State#state.alwaysget_key_count,
     case AGKC > State#state.alwaysget_perworker_minkeycount of 
         true ->
-
             KeyInt = eightytwenty_keycount(AGKC),    
             Key = generate_uniquekey(KeyInt, State#state.rand_keyid, 
                                         State#state.alwaysget_keyorder),
@@ -505,6 +529,14 @@ json_get(Url, Timeout, UsePool) ->
             {error, Other}
     end.
 
+get_existing(Url, Timeout) ->
+    case ibrowse:send_req(lists:flatten(Url), [], get, [], [], Timeout) of
+        {ok, "200", _, _Body} ->
+            ok;
+        Other ->
+            {error, Other}
+    end.
+
 
 to_binary(B) when is_binary(B) ->
     B;