summary refs log tree commit diff
path: root/synapse/replication/slave/storage/pushers.py (follow)
Commit message (Collapse)AuthorAgeFilesLines
* Rename database classes to make some sense (#8033)Erik Johnston2020-08-051-3/+3
|
* Use symbolic names for replication stream names (#7768)Richard van der Hoff2020-07-011-1/+2
| | | This makes it much easier to find where streams are referenced.
* Support any process writing to cache invalidation stream. (#7436)Erik Johnston2020-05-071-4/+2
|
* Use `stream.current_token()` and remove `stream_positions()` (#7172)Erik Johnston2020-05-011-5/+0
| | | | We move the processing of typing and federation replication traffic into their handlers so that `Stream.current_token()` points to a valid token. This allows us to remove `get_streams_to_replicate()` and `stream_positions()`.
* Move catchup of replication streams to worker. (#7024)Erik Johnston2020-03-251-0/+3
| | | This changes the replication protocol so that the server does not send down `RDATA` for rows that happened before the client connected. Instead, the server will send a `POSITION` and clients then query the database (or master out of band) to get up to date.
* Change DataStores to accept 'database' param.Erik Johnston2019-12-061-2/+3
|
* Move storage classes into a main "data store".Erik Johnston2019-10-211-1/+1
| | | | | This is in preparation for having multiple data stores that offer different functionality, e.g. splitting out state or event storage.
* Run Black. (#5482)Amber Brown2019-06-201-3/+1
|
* run isortAmber Brown2018-07-091-2/+2
|
* Update copyrightErik Johnston2018-02-231-0/+1
|
* Split PusherStoreErik Johnston2018-02-211-9/+2
|
* Change slave storage to use new replication interfaceErik Johnston2017-04-031-10/+6
| | | | | | | As the TCP replication uses a slightly different API and streams than the HTTP replication. This breaks HTTP replication.
* Assert that stream replicated stream positions are intsMark Haines2016-05-131-2/+2
|
* Replicate the pushersMark Haines2016-04-211-0/+52