Add ConfigureTelemetry

Author: jerviscui

src/plugins/ConsolePollyTest/MyMeteringEnricher.cs

@@ -4,8 +4,14 @@ namespace ConsolePollyTest;
 
 internal sealed class MyMeteringEnricher : MeteringEnricher
 {
+
+    #region Methods
+
     public override void Enrich<TResult, TArgs>(in EnrichmentContext<TResult, TArgs> context)
     {
         context.Tags.Add(new("my-custom-tag", "custom-value"));
     }
-}
+
+    #endregion
+
+}

src/plugins/ConsolePollyTest/MyTelemetryListener.cs

@@ -4,8 +4,14 @@ namespace ConsolePollyTest;
 
 internal sealed class MyTelemetryListener : TelemetryListener
 {
+
+    #region Methods
+
     public override void Write<TResult, TArgs>(in TelemetryEventArguments<TResult, TArgs> args)
     {
         Console.WriteLine($"Telemetry event occurred: {args.Event.EventName}");
     }
+
+    #endregion
+
 }

src/plugins/ConsolePollyTest/PollyTest.cs

@@ -56,7 +56,8 @@ public static async Task NoStrategy_TestAsync()
 
     public static async Task Retry_ExecThree_TestAsync()
     {
-        var builder = new ResiliencePipelineBuilder().ConfigureTelemetry(GetTelemetry())
+        var options = GetTelemetry();
+        var builder = new ResiliencePipelineBuilder().ConfigureTelemetry(options)
             .AddRetry(
                 new RetryStrategyOptions
                 {
@@ -91,6 +92,46 @@ public static async Task Retry_ExecThree_TestAsync()
         Console.WriteLine(result);
     }
 
+    public static async Task Retry_UseSamePipeline_TestAsync()
+    {
+        var builder = new ResiliencePipelineBuilder().ConfigureTelemetry(GetTelemetry().LoggerFactory)
+            .AddRetry(
+                new RetryStrategyOptions
+                {
+                    Delay = TimeSpan.FromSeconds(1),
+                    MaxRetryAttempts = 5,
+                    ShouldHandle = (args) =>
+                            {
+                                Console.WriteLine(args.AttemptNumber);
+                                return ValueTask.FromResult(args.AttemptNumber >= 0);
+                            }
+                });
+
+        var pipeline = builder.Build();
+
+        using var client = GetClient();
+
+        var t1 = pipeline.ExecuteAsync(
+            async (token) =>
+            {
+                var r = await client.GetAsync(GetUri("/weatherforecast/"), token);
+                return r;
+            },
+            cancellationToken: default);
+
+        var t2 = pipeline.ExecuteAsync(
+            async (token) =>
+            {
+                var r = await client.GetAsync(GetUri("/weatherforecast/"), token);
+                return r;
+            },
+            cancellationToken: default);
+
+        var result = await Task.WhenAll(t1.AsTask(), t2.AsTask());
+
+        Console.WriteLine(result[0]);
+    }
+
     #endregion
 
 }

src/plugins/ConsolePollyTest/Program.cs

@@ -8,7 +8,10 @@ internal static class Program
     private static async Task Main(string[] args)
     {
         //await PollyTest.NoStrategy_TestAsync();
-        await PollyTest.Retry_ExecThree_TestAsync();
+
+        //await PollyTest.Retry_ExecThree_TestAsync();
+
+        await PollyTest.Retry_UseSamePipeline_TestAsync();
 
         _ = Console.ReadKey();
     }