[Internal] OpenTelemetry: Direct Package update and replacing diagnostic files

Directory.Build.props

@@ -3,7 +3,7 @@
 		<ClientOfficialVersion>3.32.3</ClientOfficialVersion>
 		<ClientPreviewVersion>3.32.3</ClientPreviewVersion>
 		<ClientPreviewSuffixVersion>preview</ClientPreviewSuffixVersion>
-		<DirectVersion>3.30.4</DirectVersion>
+		<DirectVersion>3.30.6</DirectVersion>
 		<EncryptionOfficialVersion>2.0.1</EncryptionOfficialVersion>
 		<EncryptionPreviewVersion>2.0.1</EncryptionPreviewVersion>
 		<EncryptionPreviewSuffixVersion>preview</EncryptionPreviewSuffixVersion>

Microsoft.Azure.Cosmos/src/ChangeFeedProcessor/Exceptions/ChangeFeedProcessorUserException.cs

@@ -6,7 +6,7 @@ namespace Microsoft.Azure.Cosmos
 {
     using System;
     using System.Runtime.Serialization;
-    using global::Azure.Core.Pipeline;
+    using global::Azure.Core;
     using Microsoft.Azure.Cosmos.Telemetry;
     using Microsoft.Azure.Cosmos.Telemetry.Diagnostics;
 

Microsoft.Azure.Cosmos/src/DocumentClient.cs

@@ -167,6 +167,9 @@ internal partial class DocumentClient : IDisposable, IAuthorizationTokenProvider
         //RemoteCertificateValidationCallback
         internal RemoteCertificateValidationCallback remoteCertificateValidationCallback;
 
+        //Distributed Tracing Flag
+        internal bool isDistributedTracingEnabled;
+
         //SessionContainer.
         internal ISessionContainer sessionContainer;
 
@@ -426,6 +429,7 @@ internal DocumentClient(Uri serviceEndpoint,
         /// <param name="isLocalQuorumConsistency">Flag to allow Quorum Read with Eventual Consistency Account</param>
         /// <param name="cosmosClientId"></param>
         /// <param name="remoteCertificateValidationCallback">This delegate responsible for validating the third party certificate. </param>
+        /// <param name="isDistributedTracingEnabled">This is distributed tracing flag</param>
         /// <remarks>
         /// The service endpoint can be obtained from the Azure Management Portal.
         /// If you are connecting using one of the Master Keys, these can be obtained along with the endpoint from the Azure Management Portal
@@ -452,7 +456,8 @@ internal DocumentClient(Uri serviceEndpoint,
                               IStoreClientFactory storeClientFactory = null,
                               bool isLocalQuorumConsistency = false,
                               string cosmosClientId = null,
-                              RemoteCertificateValidationCallback remoteCertificateValidationCallback = null)
+                              RemoteCertificateValidationCallback remoteCertificateValidationCallback = null,
+                              bool isDistributedTracingEnabled = false)
         {
             if (sendingRequestEventArgs != null)
             {
@@ -485,7 +490,8 @@ internal DocumentClient(Uri serviceEndpoint,
                 enableCpuMonitor: enableCpuMonitor,
                 storeClientFactory: storeClientFactory,
                 cosmosClientId: cosmosClientId,
-                remoteCertificateValidationCallback: remoteCertificateValidationCallback);
+                remoteCertificateValidationCallback: remoteCertificateValidationCallback,
+                isDistributedTracingEnabled: isDistributedTracingEnabled);
         }
 
         /// <summary>
@@ -668,7 +674,8 @@ internal virtual void Initialize(Uri serviceEndpoint,
             IStoreClientFactory storeClientFactory = null,
             TokenCredential tokenCredential = null,
             string cosmosClientId = null,
-            RemoteCertificateValidationCallback remoteCertificateValidationCallback = null)
+            RemoteCertificateValidationCallback remoteCertificateValidationCallback = null,
+            bool isDistributedTracingEnabled = false)
         {
             if (serviceEndpoint == null)
             {
@@ -677,6 +684,7 @@ internal virtual void Initialize(Uri serviceEndpoint,
 
             this.clientId = cosmosClientId;
             this.remoteCertificateValidationCallback = remoteCertificateValidationCallback;
+            this.isDistributedTracingEnabled = isDistributedTracingEnabled;
 
             this.queryPartitionProvider = new AsyncLazy<QueryPartitionProvider>(async () =>
             {
@@ -6658,7 +6666,8 @@ private void InitializeDirectConnectivity(IStoreClientFactory storeClientFactory
                     enableTcpConnectionEndpointRediscovery: this.ConnectionPolicy.EnableTcpConnectionEndpointRediscovery,
                     addressResolver: this.AddressResolver,
                     rntbdMaxConcurrentOpeningConnectionCount: this.rntbdMaxConcurrentOpeningConnectionCount,
-                    remoteCertificateValidationCallback: this.remoteCertificateValidationCallback );
+                    remoteCertificateValidationCallback: this.remoteCertificateValidationCallback,
+                    isDistributedTracingEnabled: this.isDistributedTracingEnabled);
 
                 if (this.transportClientHandlerFactory != null)
                 {