Add Telemetry

Author: jerviscui

src/plugins/ConsolePollyTest/ConsolePollyTest.csproj

@@ -8,6 +8,8 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="Microsoft.Extensions.Logging" Version="9.0.6" />
+    <PackageReference Include="Microsoft.Extensions.Logging.Console" Version="9.0.6" />
     <PackageReference Include="Polly.Core" Version="8.6.1" />
     <PackageReference Include="Polly.Extensions" Version="8.6.1" />
   </ItemGroup>

src/plugins/ConsolePollyTest/MyMeteringEnricher.cs

@@ -0,0 +1,11 @@
+using Polly.Telemetry;
+
+namespace ConsolePollyTest;
+
+internal sealed class MyMeteringEnricher : MeteringEnricher
+{
+    public override void Enrich<TResult, TArgs>(in EnrichmentContext<TResult, TArgs> context)
+    {
+        context.Tags.Add(new("my-custom-tag", "custom-value"));
+    }
+}

src/plugins/ConsolePollyTest/MyTelemetryListener.cs

@@ -0,0 +1,11 @@
+using Polly.Telemetry;
+
+namespace ConsolePollyTest;
+
+internal sealed class MyTelemetryListener : TelemetryListener
+{
+    public override void Write<TResult, TArgs>(in TelemetryEventArguments<TResult, TArgs> args)
+    {
+        Console.WriteLine($"Telemetry event occurred: {args.Event.EventName}");
+    }
+}

src/plugins/ConsolePollyTest/PollyTest.cs

@@ -1,5 +1,7 @@
+using Microsoft.Extensions.Logging;
 using Polly;
 using Polly.Retry;
+using Polly.Telemetry;
 
 namespace ConsolePollyTest;
 
@@ -21,6 +23,19 @@ private static Uri GetUri(string path)
         return new Uri(Host, path);
     }
 
+    private static TelemetryOptions GetTelemetry()
+    {
+        var telemetryOptions = new TelemetryOptions
+        {
+            // Configure logging
+            LoggerFactory = LoggerFactory.Create(builder => builder.AddConsole()),
+        };
+        telemetryOptions.TelemetryListeners.Add(new MyTelemetryListener());
+        telemetryOptions.MeteringEnrichers.Add(new MyMeteringEnricher());
+
+        return telemetryOptions;
+    }
+
     public static async Task NoStrategy_TestAsync()
     {
         var builder = new ResiliencePipelineBuilder();
@@ -41,17 +56,26 @@ public static async Task NoStrategy_TestAsync()
 
     public static async Task Retry_ExecThree_TestAsync()
     {
-        var builder = new ResiliencePipelineBuilder().AddRetry(
-            new RetryStrategyOptions
-            {
-                Delay = TimeSpan.FromSeconds(1),
-                MaxRetryAttempts = 2,
-                ShouldHandle = (args) =>
-                        {
-                            Console.WriteLine(args.AttemptNumber);
-                            return ValueTask.FromResult(args.AttemptNumber >= 0);
-                        }
-            });
+        var builder = new ResiliencePipelineBuilder().ConfigureTelemetry(GetTelemetry())
+            .AddRetry(
+                new RetryStrategyOptions
+                {
+                    Delay = TimeSpan.FromSeconds(1),
+                    //MaxDelay = 
+                    BackoffType = DelayBackoffType.Exponential,
+                    UseJitter = true,
+                    MaxRetryAttempts = 2,
+                    //DelayGenerator = (args) =>
+                    //        {
+                    //            return ValueTask.FromResult(
+                    //                (TimeSpan?)TimeSpan.FromSeconds(Math.Pow(2, args.AttemptNumber)));
+                    //        },
+                    ShouldHandle = (args) =>
+                            {
+                                Console.WriteLine(args.AttemptNumber);
+                                return ValueTask.FromResult(args.AttemptNumber >= 0);
+                            }
+                });
         var pipeline = builder.Build();
 
         using var client = GetClient();