summary refs log tree commit diff
path: root/synapse/storage/stream.py
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2019-03-06 19:30:30 +0000
committerErik Johnston <erik@matrix.org>2019-03-06 19:30:30 +0000
commit8f7dbbc14a1e8c7c7bc42afa17bc2f4d88ad3d10 (patch)
tree7f20429e4b25eda5c8dded42a1f0b6ff574b636a /synapse/storage/stream.py
parentReenable presence tests and remove pointless change (diff)
parentMerge pull request #4818 from matrix-org/erikj/prefill_client_ips (diff)
downloadsynapse-8f7dbbc14a1e8c7c7bc42afa17bc2f4d88ad3d10.tar.xz
Merge branch 'develop' of github.com:matrix-org/synapse into matrix-org-hotfixes
Diffstat (limited to 'synapse/storage/stream.py')
-rw-r--r--synapse/storage/stream.py16
1 files changed, 10 insertions, 6 deletions
diff --git a/synapse/storage/stream.py b/synapse/storage/stream.py

index b5aa849f4c..580fafeb3a 100644 --- a/synapse/storage/stream.py +++ b/synapse/storage/stream.py
@@ -191,14 +191,18 @@ class StreamWorkerStore(EventsWorkerStore, SQLBaseStore): @defer.inlineCallbacks def get_room_events_stream_for_rooms(self, room_ids, from_key, to_key, limit=0, order='DESC'): - """ + """Get new room events in stream ordering since `from_key`. Args: - room_ids: - from_key: - to_key: - limit: - order: + room_id (str) + from_key (str): Token from which no events are returned before + to_key (str): Token from which no events are returned after. (This + is typically the current stream token) + limit (int): Maximum number of events to return + order (str): Either "DESC" or "ASC". Determines which events are + returned when the result is limited. If "DESC" then the most + recent `limit` events are returned, otherwise returns the + oldest `limit` events. Returns: Deferred[dict[str,tuple[list[FrozenEvent], str]]]