diff options
| author | Erik Johnston <erik@matrix.org> | 2018-04-11 11:07:51 +0100 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2018-04-11 12:13:40 +0100 |
| commit | 92e34615c5c9ed5df2b0072a2686d3e42239e420 (patch) | |
| tree | 53fe39bfa8245da8fa1e73690ac18a4fab9c28e7 /synapse/storage/events.py | |
| parent | Add GaugeMetric (diff) | |
| download | synapse-92e34615c5c9ed5df2b0072a2686d3e42239e420.tar.xz | |
Track where event stream processing have gotten up to
Diffstat (limited to '')
| -rw-r--r-- | synapse/storage/events.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/synapse/storage/events.py b/synapse/storage/events.py index ece5e6c41f..da44b52fd6 100644 --- a/synapse/storage/events.py +++ b/synapse/storage/events.py @@ -444,6 +444,9 @@ class EventsStore(EventsWorkerStore): new_forward_extremeties=new_forward_extremeties, ) persist_event_counter.inc_by(len(chunk)) + synapse.metrics.event_persisted_position.set( + chunk[-1][0].internal_metadata.stream_ordering, + ) for event, context in chunk: if context.app_service: origin_type = "local" |