gauge

Signed-off-by: Jesse Jaggars <jjaggars@redhat.com>

Author: jhjaggars

receptor/protocol.py

@@ -7,7 +7,7 @@
 import uuid
 
 from .messages import envelope
-from .stats import connected_peers_guage
+from .stats import connected_peers_gauge
 
 logger = logging.getLogger(__name__)
 
@@ -67,12 +67,12 @@ async def watch_queue(self):
     def connection_made(self, transport):
         self.peername = transport.get_extra_info('peername')
         self.transport = transport
-        connected_peers_guage.inc()
+        connected_peers_gauge.inc()
         self.incoming_buffer = DataBuffer(loop=self.loop)
         self.loop.create_task(self.wait_greeting())
 
     def connection_lost(self, exc):
-        connected_peers_guage.dec()
+        connected_peers_gauge.dec()
         self.receptor.remove_connection(self)
 
     def data_received(self, data):
@@ -163,12 +163,12 @@ def __init__(self, receptor, loop):
 
     def connection_made(self, transport):
         self.transport = transport
-        connected_peers_guage.inc()
+        connected_peers_gauge.inc()
         if self not in self.receptor.controller_connections:
             self.receptor.controller_connections.append(self)
 
     def connection_lost(self, exc):
-        connected_peers_guage.dec()
+        connected_peers_gauge.dec()
         if self in self.receptor.controller_connections:
             self.receptor.controller_connections.remove(self)
 

receptor/stats.py

@@ -1,7 +1,7 @@
 from prometheus_client import Counter, Gauge
 
 messages_received_counter = Counter("incoming_messages", "Messages received from Receptor Peers")
-connected_peers_guage = Gauge("connected_peers", "Number of active peer connections")
+connected_peers_gauge = Gauge("connected_peers", "Number of active peer connections")
 work_counter = Counter("work_events", "A count of the number of work events that have been received")
 active_work_gauge = Gauge("active_work", "Amount of work currently being performed")
 route_counter = Counter("route_events", "A count of the number of messages that have been routed elsewhere in the mesh")