add activity source

Author: zhiyuanliang-ms

src/Microsoft.Extensions.Configuration.AzureAppConfiguration/AzureAppConfigurationOptions.cs

@@ -50,6 +50,11 @@ public class AzureAppConfigurationOptions
         /// </summary>
         public bool LoadBalancingEnabled { get; set; }
 
+        /// <summary>
+        /// An optional timespan value to set the minimum backoff duration to a value other than the default.
+        /// </summary>
+        public TimeSpan MinBackoffDuration { get; set; } = FailOverConstants.MinBackoffDuration;
+
         /// <summary>
         /// The list of connection strings used to connect to an Azure App Configuration store and its replicas.
         /// </summary>
@@ -121,11 +126,6 @@ internal IEnumerable<IKeyValueAdapter> Adapters
         /// </summary>
         internal IConfigurationSettingPageIterator ConfigurationSettingPageIterator { get; set; }
 
-        /// <summary>
-        /// An optional timespan value to set the minimum backoff duration to a value other than the default.
-        /// </summary>
-        internal TimeSpan MinBackoffDuration { get; set; } = FailOverConstants.MinBackoffDuration;
-
         /// <summary>
         /// Options used to configure the client used to communicate with Azure App Configuration.
         /// </summary>

src/Microsoft.Extensions.Configuration.AzureAppConfiguration/AzureAppConfigurationProvider.cs

@@ -58,6 +58,14 @@ private class ConfigurationClientBackoffStatus
             public DateTimeOffset BackoffEndTime { get; set; }
         }
 
+        private readonly ActivityListener _activityListener = new ActivityListener
+        {
+            ShouldListenTo = (activitySource) => activitySource.Name == RequestTracingConstants.AzureAppConfigurationActivitySource,
+            Sample = (ref ActivityCreationOptions<ActivityContext> options) => ActivitySamplingResult.AllData
+        };
+
+        public static readonly ActivitySource ActivitySource = new ActivitySource(RequestTracingConstants.AzureAppConfigurationActivitySource);
+
         public DateTimeOffset? LastSuccessfulAttempt { get; private set; } = null;
         public DateTimeOffset? LastFailedAttempt { get; private set; } = null;
 
@@ -156,6 +164,8 @@ public AzureAppConfigurationProvider(IConfigurationClientManager configClientMan
             {
                 SetRequestTracingOptions();
             }
+
+            ActivitySource.AddActivityListener(_activityListener);
         }
 
         /// <summary>
@@ -1412,6 +1422,7 @@ private async Task ProcessKeyValueChangesAsync(
         public void Dispose()
         {
             (_configClientManager as ConfigurationClientManager)?.Dispose();
+            _activityListener.Dispose();
         }
     }
 }

src/Microsoft.Extensions.Configuration.AzureAppConfiguration/Constants/RequestTracingConstants.cs

@@ -45,6 +45,7 @@ internal class RequestTracingConstants
         public const string FeatureFlagUsesSeedTag = "Seed";
         public const string FeatureFlagMaxVariantsKey = "MaxVariants";
 
+        public const string AzureAppConfigurationActivitySource = "Microsoft.Extensions.Configuration.AzureAppConfiguration";
         public const string DiagnosticHeaderActivityName = "Azure.CustomDiagnosticHeaders";
         public const string CorrelationContextHeader = "Correlation-Context";
         public const string UserAgentHeader = "User-Agent";

src/Microsoft.Extensions.Configuration.AzureAppConfiguration/TracingUtils.cs

@@ -116,10 +116,7 @@ public static async Task CallWithRequestTracing(bool tracingEnabled, RequestType
                 correlationContextHeader = CreateCorrelationContextHeader(requestType, requestTracingOptions);
             }
 
-            var activity = new Activity(RequestTracingConstants.DiagnosticHeaderActivityName);
-            activity.Start();
-
-            try
+            using (var activity = AzureAppConfigurationProvider.ActivitySource.StartActivity(RequestTracingConstants.DiagnosticHeaderActivityName))
             {
                 if (!string.IsNullOrWhiteSpace(correlationContextHeader))
                 {
@@ -128,10 +125,6 @@ public static async Task CallWithRequestTracing(bool tracingEnabled, RequestType
 
                 await clientCall().ConfigureAwait(false);
             }
-            finally
-            {
-                activity.Stop();
-            }
         }
 
         private static string CreateCorrelationContextHeader(RequestType requestType, RequestTracingOptions requestTracingOptions)