Add --simulations=N parameter to seqcli sample ingest

Author: nblumhardt

src/Roastery/Program.cs

@@ -28,11 +28,10 @@ public static async Task Main(ILogger logger, CancellationToken cancellationToke
                 new RequestLoggingMiddleware(webApplicationLogger,
                     new SchedulingLatencyMiddleware(
                         new FaultInjectionMiddleware(webApplicationLogger,
-                            new Router(new Controller[]
-                            {
+                            new Router([
                                 new OrdersController(logger, database),
                                 new ProductsController(logger, database)
-                            }, webApplicationLogger))))));
+                            ], webApplicationLogger))))));
 
         var agents = new List<Agent>();
 

src/SeqCli/Cli/Commands/Sample/IngestCommand.cs

@@ -13,6 +13,7 @@
 // limitations under the License.
 
 using System;
+using System.Linq;
 using System.Threading.Tasks;
 using SeqCli.Cli.Features;
 using SeqCli.Connection;
@@ -31,6 +32,7 @@ class IngestCommand : Command
     readonly BatchSizeFeature _batchSize;
 
     bool _quiet;
+    int _simulations = 1;
 
     public IngestCommand(SeqConnectionFactory connectionFactory)
     {
@@ -39,6 +41,8 @@ public IngestCommand(SeqConnectionFactory connectionFactory)
         _connection = Enable<ConnectionFeature>();
 
         Options.Add("quiet", "Don't echo ingested events to `STDOUT`", _ => _quiet = true);
+        Options.Add("simulations=", "Number of concurrent simulations to run; the default runs a single simulation",
+            v => _simulations = int.Parse(v));
 
         _batchSize = Enable<BatchSizeFeature>();
     }
@@ -55,7 +59,12 @@ protected override async Task<int> Run()
         }
 
         var connection = _connectionFactory.Connect(_connection);
-        await Simulation.RunAsync(connection, apiKey, batchSize, echoToStdout: !_quiet);
+        var simulations = Enumerable.Range(0, _simulations)
+            .Select(_ => Simulation.RunAsync(connection, apiKey, batchSize, echoToStdout: !_quiet))
+            .ToList();
+
+        await Task.WhenAll(simulations);
+        
         return 0;
     }
 }

src/SeqCli/Sample/Loader/Simulation.cs

@@ -35,7 +35,7 @@ public static async Task RunAsync(SeqConnection connection, string? apiKey, int
             .CreateLogger();
 
         var ship = Task.Run(() => LogShipper.ShipEvents(connection, apiKey, buffer,
-            InvalidDataHandling.Fail, SendFailureHandling.Continue, batchSize));
+            InvalidDataHandling.Fail, SendFailureHandling.Continue, batchSize), cancellationToken);
 
         await Roastery.Program.Main(logger, cancellationToken);
         await logger.DisposeAsync();