Merge pull request #3 from Azure-Samples/attribution2

Co-author augmentation
Azure-Samples · Feb 7, 2023 · 7b1516b · 7b1516b
2 parents c535000 + 0d8febf
commit 7b1516b
Show file tree

Hide file tree

Showing 6 changed files with 268 additions and 268 deletions.
diff --git a/src/Program.cs b/src/Program.cs
@@ -1,22 +1,22 @@
-using custom_metrics_emitter;
-
-IHost host = Host.CreateDefaultBuilder(args)
-    .ConfigureServices((hostContext, services) =>
-    {
-        IConfiguration configuration = hostContext.Configuration;
-
-        if (!string.IsNullOrEmpty(configuration["APPLICATIONINSIGHTS_CONNECTION_STRING"]))
-        {
-            services.AddApplicationInsightsTelemetryWorkerService();
-        }
-        services.AddHostedService<Worker>();
-        services.AddLogging(opt =>
-        {
-            opt.AddSimpleConsole(config => config.TimestampFormat = "[HH:mm:ss]");
-        });
-
-    })
-    .Build();
-
-await host.RunAsync();
-
+using custom_metrics_emitter;
+
+IHost host = Host.CreateDefaultBuilder(args)
+    .ConfigureServices((hostContext, services) =>
+    {
+        IConfiguration configuration = hostContext.Configuration;
+
+        if (!string.IsNullOrEmpty(configuration["APPLICATIONINSIGHTS_CONNECTION_STRING"]))
+        {
+            services.AddApplicationInsightsTelemetryWorkerService();
+        }
+        services.AddHostedService<Worker>();
+        services.AddLogging(opt =>
+        {
+            opt.AddSimpleConsole(config => config.TimestampFormat = "[HH:mm:ss]");
+        });
+
+    })
+    .Build();
+
+await host.RunAsync();
+
diff --git a/src/Worker.cs b/src/Worker.cs
@@ -1,15 +1,15 @@
-namespace custom_metrics_emitter;
-
-using Azure.Identity;
-
-public class Worker : BackgroundService
-{
-    private readonly ILogger<Worker> _logger = default!;
-    private readonly EmitterConfig _cfg = default!;
-    private readonly EventHubEmitter _ehEmitter = default!;
-
-    public Worker(ILogger<Worker> logger, IConfiguration configuration)
-    {
+namespace custom_metrics_emitter;
+
+using Azure.Identity;
+
+public class Worker : BackgroundService
+{
+    private readonly ILogger<Worker> _logger = default!;
+    private readonly EmitterConfig _cfg = default!;
+    private readonly EventHubEmitter _ehEmitter = default!;
+
+    public Worker(ILogger<Worker> logger, IConfiguration configuration)
+    {
         try
         {
             _logger = logger;
@@ -32,59 +32,59 @@ public Worker(ILogger<Worker> logger, IConfiguration configuration)
                 : new DefaultAzureCredential(options: new() { ManagedIdentityClientId = _cfg.ManagedIdentityClientId });
 
             _ehEmitter = new(_logger, _cfg, defaultCredential);
-        }
-        catch(Exception ex)
+        }
+        catch(Exception ex)
         {
             logger.LogError("{error}", ex.ToString());
-        }
-    }
-
-    protected override async Task ExecuteAsync(CancellationToken cancellationToken = default)
-    {
-        try
-        {
-            while (!cancellationToken.IsCancellationRequested)
-            {
-                _logger.LogInformation("Worker running at: {time}", DateTimeOffset.UtcNow);
-                var res = await _ehEmitter.ReadFromBlobStorageAndPublishToAzureMonitorAsync(cancellationToken);
-
-                if (res.IsSuccessStatusCode)
-                {
-                    _logger.LogInformation("Send Custom Metric end with status: {status}", res.StatusCode);
-                }
-                else
-                {
-                    _logger.LogError("Error sending custom event with status: {status}", res.StatusCode);
-                }
-
-                await Task.Delay(_cfg.CustomMetricInterval, cancellationToken);
-            }
-        }
-        catch (Exception ex)
-        {
-            _logger.LogError("{error}", ex.ToString());
-        }
-    }
-}
-
-/// <summary>
-/// A helper class to make configuration parsing more fluent.
-/// </summary>
-internal static class IConfigurationExtensions
-{
-    internal static int GetIntOrDefault(this IConfiguration cfg, string name, int defaulT) =>
-        !string.IsNullOrEmpty(cfg.GetValue<string>(name)) && int.TryParse(cfg.GetValue<string>(name), out int value) ? value : defaulT;
-
-    internal static string Optional(this IConfiguration cfg, string name) =>
-        cfg.GetValue<string>(name) ?? string.Empty;
-
-    internal static string Require(this IConfiguration cfg, string name)
-    {
-        var val = cfg.Optional(name);
-        if (string.IsNullOrEmpty(val))
-        {
-            throw new ArgumentException($"Configuration error, missing key {name}", nameof(cfg));
-        }
-        return val;
-    }
-}
+        }
+    }
+
+    protected override async Task ExecuteAsync(CancellationToken cancellationToken = default)
+    {
+        try
+        {
+            while (!cancellationToken.IsCancellationRequested)
+            {
+                _logger.LogInformation("Worker running at: {time}", DateTimeOffset.UtcNow);
+                var res = await _ehEmitter.ReadFromBlobStorageAndPublishToAzureMonitorAsync(cancellationToken);
+
+                if (res.IsSuccessStatusCode)
+                {
+                    _logger.LogInformation("Send Custom Metric end with status: {status}", res.StatusCode);
+                }
+                else
+                {
+                    _logger.LogError("Error sending custom event with status: {status}", res.StatusCode);
+                }
+
+                await Task.Delay(_cfg.CustomMetricInterval, cancellationToken);
+            }
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError("{error}", ex.ToString());
+        }
+    }
+}
+
+/// <summary>
+/// A helper class to make configuration parsing more fluent.
+/// </summary>
+internal static class IConfigurationExtensions
+{
+    internal static int GetIntOrDefault(this IConfiguration cfg, string name, int defaulT) =>
+        !string.IsNullOrEmpty(cfg.GetValue<string>(name)) && int.TryParse(cfg.GetValue<string>(name), out int value) ? value : defaulT;
+
+    internal static string Optional(this IConfiguration cfg, string name) =>
+        cfg.GetValue<string>(name) ?? string.Empty;
+
+    internal static string Require(this IConfiguration cfg, string name)
+    {
+        var val = cfg.Optional(name);
+        if (string.IsNullOrEmpty(val))
+        {
+            throw new ArgumentException($"Configuration error, missing key {name}", nameof(cfg));
+        }
+        return val;
+    }
+}
diff --git a/src/emitters/EmitterConfig.cs b/src/emitters/EmitterConfig.cs
@@ -1,14 +1,14 @@
-namespace custom_metrics_emitter;
-
-public record EmitterConfig(
-    string Region,
-    string SubscriptionId,
-    string ResourceGroup,
-    string TenantId,
-    string EventHubNamespace,
-    string EventHubName,
-    string ConsumerGroup,
-    string CheckpointAccountName,
-    string CheckpointContainerName,
-    int CustomMetricInterval,
+namespace custom_metrics_emitter;
+
+public record EmitterConfig(
+    string Region,
+    string SubscriptionId,
+    string ResourceGroup,
+    string TenantId,
+    string EventHubNamespace,
+    string EventHubName,
+    string ConsumerGroup,
+    string CheckpointAccountName,
+    string CheckpointContainerName,
+    int CustomMetricInterval,
     string ManagedIdentityClientId);
diff --git a/src/emitters/EmitterHelper.cs b/src/emitters/EmitterHelper.cs
@@ -1,4 +1,4 @@
-namespace custom_metrics_emitter.emitters;
+namespace custom_metrics_emitter.emitters;
 
 using Azure.Core;
 using Azure.Identity;

diff --git a/src/emitters/EmitterSchema.cs b/src/emitters/EmitterSchema.cs
@@ -1,29 +1,29 @@
-namespace custom_metrics_emitter.emitters;
+namespace custom_metrics_emitter.emitters;
 
 using System.Text.Json.Serialization;
 
 // https://learn.microsoft.com/en-us/azure/azure-monitor/essentials/metrics-store-custom-rest-api
-
-#pragma warning disable IDE1006 // Naming Styles
+
+#pragma warning disable IDE1006 // Naming Styles
 
 public record EmitterSchema(
     DateTime time,
     CustomMetricData? data);
 
 public record CustomMetricData(
     CustomMetricBaseData? baseData);
-
-public record CustomMetricBaseData(
-    string? metric,
-    string? Namespace,
-    IEnumerable<string>? dimNames,
-    IEnumerable<CustomMetricBaseDataSeriesItem>? series);
-
-public record CustomMetricBaseDataSeriesItem(
-    IEnumerable<string>? dimValues,
-    [property: JsonIgnore(Condition = JsonIgnoreCondition.WhenWritingNull)] long? min,
-    [property: JsonIgnore(Condition = JsonIgnoreCondition.WhenWritingNull)] long? max,
-    [property: JsonIgnore(Condition = JsonIgnoreCondition.WhenWritingNull)] long? sum,
-    [property: JsonIgnore(Condition = JsonIgnoreCondition.WhenWritingNull)] long? count);
-
-#pragma warning restore IDE1006 // Naming Styles
+
+public record CustomMetricBaseData(
+    string? metric,
+    string? Namespace,
+    IEnumerable<string>? dimNames,
+    IEnumerable<CustomMetricBaseDataSeriesItem>? series);
+
+public record CustomMetricBaseDataSeriesItem(
+    IEnumerable<string>? dimValues,
+    [property: JsonIgnore(Condition = JsonIgnoreCondition.WhenWritingNull)] long? min,
+    [property: JsonIgnore(Condition = JsonIgnoreCondition.WhenWritingNull)] long? max,
+    [property: JsonIgnore(Condition = JsonIgnoreCondition.WhenWritingNull)] long? sum,
+    [property: JsonIgnore(Condition = JsonIgnoreCondition.WhenWritingNull)] long? count);
+
+#pragma warning restore IDE1006 // Naming Styles