first draft

Author: maximsemenov80

dotnet/src/Azure.Iot.Operations.Services/Observability/AkriObservabilityServiceStub.cs

@@ -0,0 +1,19 @@
+// Copyright (c) Microsoft Corporation.
+// Licensed under the MIT License.
+
+using Azure.Iot.Operations.Protocol;
+
+namespace Azure.Iot.Operations.Services.Observability;
+
+public class AkriObservabilityServiceStub : AkriObservabilityService.AkriObservabilityService.Client
+{
+    public AkriObservabilityServiceStub(
+        ApplicationContext applicationContext,
+        IMqttPubSubClient mqttClient,
+        Dictionary<string, string>? topicTokenMap = null) : base(
+            applicationContext,
+            mqttClient,
+            topicTokenMap)
+    {
+    }
+}

dotnet/src/Azure.Iot.Operations.Services/Observability/CachedCounter.cs

@@ -0,0 +1,52 @@
+// Copyright (c) Microsoft Corporation.
+// Licensed under the MIT License.
+
+using System.Collections.Concurrent;
+using Azure.Iot.Operations.Services.Observability.AkriObservabilityService;
+
+namespace Azure.Iot.Operations.Services.Observability;
+
+internal class CachedCounter : ICounter
+{
+    private readonly ConcurrentQueue<IncrementOperation> _operations = new();
+
+    public string Name { get; }
+    public Dictionary<string, string> Labels { get; }
+    public string? Unit { get; }
+
+    public CachedCounter(string name, Dictionary<string, string> labels, string? unit)
+    {
+        Name = name;
+        Labels = labels;
+        Unit = unit;
+    }
+
+    public void Add(double value)
+    {
+        _operations.Enqueue(new IncrementOperation
+        {
+            OperationId = Guid.NewGuid().ToString(),
+            Timestamp = DateTime.UtcNow,
+            Value = value
+        });
+    }
+
+    public void Increment()
+    {
+        Add(1);
+    }
+
+    public List<IncrementOperation> GetOperationsAndClear(int maxCount)
+    {
+        var result = new List<IncrementOperation>();
+
+        int count = 0;
+        while (count < maxCount && _operations.TryDequeue(out var operation))
+        {
+            result.Add(operation);
+            count++;
+        }
+
+        return result;
+    }
+}

dotnet/src/Azure.Iot.Operations.Services/Observability/CachedGauge.cs

@@ -0,0 +1,47 @@
+// Copyright (c) Microsoft Corporation.
+// Licensed under the MIT License.
+
+using System.Collections.Concurrent;
+using Azure.Iot.Operations.Services.Observability.AkriObservabilityService;
+
+namespace Azure.Iot.Operations.Services.Observability;
+
+internal class CachedGauge : IGauge
+{
+    private readonly ConcurrentQueue<RecordOperation> _operations = new();
+
+    public string Name { get; }
+    public Dictionary<string, string> Labels { get; }
+    public string? Unit { get; }
+
+    public CachedGauge(string name, Dictionary<string, string> labels, string? unit)
+    {
+        Name = name;
+        Labels = labels;
+        Unit = unit;
+    }
+
+    public void Record(double value)
+    {
+        _operations.Enqueue(new RecordOperation
+        {
+            OperationId = Guid.NewGuid().ToString(),
+            Timestamp = DateTime.UtcNow,
+            Value = value
+        });
+    }
+
+    public List<RecordOperation> GetOperationsAndClear(int maxCount)
+    {
+        var result = new List<RecordOperation>();
+
+        int count = 0;
+        while (count < maxCount && _operations.TryDequeue(out var operation))
+        {
+            result.Add(operation);
+            count++;
+        }
+
+        return result;
+    }
+}

dotnet/src/Azure.Iot.Operations.Services/Observability/CachedHistogram.cs

@@ -0,0 +1,48 @@
+// Copyright (c) Microsoft Corporation.
+// Licensed under the MIT License.
+
+using System.Collections.Concurrent;
+using Azure.Iot.Operations.Services.Observability.AkriObservabilityService;
+
+namespace Azure.Iot.Operations.Services.Observability
+{
+    internal class CachedHistogram : IHistogram
+    {
+        private readonly ConcurrentQueue<RecordOperation> _operations = new();
+
+        public string Name { get; }
+        public Dictionary<string, string> Labels { get; }
+        public string? Unit { get; }
+
+        public CachedHistogram(string name, Dictionary<string, string> labels, string? unit)
+        {
+            Name = name;
+            Labels = labels;
+            Unit = unit;
+        }
+
+        public void Record(double value)
+        {
+            _operations.Enqueue(new RecordOperation
+            {
+                OperationId = Guid.NewGuid().ToString(),
+                Timestamp = DateTime.UtcNow,
+                Value = value
+            });
+        }
+
+        public List<RecordOperation> GetOperationsAndClear(int maxCount)
+        {
+            var result = new List<RecordOperation>();
+
+            int count = 0;
+            while (count < maxCount && _operations.TryDequeue(out var operation))
+            {
+                result.Add(operation);
+                count++;
+            }
+
+            return result;
+        }
+    }
+}