Create/apply aspect in order to measure execution time

Aspects/ExecutionTimeMeasured.cs

@@ -0,0 +1,30 @@
+using AspectInjector.Broker;
+using NLog;
+using System;
+using System.Diagnostics;
+
+namespace Mycenae.Aspects
+{
+    [Aspect(Scope.PerInstance)]
+    [Injection(typeof(ExecutionTimeMeasured))]
+    public class ExecutionTimeMeasured : Attribute
+    {
+        private readonly ILogger _logger = LogManager.GetCurrentClassLogger();
+        private Stopwatch _stopwatch;
+
+        [Advice(Kind.Before)]
+        public void StartMeasurement()
+        {
+            _stopwatch = Stopwatch.StartNew();
+        }
+
+        [Advice(Kind.After)]
+        public void FinishMeasurement([Argument(Source.Name)] string name)
+        {
+            _stopwatch.Stop();
+
+            _logger.Info($"Time elapsed ({name}): {_stopwatch.Elapsed.Hours}h:{_stopwatch.Elapsed.Minutes}m:" +
+                $"{_stopwatch.Elapsed.Seconds}s:{_stopwatch.Elapsed.Milliseconds}ms");
+        }
+    }
+}

Mycenae.csproj

@@ -6,6 +6,7 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="AspectInjector" Version="2.4.0" />
     <PackageReference Include="CassandraCSharpDriver" Version="3.15.0" />
     <PackageReference Include="CsvHelper" Version="15.0.5" />
     <PackageReference Include="Microsoft.Extensions.Configuration" Version="3.1.6" />

Tasks/EndToEnd.cs

@@ -1,4 +1,5 @@
 using Cassandra;
+using Mycenae.Aspects;
 using Mycenae.Models;
 using NLog;
 using System;
@@ -11,6 +12,7 @@ internal class EndToEnd : MigrationTask
     {
         private static readonly Logger Logger = LogManager.GetCurrentClassLogger();
 
+        [ExecutionTimeMeasured]
         internal override void Execute()
         {
             Logger.Info("Starting end-to-end migration...");

Tasks/Extraction.cs

@@ -1,4 +1,5 @@
 using Cassandra;
+using Mycenae.Aspects;
 using Mycenae.Models;
 using NLog;
 using System;
@@ -13,6 +14,7 @@ internal class Extraction : MigrationTask
     {
         private static readonly Logger Logger = LogManager.GetCurrentClassLogger();
 
+        [ExecutionTimeMeasured]
         internal override void Execute()
         {
             Logger.Info("Starting extraction phase...");

Tasks/Insertion.cs

@@ -1,5 +1,6 @@
 using Cassandra;
 using CsvHelper;
+using Mycenae.Aspects;
 using Mycenae.Converters;
 using Mycenae.Models;
 using NLog;
@@ -16,6 +17,7 @@ internal class Insertion : MigrationTask
     {
         private static readonly Logger Logger = LogManager.GetCurrentClassLogger();
 
+        [ExecutionTimeMeasured]
         internal override void Execute()
         {
             Logger.Info("Starting insertion phase...");

Tasks/MigrationTask.cs

@@ -1,4 +1,5 @@
 using Cassandra;
+using Mycenae.Aspects;
 using Mycenae.Models;
 using Mycenae.Policies;
 using NLog;
@@ -112,6 +113,7 @@ protected static IList<CColumn> GetColumnsInfo(string keyspace, string table)
             return results.Columns.Select(column => new CColumn(column.Name, column.Type)).ToList();
         }
 
+        [ExecutionTimeMeasured]
         protected static async Task ExecuteInsertAsync(IList<BoundStatement> insertStatements)
         {
             Logger.Info($"Inserting {insertStatements.Count} records into table...");