diff --git a/receptor/protocol.py b/receptor/protocol.py index 4a166b04..71be5915 100644 --- a/receptor/protocol.py +++ b/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) diff --git a/receptor/stats.py b/receptor/stats.py index 9e795f6d..3f34ed8d 100644 --- a/receptor/stats.py +++ b/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")