Set benchmark concurrency levels to 1, 10, 20, 50

README.md

@@ -103,13 +103,23 @@ Example output:
 
 ```
 ## AppendEventsBench
-append events, single writer                  100   10170.26 µs/op
-append events, 10 concurrent writers           20   85438.80 µs/op
-append events, 100 concurrent writers           2   1102006.00 µs/op
+benchmark name                         iterations   average time
+append events, single writer                  100   20288.68 µs/op
+append events, 10 concurrent writers           10   127416.90 µs/op
+append events, 20 concurrent writers            5   376836.60 µs/op
+append events, 50 concurrent writers            2   582350.50 µs/op
 ## ReadEventsBench
-read events, single reader                   1000   1578.10 µs/op
-read events, 10 concurrent readers            100   16799.80 µs/op
-read events, 100 concurrent readers            10   167397.30 µs/op
+benchmark name                         iterations   average time
+read events, single reader                    500   3674.93 µs/op
+read events, 10 concurrent readers             50   44653.98 µs/op
+read events, 20 concurrent readers             20   73927.55 µs/op
+read events, 50 concurrent readers             10   188244.80 µs/op
+## SubscribeToStreamBench
+benchmark name                         iterations   average time
+subscribe to stream, 1 subscription           100   27687.97 µs/op
+subscribe to stream, 10 subscriptions          50   56047.72 µs/op
+subscribe to stream, 20 subscriptions          10   194164.40 µs/op
+subscribe to stream, 50 subscriptions           5   320435.40 µs/op
 ```
 
 ## Contributing

bench/storage/append_events_bench.exs

@@ -12,15 +12,19 @@ defmodule AppendEventsBench do
   end
 
   bench "append events, single writer" do
-    EventStore.append_to_stream(UUID.uuid4, 0, bench_context)
+    append_events(bench_context, 1)
   end
 
   bench "append events, 10 concurrent writers" do
     append_events(bench_context, 10)
   end
 
-  bench "append events, 100 concurrent writers" do
-    append_events(bench_context, 100)
+  bench "append events, 20 concurrent writers" do
+    append_events(bench_context, 20)
+  end
+
+  bench "append events, 50 concurrent writers" do
+    append_events(bench_context, 50)
   end
 
   defp append_events(events, concurrency) do

bench/storage/read_events_bench.exs

@@ -17,17 +17,19 @@ defmodule ReadEventsBench do
   end
 
   bench "read events, single reader" do
-    {:ok, _} = EventStore.read_stream_forward(bench_context)
-
-    :ok
+    read_stream_forward(bench_context, 1)
   end
 
   bench "read events, 10 concurrent readers" do
     read_stream_forward(bench_context, 10)
   end
 
-  bench "read events, 100 concurrent readers" do
-    read_stream_forward(bench_context, 100)
+  bench "read events, 20 concurrent readers" do
+    read_stream_forward(bench_context, 20)
+  end
+
+  bench "read events, 50 concurrent readers" do
+    read_stream_forward(bench_context, 50)
   end
 
   defp read_stream_forward(stream_uuid, concurrency) do

bench/storage/subscribe_to_stream_bench.exs

@@ -19,8 +19,12 @@ defmodule SubscribeToStreamBench do
     subscribe_to_stream(bench_context, 10)
   end
 
-  bench "subscribe to stream, 100 subscriptions" do
-    subscribe_to_stream(bench_context, 100)
+  bench "subscribe to stream, 20 subscriptions" do
+    subscribe_to_stream(bench_context, 20)
+  end
+
+  bench "subscribe to stream, 50 subscriptions" do
+    subscribe_to_stream(bench_context, 50)
   end
 
   defp subscribe_to_stream(events, concurrency) do