Skip to content
This repository was archived by the owner on Apr 26, 2024. It is now read-only.

Commit dfa0782

Browse files
authored
Remove connections per replication stream metric. (#7195)
This broke in a recent PR (#7024) and is no longer useful due to all replication clients implicitly subscribing to all streams, so let's just remove it.
1 parent 2e826cd commit dfa0782

File tree

2 files changed

+1
-16
lines changed

2 files changed

+1
-16
lines changed

changelog.d/7195.misc

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
Move catchup of replication streams logic to worker.

synapse/replication/tcp/resource.py

Lines changed: 0 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -99,22 +99,6 @@ def __init__(self, hs):
9999

100100
self.streams_by_name = {stream.NAME: stream for stream in self.streams}
101101

102-
LaterGauge(
103-
"synapse_replication_tcp_resource_connections_per_stream",
104-
"",
105-
["stream_name"],
106-
lambda: {
107-
(stream_name,): len(
108-
[
109-
conn
110-
for conn in self.connections
111-
if stream_name in conn.replication_streams
112-
]
113-
)
114-
for stream_name in self.streams_by_name
115-
},
116-
)
117-
118102
self.federation_sender = None
119103
if not hs.config.send_federation:
120104
self.federation_sender = hs.get_federation_sender()

0 commit comments

Comments
 (0)