summary refs log tree commit diff
path: root/synapse
diff options
context:
space:
mode:
authorAndrew Morgan <1342360+anoadragon453@users.noreply.github.com>2019-01-23 15:58:40 +0000
committerGitHub <noreply@github.com>2019-01-23 15:58:40 +0000
commit6b90ae6efc9d18c9125601d9f2b79558d332235e (patch)
tree8c507df1a8840cc7e2244f2abe33a71946cb7ffd /synapse
parentMerge pull request #4428 from matrix-org/rav/matrix_federation_agent (diff)
parentAdd changelog (diff)
downloadsynapse-6b90ae6efc9d18c9125601d9f2b79558d332235e.tar.xz
Merge pull request #4445 from matrix-org/anoa/user_dir_develop_backport
Add metric for user dir current event stream position
Diffstat (limited to 'synapse')
-rw-r--r--synapse/handlers/user_directory.py6
1 files changed, 6 insertions, 0 deletions
diff --git a/synapse/handlers/user_directory.py b/synapse/handlers/user_directory.py
index 3c40999338..120815b09b 100644
--- a/synapse/handlers/user_directory.py
+++ b/synapse/handlers/user_directory.py
@@ -19,6 +19,7 @@ from six import iteritems
 
 from twisted.internet import defer
 
+import synapse.metrics
 from synapse.api.constants import EventTypes, JoinRules, Membership
 from synapse.metrics.background_process_metrics import run_as_background_process
 from synapse.storage.roommember import ProfileInfo
@@ -163,6 +164,11 @@ class UserDirectoryHandler(object):
                 yield self._handle_deltas(deltas)
 
                 self.pos = deltas[-1]["stream_id"]
+
+                # Expose current event processing position to prometheus
+                synapse.metrics.event_processing_positions.labels(
+                    "user_dir").set(self.pos)
+
                 yield self.store.update_user_directory_stream_pos(self.pos)
 
     @defer.inlineCallbacks