diff options
| author | Erik Johnston <erik@matrix.org> | 2020-04-01 10:40:46 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-04-01 10:40:46 +0100 |
| commit | dfa07822542da96b93ef9d871d43bf1a36dc4664 (patch) | |
| tree | 14beecda2571cd5763877923c89b51ea6f64624d | |
| parent | Improve TURN documentation. (#7167) (diff) | |
| download | synapse-dfa07822542da96b93ef9d871d43bf1a36dc4664.tar.xz | |
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.
| -rw-r--r-- | changelog.d/7195.misc | 1 | ||||
| -rw-r--r-- | synapse/replication/tcp/resource.py | 16 |
2 files changed, 1 insertions, 16 deletions
diff --git a/changelog.d/7195.misc b/changelog.d/7195.misc new file mode 100644 index 0000000000..676f285377 --- /dev/null +++ b/changelog.d/7195.misc @@ -0,0 +1 @@ +Move catchup of replication streams logic to worker. diff --git a/synapse/replication/tcp/resource.py b/synapse/replication/tcp/resource.py index 8b6067e20d..30021ee309 100644 --- a/synapse/replication/tcp/resource.py +++ b/synapse/replication/tcp/resource.py @@ -99,22 +99,6 @@ class ReplicationStreamer(object): self.streams_by_name = {stream.NAME: stream for stream in self.streams} - LaterGauge( - "synapse_replication_tcp_resource_connections_per_stream", - "", - ["stream_name"], - lambda: { - (stream_name,): len( - [ - conn - for conn in self.connections - if stream_name in conn.replication_streams - ] - ) - for stream_name in self.streams_by_name - }, - ) - self.federation_sender = None if not hs.config.send_federation: self.federation_sender = hs.get_federation_sender() |