diff options
| author | Richard van der Hoff <1389908+richvdh@users.noreply.github.com> | 2019-03-28 18:31:17 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-03-28 18:31:17 +0000 |
| commit | d688a51736796d88f1dd72930869bbbabefbeeb5 (patch) | |
| tree | 7b8a6a32d838132d3ed6e3fc87abffcd5a2b8756 /synapse/replication/tcp/client.py | |
| parent | remove log line for password (#4965) (diff) | |
| parent | Merge remote-tracking branch 'origin/develop' into rav/refactor_parse_row (diff) | |
| download | synapse-d688a51736796d88f1dd72930869bbbabefbeeb5.tar.xz | |
Merge pull request #4954 from matrix-org/rav/refactor_parse_row
Refactors to replication stream row update/parsing
Diffstat (limited to 'synapse/replication/tcp/client.py')
| -rw-r--r-- | synapse/replication/tcp/client.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/synapse/replication/tcp/client.py b/synapse/replication/tcp/client.py index 150975608f..206dc3b397 100644 --- a/synapse/replication/tcp/client.py +++ b/synapse/replication/tcp/client.py @@ -105,13 +105,14 @@ class ReplicationClientHandler(object): def on_rdata(self, stream_name, token, rows): """Called to handle a batch of replication data with a given stream token. - By default this just pokes the slave store. Can be overriden in subclasses to + By default this just pokes the slave store. Can be overridden in subclasses to handle more. Args: stream_name (str): name of the replication stream for this batch of rows token (int): stream token for this batch of rows - rows (list): a list of Stream.ROW_TYPE objects. + rows (list): a list of Stream.ROW_TYPE objects as returned by + Stream.parse_row. Returns: Deferred|None |