diff options
| author | Mark Haines <mark.haines@matrix.org> | 2016-03-02 17:26:20 +0000 |
|---|---|---|
| committer | Mark Haines <mark.haines@matrix.org> | 2016-03-02 17:26:20 +0000 |
| commit | 2223204ebaf7624f4d640f2c56d3a4eb7ff6d98e (patch) | |
| tree | 764f70995e5d2cd7968560cd7e8bce19c038d0dd /synapse/storage/push_rule.py | |
| parent | Add a stream for push rule updates (diff) | |
| download | synapse-2223204ebaf7624f4d640f2c56d3a4eb7ff6d98e.tar.xz | |
Hook push rules up to the replication API
Diffstat (limited to 'synapse/storage/push_rule.py')
| -rw-r--r-- | synapse/storage/push_rule.py | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/synapse/storage/push_rule.py b/synapse/storage/push_rule.py index f3ebd49492..e034024108 100644 --- a/synapse/storage/push_rule.py +++ b/synapse/storage/push_rule.py @@ -412,6 +412,12 @@ class PushRuleStore(SQLBaseStore): "get_all_push_rule_updates", get_all_push_rule_updates_txn ) + def get_push_rules_stream_token(self): + """Get the position of the push rules stream. + Returns a pair of a stream id for the push_rules stream and the + room stream ordering it corresponds to.""" + return self._push_rules_stream_id_gen.get_max_token() + class RuleNotFoundException(Exception): pass |