Execution API alignment

src/Paprika.Runner/Measurement.cs

@@ -0,0 +1,98 @@
+using System.Diagnostics.Metrics;
+using Spectre.Console;
+using Spectre.Console.Rendering;
+
+namespace Paprika.Runner;
+
+abstract class Measurement : JustInTimeRenderable
+{
+    private readonly Instrument _instrument;
+    private const long NoValue = Int64.MaxValue;
+
+    private long _value;
+
+    private Measurement(Instrument instrument)
+    {
+        _instrument = instrument;
+    }
+
+    protected override IRenderable Build()
+    {
+        var value = Volatile.Read(ref _value);
+        return value == NoValue ? new Text("") : new Text(value.ToString());
+    }
+
+    public void Update(double measurement, ReadOnlySpan<KeyValuePair<string, object?>> tags)
+    {
+        var updated = Update(measurement);
+        var previous = Interlocked.Exchange(ref _value, updated);
+
+        if (updated != previous)
+        {
+            MarkAsDirty();
+        }
+    }
+
+    protected abstract long Update(double measurement);
+
+    public override string ToString() => $"{nameof(Instrument)}: {_instrument.Name}, Value: {Volatile.Read(ref _value)}";
+
+    public static Measurement Build(Instrument instrument)
+    {
+        var type = instrument.GetType();
+        if (type.IsGenericType)
+        {
+            var definition = type.GetGenericTypeDefinition();
+
+            if (definition == typeof(ObservableGauge<>))
+            {
+                return new GaugeMeasurement(instrument);
+            }
+
+            if (definition == typeof(Counter<>))
+            {
+                return new CounterMeasurement(instrument);
+            }
+
+            if (definition == typeof(Histogram<>))
+            {
+                return new HistogramMeasurement(instrument);
+            }
+        }
+
+        throw new NotImplementedException($"Not implemented for type {type}");
+    }
+
+    private class GaugeMeasurement : Measurement
+    {
+        public GaugeMeasurement(Instrument instrument) : base(instrument)
+        {
+        }
+
+        protected override long Update(double measurement) => (long)measurement;
+    }
+
+    // for now use the last value
+    private class HistogramMeasurement : Measurement
+    {
+        protected override long Update(double measurement)
+        {
+            return (long)measurement;
+        }
+
+        public HistogramMeasurement(Instrument instrument) : base(instrument)
+        {
+        }
+    }
+
+    private class CounterMeasurement : Measurement
+    {
+        private long _sum;
+
+        protected override long Update(double measurement) => Interlocked.Add(ref _sum, (long)measurement);
+
+        public CounterMeasurement(Instrument instrument) : base(instrument)
+        {
+        }
+    }
+}

src/Paprika.Runner/MetricsReporter.cs

@@ -0,0 +1,85 @@
+using System.Diagnostics.Metrics;
+using System.Runtime.InteropServices;
+using Spectre.Console;
+using Spectre.Console.Rendering;
+
+namespace Paprika.Runner;
+
+public class MetricsReporter : IDisposable
+{
+    private readonly object _sync = new();
+    private readonly MeterListener _listener;
+    private readonly Dictionary<Meter, Dictionary<Instrument, Measurement>> _instrument2State = new();
+
+    public IRenderable Renderer { get; }
+
+    public MetricsReporter()
+    {
+        var table = new Table();
+
+        Renderer = table;
+
+        table.AddColumn(new TableColumn("Meter").LeftAligned());
+        table.AddColumn(new TableColumn("Instrument").LeftAligned());
+        table.AddColumn(new TableColumn("Value").Width(10).RightAligned());
+        table.AddColumn(new TableColumn("Unit").RightAligned());
+
+        _listener = new MeterListener
+        {
+            InstrumentPublished = (instrument, listener) =>
+            {
+                lock (_sync)
+                {
+                    var meter = instrument.Meter;
+                    ref var dict = ref CollectionsMarshal.GetValueRefOrAddDefault(_instrument2State, meter,
+                        out var exists);
+
+                    if (!exists)
+                    {
+                        dict = new Dictionary<Instrument, Measurement>();
+                    }
+
+                    var state = Measurement.Build(instrument);
+                    dict!.Add(instrument, state);
+
+                    table.AddRow(new Text(meter.Name.Replace("Paprika.", "")),
+                        new Text(instrument.Name),
+                        state,
+                        new Text(instrument.Unit!));
+
+                    listener.EnableMeasurementEvents(instrument, state);
+                }
+            },
+            MeasurementsCompleted = (instrument, cookie) =>
+            {
+                lock (_sync)
+                {
+                    var instruments = _instrument2State[instrument.Meter];
+                    instruments.Remove(instrument, out _);
+                    if (instruments.Count == 0)
+                        _instrument2State.Remove(instrument.Meter);
+                }
+            }
+        };
+
+        _listener.Start();
+
+        _listener.SetMeasurementEventCallback<double>((i, m, l, c) => ((Measurement)c!).Update(m, l));
+        _listener.SetMeasurementEventCallback<float>((i, m, l, c) => ((Measurement)c!).Update(m, l));
+        _listener.SetMeasurementEventCallback<long>((i, m, l, c) => ((Measurement)c!).Update(m, l));
+        _listener.SetMeasurementEventCallback<int>((i, m, l, c) => ((Measurement)c!).Update(m, l));
+        _listener.SetMeasurementEventCallback<short>((i, m, l, c) => ((Measurement)c!).Update(m, l));
+        _listener.SetMeasurementEventCallback<byte>((i, m, l, c) => ((Measurement)c!).Update(m, l));
+        _listener.SetMeasurementEventCallback<decimal>((i, m, l, c) => ((Measurement)c!).Update((double)m, l));
+    }
+
+    public void Observe()
+    {
+        _listener.RecordObservableInstruments();
+    }
+
+    public void Dispose()
+    {
+        _listener.Dispose();
+    }
+}

src/Paprika.Runner/Paprika.Runner.csproj

@@ -14,6 +14,7 @@
 
     <ItemGroup>
       <PackageReference Include="HdrHistogram" Version="2.5.0" />
+      <PackageReference Include="Spectre.Console" Version="0.47.1-preview.0.6" />
     </ItemGroup>
 
 </Project>