diff options
| author | Erik Johnston <erik@matrix.org> | 2019-05-16 16:54:05 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-05-16 16:54:05 +0100 |
| commit | 5c39d262c048ecb9f7d6aacc10fa26ffef8c32df (patch) | |
| tree | b4584277b4404429f290824e37f8807d772cc0b3 /synapse/replication/tcp | |
| parent | Merge pull request #5186 from matrix-org/erikj/simple_pagination (diff) | |
| parent | Move parsing of tokens out of storage layer (diff) | |
| download | synapse-5c39d262c048ecb9f7d6aacc10fa26ffef8c32df.tar.xz | |
Merge pull request #5192 from matrix-org/erikj/relations_aggregations
Add relation aggregation APIs
Diffstat (limited to 'synapse/replication/tcp')
| -rw-r--r-- | synapse/replication/tcp/streams/_base.py | 1 | ||||
| -rw-r--r-- | synapse/replication/tcp/streams/events.py | 11 |
2 files changed, 7 insertions, 5 deletions
diff --git a/synapse/replication/tcp/streams/_base.py b/synapse/replication/tcp/streams/_base.py index 8971a6a22e..b6ce7a7bee 100644 --- a/synapse/replication/tcp/streams/_base.py +++ b/synapse/replication/tcp/streams/_base.py @@ -32,6 +32,7 @@ BackfillStreamRow = namedtuple("BackfillStreamRow", ( "type", # str "state_key", # str, optional "redacts", # str, optional + "relates_to", # str, optional )) PresenceStreamRow = namedtuple("PresenceStreamRow", ( "user_id", # str diff --git a/synapse/replication/tcp/streams/events.py b/synapse/replication/tcp/streams/events.py index e0f6e29248..f1290d022a 100644 --- a/synapse/replication/tcp/streams/events.py +++ b/synapse/replication/tcp/streams/events.py @@ -80,11 +80,12 @@ class BaseEventsStreamRow(object): class EventsStreamEventRow(BaseEventsStreamRow): TypeId = "ev" - event_id = attr.ib() # str - room_id = attr.ib() # str - type = attr.ib() # str - state_key = attr.ib() # str, optional - redacts = attr.ib() # str, optional + event_id = attr.ib() # str + room_id = attr.ib() # str + type = attr.ib() # str + state_key = attr.ib() # str, optional + redacts = attr.ib() # str, optional + relates_to = attr.ib() # str, optional @attr.s(slots=True, frozen=True) |