Add byte rate metrics

AerospikeClient/Async/AsyncConnectionArgs.cs

@@ -131,6 +131,8 @@ private void SendEvent(SocketAsyncEventArgs args)
 					return;
 				}
 
+				node.IncrBytesSent(sent);
+
 				if (sent < args.Count)
 				{
 					args.SetBuffer(args.Offset + sent, args.Count - sent);
@@ -172,6 +174,8 @@ private void ReceiveEvent(SocketAsyncEventArgs args)
 					return;
 				}
 
+				node.IncrBytesReceived(received);
+
 				if (received < args.Count)
 				{
 					args.SetBuffer(args.Offset + received, args.Count - received);

AerospikeClient/Async/AsyncNode.cs

@@ -26,6 +26,8 @@ public sealed class AsyncNode : Node
 		private readonly new AsyncCluster cluster;
 		private int asyncConnsOpened;
 		private int asyncConnsClosed;
+		private long bytesReceived;
+		private long bytesSent;
 
 		/// <summary>
 		/// Initialize server node with connection parameters.
@@ -196,6 +198,16 @@ internal void IncrAsyncConnClosed()
 			Interlocked.Increment(ref asyncConnsClosed);
 		}
 
+		public void IncrBytesReceived(long bytesReceived)
+		{
+			Interlocked.Add(ref this.bytesReceived, bytesReceived);
+		}
+
+		public void IncrBytesSent(long bytesSent)
+		{
+			Interlocked.Add(ref this.bytesSent, bytesSent);
+		}
+
 		public ConnectionStats GetAsyncConnectionStats()
 		{
 			int inPool = asyncConnQueue.Count;
@@ -206,7 +218,7 @@ public ConnectionStats GetAsyncConnectionStats()
 			{
 				inUse = 0;
 			}
-			return new ConnectionStats(inPool, inUse, asyncConnsOpened, asyncConnsClosed);
+			return new ConnectionStats(inPool, inUse, asyncConnsOpened, asyncConnsClosed, bytesReceived, bytesSent);
 		}
 	}
 }

AerospikeClient/Cluster/ClusterStats.cs

@@ -122,7 +122,7 @@ public NodeStats(Node node)
 			}
 			else
 			{
-				this.asyncStats = new ConnectionStats(0, 0, 0, 0);
+				this.asyncStats = new ConnectionStats(0, 0, 0, 0, 0, 0);
 			}
 		}
 
@@ -159,24 +159,36 @@ public sealed class ConnectionStats
 		/// Total number of node connections closed since node creation.
 		/// </summary>
 		public readonly int closed;
-
+
+		/// <summary>
+		/// Total number of bytes received from that connection.
+		/// </summary>
+		public readonly long bytesReceived;
+
+		/// <summary>
+		/// Total number of bytes sent to that connection.
+		/// </summary>
+		public readonly long bytesSent;
+
 		/// <summary>
 		/// Connection statistics constructor.
 		/// </summary>
-		public ConnectionStats(int inPool, int inUse, int opened, int closed)
+		public ConnectionStats(int inPool, int inUse, int opened, int closed, long bytesReceived, long bytesSent)
 		{
 			this.inPool = inPool;
 			this.inUse = inUse;
 			this.opened = opened;
 			this.closed = closed;
+			this.bytesReceived = bytesReceived;
+			this.bytesSent = bytesSent;
 		}
 
 		/// <summary>
 		/// Convert statistics to string.
 		/// </summary>
 		public override string ToString()
 		{
-			return "" + inUse + ',' + inPool + ',' + opened + ',' + closed;
+			return "" + inUse + ',' + inPool + ',' + opened + ',' + closed + ',' + bytesReceived + ',' + bytesSent;
 		}
 	}
 }

AerospikeClient/Cluster/Node.cs

@@ -831,7 +831,7 @@ public ConnectionStats GetConnectionStats()
 				}
 				inUse += tmp;
 			}
-			return new ConnectionStats(inPool, inUse, connsOpened, connsClosed);
+			return new ConnectionStats(inPool, inUse, connsOpened, connsClosed, -1, -1);
 		}
 
 		public void IncrErrorCount()