diff options
| author | Amber Brown <hawkowl@atleastfornow.net> | 2018-06-21 09:39:58 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-06-21 09:39:58 +0100 |
| commit | c2eff937ac357a46a176e2b6552a853fab85ee9c (patch) | |
| tree | 421d0a759530d5c1d2e6ab88b90e02e98db289ca /synapse/federation/transaction_queue.py | |
| parent | Fix tcp protocol metrics naming (#3410) (diff) | |
| download | synapse-c2eff937ac357a46a176e2b6552a853fab85ee9c.tar.xz | |
Populate synapse_federation_client_sent_pdu_destinations:count again (#3386)
Diffstat (limited to 'synapse/federation/transaction_queue.py')
| -rw-r--r-- | synapse/federation/transaction_queue.py | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/synapse/federation/transaction_queue.py b/synapse/federation/transaction_queue.py index bcbce7f6eb..d72b057e28 100644 --- a/synapse/federation/transaction_queue.py +++ b/synapse/federation/transaction_queue.py @@ -41,8 +41,11 @@ import logging logger = logging.getLogger(__name__) -sent_pdus_destination_dist = Counter( - "synapse_federation_transaction_queue_sent_pdu_destinations", "" +sent_pdus_destination_dist_count = Counter( + "synapse_federation_client_sent_pdu_destinations:count", "" +) +sent_pdus_destination_dist_total = Counter( + "synapse_federation_client_sent_pdu_destinations:total", "" ) @@ -279,7 +282,8 @@ class TransactionQueue(object): if not destinations: return - sent_pdus_destination_dist.inc(len(destinations)) + sent_pdus_destination_dist_total.inc(len(destinations)) + sent_pdus_destination_dist_count.inc() for destination in destinations: self.pending_pdus_by_dest.setdefault(destination, []).append( |