diff options
| author | Richard van der Hoff <1389908+richvdh@users.noreply.github.com> | 2020-03-19 11:00:24 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-03-19 10:00:24 +0000 |
| commit | 8c75667ad7810b4c05e40f7665e724a40aaf4d64 (patch) | |
| tree | 151260d3d74a739c2d658df8d651e73a0a6ff06d /synapse/metrics/__init__.py | |
| parent | Move pusherpool startup into _base.setup (#7104) (diff) | |
| download | synapse-8c75667ad7810b4c05e40f7665e724a40aaf4d64.tar.xz | |
Add prometheus metrics for the number of active pushers (#7103)
Diffstat (limited to 'synapse/metrics/__init__.py')
| -rw-r--r-- | synapse/metrics/__init__.py | 12 |
1 files changed, 7 insertions, 5 deletions
diff --git a/synapse/metrics/__init__.py b/synapse/metrics/__init__.py index 0dba997a23..d2fd29acb4 100644 --- a/synapse/metrics/__init__.py +++ b/synapse/metrics/__init__.py @@ -20,7 +20,7 @@ import os import platform import threading import time -from typing import Dict, Union +from typing import Callable, Dict, Iterable, Optional, Tuple, Union import six @@ -59,10 +59,12 @@ class RegistryProxy(object): @attr.s(hash=True) class LaterGauge(object): - name = attr.ib() - desc = attr.ib() - labels = attr.ib(hash=False) - caller = attr.ib() + name = attr.ib(type=str) + desc = attr.ib(type=str) + labels = attr.ib(hash=False, type=Optional[Iterable[str]]) + # callback: should either return a value (if there are no labels for this metric), + # or dict mapping from a label tuple to a value + caller = attr.ib(type=Callable[[], Union[Dict[Tuple[str, ...], float], float]]) def collect(self): |