chore: name variable according to project convention

Author: aygalinc

RabbitMQ.AMQP.Client/Impl/MetricsReporter.cs

@@ -15,13 +15,11 @@ internal sealed class MetricsReporter : IMetricsReporter
     {
         const string Version = "0.1.0";
 
-        static readonly Meter Meter;
+        static readonly Counter<int> s_messagingClientSentMessages;
+        static readonly Histogram<double> s_messagingClientOperationDuration;
 
-        static readonly Counter<int> MessagingClientSentMessages;
-        static readonly Histogram<double> MessagingClientOperationDuration;
-
-        static readonly Counter<int> MessagingClientConsumedMessages;
-        static readonly Histogram<double> MessagingProcessDuration;
+        static readonly Counter<int> s_messagingClientConsumedMessages;
+        static readonly Histogram<double> s_messagingProcessDuration;
 
         readonly KeyValuePair<string, object?>
             _messagingOperationSystemTag = new(MessagingSystem, MessagingSystemValue);
@@ -48,27 +46,27 @@ internal sealed class MetricsReporter : IMetricsReporter
 
         static MetricsReporter()
         {
-            Meter = new("RabbitMQ.Amqp", Version);
+            Meter meter = new("RabbitMQ.Amqp", Version);
 
-            MessagingClientSentMessages = Meter.CreateCounter<int>(
+            s_messagingClientSentMessages = meter.CreateCounter<int>(
                 "messaging.client.sent.messages",
                 unit: "{message}",
                 description:
                 "Number of messages producer attempted to send to the broker.");
 
-            MessagingClientOperationDuration = Meter.CreateHistogram<double>(
+            s_messagingClientOperationDuration = meter.CreateHistogram<double>(
                 "messaging.client.operation.duration",
                 unit: "s",
                 description:
                 "Duration of messaging operation initiated by a producer or consumer client.");
 
-            MessagingClientConsumedMessages = Meter.CreateCounter<int>(
+            s_messagingClientConsumedMessages = meter.CreateCounter<int>(
                 "messaging.client.consumed.messages",
                 unit: "{message}",
                 description:
                 "Number of messages that were delivered to the application. ");
 
-            MessagingProcessDuration = Meter.CreateHistogram<double>(
+            s_messagingProcessDuration = meter.CreateHistogram<double>(
                 "messaging.process.duration",
                 unit: "s",
                 description:
@@ -81,17 +79,17 @@ public void ReportMessageSendSuccess(IMetricsReporter.PublisherContext context,
             var serverPort = new KeyValuePair<string, object?>(ServerPort, context.ServerPort);
             var destination = new KeyValuePair<string, object?>(MessageDestinationName, context.Destination);
 
-            MessagingClientSentMessages.Add(1, serverAddress, serverPort, destination, _messagingOperationSystemTag,
+            s_messagingClientSentMessages.Add(1, serverAddress, serverPort, destination, _messagingOperationSystemTag,
                 _sendOperationType, _publishOperationName);
             if (startTimestamp > 0)
             {
 #if NET7_0_OR_GREATER
             var duration = Stopwatch.GetElapsedTime(startTimestamp);
 #else
                 var duration =
-                    new TimeSpan((long)((Stopwatch.GetTimestamp() - startTimestamp) * StopWatchTickFrequency));
+                    new TimeSpan((long)((Stopwatch.GetTimestamp() - startTimestamp) * s_stopWatchTickFrequency));
 #endif
-                MessagingClientOperationDuration.Record(duration.TotalSeconds, serverAddress, serverPort, destination,
+                s_messagingClientOperationDuration.Record(duration.TotalSeconds, serverAddress, serverPort, destination,
                     _messagingOperationSystemTag, _sendOperationType, _publishOperationName);
             }
         }
@@ -103,7 +101,7 @@ public void ReportMessageSendFailure(IMetricsReporter.PublisherContext context,
             var serverAddress = new KeyValuePair<string, object?>(ServerAddress, context.ServerAddress);
             var serverPort = new KeyValuePair<string, object?>(ServerPort, context.ServerPort);
             var destination = new KeyValuePair<string, object?>(MessageDestinationName, context.Destination);
-            MessagingClientSentMessages.Add(1, errorType, serverAddress, serverPort, destination,
+            s_messagingClientSentMessages.Add(1, errorType, serverAddress, serverPort, destination,
                 _messagingOperationSystemTag, _sendOperationType, _publishOperationName);
 
             if (startTimestamp > 0)
@@ -112,9 +110,9 @@ public void ReportMessageSendFailure(IMetricsReporter.PublisherContext context,
             var duration = Stopwatch.GetElapsedTime(startTimestamp);
 #else
                 var duration =
-                    new TimeSpan((long)((Stopwatch.GetTimestamp() - startTimestamp) * StopWatchTickFrequency));
+                    new TimeSpan((long)((Stopwatch.GetTimestamp() - startTimestamp) * s_stopWatchTickFrequency));
 #endif
-                MessagingClientOperationDuration.Record(duration.TotalSeconds, errorType, serverAddress, serverPort,
+                s_messagingClientOperationDuration.Record(duration.TotalSeconds, errorType, serverAddress, serverPort,
                     destination,
                     _messagingOperationSystemTag, _sendOperationType, _publishOperationName);
             }
@@ -125,17 +123,17 @@ public void ReportMessageDeliverSuccess(IMetricsReporter.ConsumerContext context
             var serverAddress = new KeyValuePair<string, object?>(ServerAddress, context.ServerAddress);
             var serverPort = new KeyValuePair<string, object?>(ServerPort, context.ServerPort);
             var destination = new KeyValuePair<string, object?>(MessageDestinationName, context.Destination);
-            MessagingClientConsumedMessages.Add(1, serverAddress, serverPort, destination, _messagingOperationSystemTag,
+            s_messagingClientConsumedMessages.Add(1, serverAddress, serverPort, destination, _messagingOperationSystemTag,
                 _processOperationType, _deliverOperationName);
             if (startTimestamp > 0)
             {
 #if NET7_0_OR_GREATER
             var duration = Stopwatch.GetElapsedTime(startTimestamp);
 #else
                 var duration =
-                    new TimeSpan((long)((Stopwatch.GetTimestamp() - startTimestamp) * StopWatchTickFrequency));
+                    new TimeSpan((long)((Stopwatch.GetTimestamp() - startTimestamp) * s_stopWatchTickFrequency));
 #endif
-                MessagingProcessDuration.Record(duration.TotalSeconds, serverAddress, serverPort,
+                s_messagingProcessDuration.Record(duration.TotalSeconds, serverAddress, serverPort,
                     destination,
                     _messagingOperationSystemTag, _sendOperationType, _publishOperationName);
             }
@@ -148,7 +146,7 @@ public void ReportMessageDeliverFailure(IMetricsReporter.ConsumerContext context
             var serverAddress = new KeyValuePair<string, object?>(ServerAddress, context.ServerAddress);
             var serverPort = new KeyValuePair<string, object?>(ServerPort, context.ServerPort);
             var destination = new KeyValuePair<string, object?>(MessageDestinationName, context.Destination);
-            MessagingClientConsumedMessages.Add(1, errorType, serverAddress, serverPort, destination,
+            s_messagingClientConsumedMessages.Add(1, errorType, serverAddress, serverPort, destination,
                 _messagingOperationSystemTag,
                 _processOperationType, _deliverOperationName);
             if (startTimestamp > 0)
@@ -157,9 +155,9 @@ public void ReportMessageDeliverFailure(IMetricsReporter.ConsumerContext context
             var duration = Stopwatch.GetElapsedTime(startTimestamp);
 #else
                 var duration =
-                    new TimeSpan((long)((Stopwatch.GetTimestamp() - startTimestamp) * StopWatchTickFrequency));
+                    new TimeSpan((long)((Stopwatch.GetTimestamp() - startTimestamp) * s_stopWatchTickFrequency));
 #endif
-                MessagingProcessDuration.Record(duration.TotalSeconds, errorType, serverAddress, serverPort,
+                s_messagingProcessDuration.Record(duration.TotalSeconds, errorType, serverAddress, serverPort,
                     destination,
                     _messagingOperationSystemTag, _sendOperationType, _publishOperationName);
             }
@@ -168,7 +166,7 @@ public void ReportMessageDeliverFailure(IMetricsReporter.ConsumerContext context
         const long TicksPerMicrosecond = 10;
         const long TicksPerMillisecond = TicksPerMicrosecond * 1000;
         const long TicksPerSecond = TicksPerMillisecond * 1000; // 10,000,000
-        static readonly double StopWatchTickFrequency = (double)TicksPerSecond / Stopwatch.Frequency;
+        static readonly double s_stopWatchTickFrequency = (double)TicksPerSecond / Stopwatch.Frequency;
 #endif
     }
 #else