summary refs log tree commit diff
path: root/synapse/replication/tcp
diff options
context:
space:
mode:
authorErik Johnston <erikj@jki.re>2017-04-10 13:09:25 +0100
committerGitHub <noreply@github.com>2017-04-10 13:09:25 +0100
commitefcb6db6883b9036f131c6fcec09e9f1b7464a37 (patch)
tree11e892a4a9d6c161e50b9fadceddc4da934db979 /synapse/replication/tcp
parentUp replication ping timeout (diff)
parentRename variable (diff)
downloadsynapse-efcb6db6883b9036f131c6fcec09e9f1b7464a37.tar.xz
Merge pull request #2109 from matrix-org/erikj/send_queue_fix
Fix up federation SendQueue and document types
Diffstat (limited to 'synapse/replication/tcp')
-rw-r--r--synapse/replication/tcp/streams.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/replication/tcp/streams.py b/synapse/replication/tcp/streams.py
index 967b459e0e..369d5f2428 100644
--- a/synapse/replication/tcp/streams.py
+++ b/synapse/replication/tcp/streams.py
@@ -98,8 +98,8 @@ ToDeviceStreamRow = namedtuple("ToDeviceStreamRow", (
     "entity",  # str
 ))
 FederationStreamRow = namedtuple("FederationStreamRow", (
-    "type",  # str
-    "data",  # dict
+    "type",  # str, the type of data as defined in the BaseFederationRows
+    "data",  # dict, serialization of a federation.send_queue.BaseFederationRow
 ))
 TagAccountDataStreamRow = namedtuple("TagAccountDataStreamRow", (
     "user_id",  # str