summary refs log tree commit diff
path: root/synapse/replication/slave/storage/devices.py (follow)
Commit message (Collapse)AuthorAgeFilesLines
* Move and rename `get_devices_with_keys_by_user` (#8204)Richard van der Hoff2020-09-011-0/+3
| | | | | | | | | | | | | | | | | | * Move `get_devices_with_keys_by_user` to `EndToEndKeyWorkerStore` this seems a better fit for it. This commit simply moves the existing code: no other changes at all. * Rename `get_devices_with_keys_by_user` to better reflect what it does. * get_device_stream_token abstract method To avoid referencing fields which are declared in the derived classes, make `get_device_stream_token` abstract, and define that in the classes which define `_device_list_id_gen`.
* Make SlavedIdTracker.advance have same interface as MultiWriterIDGenerator ↵Erik Johnston2020-08-261-2/+2
| | | | (#8171)
* Rename database classes to make some sense (#8033)Erik Johnston2020-08-051-4/+4
|
* 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-10/+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()`.
* Comments from reviewErik Johnston2020-03-181-0/+3
|
* Change device list replication to match new semantics.Erik Johnston2020-02-281-12/+13
| | | | | Instead of sending down batches of user ID/host tuples, send down a row per entity (user ID or host).
* Add 'device_lists_outbound_pokes' as extra table.Erik Johnston2020-02-281-1/+7
| | | | | | | | | This makes sure we check all the relevant tables to get the current max stream ID. Currently not doing so isn't problematic as the max stream ID in `device_lists_outbound_pokes` is the same as in `device_lists_stream`, however that will change.
* Detect unknown remote devices and mark cache as stale (#6776)Erik Johnston2020-01-281-1/+1
| | | | We just mark the fact that the cache may be stale in the database for now.
* Change DataStores to accept 'database' param.Erik Johnston2019-12-061-2/+3
|
* clean up code a bitHubert Chathi2019-10-311-5/+9
|
* make user signatures a separate streamHubert Chathi2019-10-301-2/+6
|
* make notification of signatures work with workersHubert Chathi2019-10-241-0/+1
|
* Merge branch 'develop' of github.com:matrix-org/synapse into ↵Erik Johnston2019-10-221-0/+3
|\ | | | | | | erikj/refactor_stores
| * add user signature stream change cache to slaved device storeHubert Chathi2019-09-041-0/+3
| |
* | Move storage classes into a main "data store".Erik Johnston2019-10-211-2/+2
|/ | | | | 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-9/+5
|
* Fixup slave storesErik Johnston2019-03-041-24/+21
|
* Make workers work on Py3 (#4027)Amber Brown2018-10-131-10/+1
|
* merge (#3576)Amber Brown2018-09-141-7/+16
|
* run isortAmber Brown2018-07-091-2/+3
|
* Add missing storage function to slave storeErik Johnston2017-05-221-0/+2
|
* Change slave storage to use new replication interfaceErik Johnston2017-04-031-14/+10
| | | | | | | As the TCP replication uses a slightly different API and streams than the HTTP replication. This breaks HTTP replication.
* Hook device list updates to replicationErik Johnston2017-01-271-0/+72