Add counters configuration for 2.0+.

Add a configuration that can be modified to do benchmarking
for the new 2.0 CRDT counters.

Author: cmeiklejohn

examples/counters-2.0.config

@@ -0,0 +1,21 @@
+{mode,{rate,max}}.
+{duration,1}.
+{rng_seed,now}.
+
+%% This bucket type must be created and set to be datatype, maps.
+{riakc_pb_bucket,{<<"counters">>,<<"testbucket">>}}.
+
+%% Pareto distribution over 7.5 million records.
+{key_generator, {int_to_bin_bigendian, {uniform_int, 10000}}}.
+{value_generator, {uniform_int, 100}}.
+
+{concurrent,10}.
+
+{operations,[{{counter,increment},1},
+             {{counter,value},10}]}.
+
+{riakc_pb_ips,[{"127.0.0.1",8087}]}.
+
+{riakc_pb_replies,default}.
+
+{driver,basho_bench_driver_riakc_pb}.

src/basho_bench_driver_riakc_pb.erl

@@ -440,13 +440,16 @@ run(mr_keylist_js, KeyGen, _ValueGen, State) ->
 
 run({counter, value}, KeyGen, _ValueGen, State) ->
     Key = KeyGen(),
+    lager:info("Counter value called for key: ~p", [Key]),
     Options = [{r,2}, {notfound_ok, true}, {timeout, 5000}],
     Result = riakc_pb_socket:fetch_type(State#state.pid,
                                         State#state.bucket,
                                         Key,
                                         Options),
     case Result of
-        {ok, _} ->
+        {ok, C0} ->
+            C = riakc_counter:value(C0),
+            lager:info("Counter value is: ~p", [C]),
             {ok, State};
         {error, {notfound, _}} ->
             {ok, State};
@@ -458,6 +461,7 @@ run({counter, value}, KeyGen, _ValueGen, State) ->
 run({counter, increment}, KeyGen, ValueGen, State) ->
     Amt = ValueGen(),
     Key = KeyGen(),
+    lager:info("Counter value called for key: ~p", [Key]),
     Result = riakc_pb_socket:modify_type(State#state.pid,
                                          fun(C) ->
                                                  riakc_counter:increment(Amt, C)