Add tracing instrumentation

AerospikeClient/Async/AsyncCommand.cs

@@ -54,7 +54,8 @@ public abstract class AsyncCommand : Command, IAsyncCommand, ITimeout
 		private bool compressed;
 		private bool inAuthenticate;
 		private bool inHeader = true;
-
+		private Activity activity;
+
 		/// <summary>
 		/// Default Constructor.
 		/// </summary>
@@ -203,14 +204,25 @@ private void ExecuteCore()
 			}
 			ExecuteCommand();
 		}
-
+		
 		private void ExecuteCommand()
 		{
 			iteration++;
+
+			Exception exception = null;
+
+			StartActivity();
 
 			try
 			{
 				node = (AsyncNode)GetNode(cluster);
+
+				if (activity != null)
+				{
+					activity.SetTag("node.name", node.Name);
+					activity.SetTag("node.address", node.NodeAddress.ToString());
+				}
+
 				node.ValidateErrorCount();
 				conn = node.GetAsyncConnection();
 
@@ -229,29 +241,60 @@ private void ExecuteCommand()
 			}
 			catch (AerospikeException.Connection aec)
 			{
+				exception = aec;
 				ErrorCount++;
 				ConnectionFailed(aec);
 			}
 			catch (AerospikeException.Backoff aeb)
 			{
+				exception = aeb;
 				ErrorCount++;
 				Backoff(aeb);
 			}
 			catch (AerospikeException ae)
 			{
+				exception = ae;
 				ErrorCount++;
 				FailOnApplicationError(ae);
 			}
 			catch (SocketException se)
 			{
+				exception = se;
 				ErrorCount++;
 				OnSocketError(se.SocketErrorCode);
 			}
 			catch (Exception e)
 			{
+				exception = e;
 				ErrorCount++;
 				FailOnApplicationError(new AerospikeException(e));
 			}
+			finally
+			{
+				if (activity != null && exception != null)
+				{
+					activity.SetStatus(ActivityStatusCode.Error, exception.ToString());
+				}
+			}
+		}
+
+		private void StartActivity()
+		{
+			// Because of the retry mecanism, one operation can result in several I/Os, on several nodes.
+			// For this reason, we create a new Activity on every retry, so that we can set the actual node
+			// adress and the I/O status as tags of this current Activity.
+
+			// If we're retrying, stop the previous Activity before restarting a new one.
+			activity?.Dispose();
+			activity = Tracing.Source.StartActivity(GetType().Name, ActivityKind.Client);
+			if (activity != null)
+			{
+				// https://github.com/open-telemetry/opentelemetry-specification/blob/6ce62202e5407518e19c56c445c13682ef51a51d/specification/trace/semantic_conventions/span-general.md#general-remote-service-attributes
+				activity.SetTag("peer.service", Tracing.SERVICE_NAME);
+				// https://github.com/open-telemetry/opentelemetry-specification/blob/6ce62202e5407518e19c56c445c13682ef51a51d/specification/trace/semantic_conventions/database.md#connection-level-attributes
+				activity.SetTag("db.system", Tracing.SERVICE_NAME);
+				activity.SetTag("iteration", iteration);
+			}
 		}
 
 		public void OnConnected()

AerospikeClient/Util/Tracing.cs

@@ -0,0 +1,17 @@
+#if NET6_0_OR_GREATER
+
+using System.Diagnostics;
+
+namespace Aerospike.Client
+{
+    public class Tracing
+    {
+        private const string SOURCE_NAME = "Aerospike.Client";
+
+        internal const string SERVICE_NAME = "Aerospike";
+
+        internal static readonly ActivitySource Source = new ActivitySource(SOURCE_NAME);
+    }
+}
+
+#endif