From 82a92ba535b424009ef752add2e0d5e198254e04 Mon Sep 17 00:00:00 2001
From: Andrew Morgan <andrew@amorgan.xyz>
Date: Wed, 23 Jan 2019 15:01:09 +0000
Subject: [PATCH 1/2] Add metric for user dir current event stream position

---
 synapse/handlers/user_directory.py | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/synapse/handlers/user_directory.py b/synapse/handlers/user_directory.py
index 3c409993383a..120815b09b91 100644
--- a/synapse/handlers/user_directory.py
+++ b/synapse/handlers/user_directory.py
@@ -19,6 +19,7 @@
 
 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 @@ def _unsafe_process(self):
                 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

From cb0e637a94c23b246c2297f52833b5c776675f78 Mon Sep 17 00:00:00 2001
From: Andrew Morgan <andrew@amorgan.xyz>
Date: Wed, 23 Jan 2019 15:38:27 +0000
Subject: [PATCH 2/2] Add changelog

---
 changelog.d/4445.feature | 1 +
 1 file changed, 1 insertion(+)
 create mode 100644 changelog.d/4445.feature

diff --git a/changelog.d/4445.feature b/changelog.d/4445.feature
new file mode 100644
index 000000000000..a6f9b7bbac1b
--- /dev/null
+++ b/changelog.d/4445.feature
@@ -0,0 +1 @@
+Add a metric for tracking event stream position of the user directory.
\ No newline at end of file