summary refs log tree commit diff
path: root/synapse/replication/slave/storage/pushers.py (follow)
Commit message (Collapse)AuthorAgeFilesLines
* Merge/remove `Slaved*` stores into `WorkerStores` (#14375)Nick Mills-Barrett2022-11-111-47/+0
|
* Use cache store remove base slaved (#13329)Nick Mills-Barrett2022-07-211-2/+1
| | | This comes from two identical definitions in each of the base stores, and means the base slaved store is now empty and can be removed.
* Revert "Make all `process_replication_rows` methods async (#13304)" (#13312)Erik Johnston2022-07-181-4/+2
| | | This reverts commit 5d4028f217f178fcd384d5bfddd92225b4e78c51.
* Make all `process_replication_rows` methods async (#13304)Nick Mills-Barrett2022-07-171-2/+4
| | | | | More prep work for asyncronous caching, also makes all process_replication_rows methods consistent (presence handler already is so). Signed off by Nick @ Beeper (@Fizzadar)
* Add missing type hints to synapse.replication. (#11938)Patrick Cloke2022-02-081-3/+3
|
* Annotate synapse.storage.util (#10892)David Robertson2021-10-081-3/+7
| | | | | Also mark `synapse.streams` as having has no untyped defs Co-authored-by: Sean Quah <8349537+squahtx@users.noreply.github.com>
* Remove redundant "coding: utf-8" lines (#9786)Jonathan de Jong2021-04-141-1/+0
| | | | | | | Part of #9744 Removes all redundant `# -*- coding: utf-8 -*-` lines from files, as python 3 automatically reads source code as utf-8 now. `Signed-off-by: Jonathan de Jong <jonathan@automatia.nl>`
* Import HomeServer from the proper module. (#9665)Patrick Cloke2021-03-231-1/+1
|
* Convert internal pusher dicts to attrs classes. (#8940)Patrick Cloke2020-12-161-5/+12
| | | This improves type hinting and should use less memory.
* Simplify super() calls to Python 3 syntax. (#8344)Patrick Cloke2020-09-181-1/+1
| | | | | | | This converts calls like super(Foo, self) -> super(). Generated with: sed -i "" -Ee 's/super\([^\(]+\)/super()/g' **/*.py
* Make SlavedIdTracker.advance have same interface as MultiWriterIDGenerator ↵Erik Johnston2020-08-261-1/+1
| | | | (#8171)
* 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