summary refs log tree commit diff
path: root/synapse/replication/slave (follow)
Commit message (Expand)AuthorAgeFilesLines
* Annotate synapse.storage.util (#10892)David Robertson2021-10-082-5/+9
* Remove the unused public_room_list_stream (#10565)Andrew Morgan2021-08-171-37/+0
* Use inline type hints in various other places (in `synapse/`) (#10380)Jonathan de Jong2021-07-152-4/+6
* Combine `LruCache.invalidate` and `invalidate_many` (#9973)Richard van der Hoff2021-05-271-1/+1
* Remove `keylen` from `LruCache`. (#9993)Richard van der Hoff2021-05-241-1/+1
* Don't hammer the database for destination retry timings every ~5mins (#10036)Erik Johnston2021-05-211-21/+0
* Split presence out of master (#9820)Erik Johnston2021-04-231-50/+0
* Remove redundant "coding: utf-8" lines (#9786)Jonathan de Jong2021-04-1422-22/+0
* Import HomeServer from the proper module. (#9665)Patrick Cloke2021-03-231-1/+1
* Allow moving account data and receipts streams off master (#9104)Erik Johnston2021-01-183-76/+9
* Allow running sendToDevice on workers (#9044)Erik Johnston2021-01-071-31/+1
* Some cleanups to device inbox store. (#9041)Erik Johnston2021-01-071-8/+0
* Convert internal pusher dicts to attrs classes. (#8940)Patrick Cloke2020-12-162-10/+27
* Replace DeferredCache with LruCache where possible (#8563)Richard van der Hoff2020-10-191-5/+5
* move DeferredCache into its own moduleRichard van der Hoff2020-10-141-1/+1
* Rename Cache->DeferredCacheRichard van der Hoff2020-10-141-3/+3
* Add some more type annotations to CacheRichard van der Hoff2020-10-141-1/+1
* Fix MultiWriteIdGenerator's handling of restarts. (#8374)Erik Johnston2020-09-241-0/+2
* Simplify super() calls to Python 3 syntax. (#8344)Patrick Cloke2020-09-1812-12/+12
* Stop sub-classing object (#8249)Patrick Cloke2020-09-041-1/+1
* Move and rename `get_devices_with_keys_by_user` (#8204)Richard van der Hoff2020-09-011-0/+3
* Make SlavedIdTracker.advance have same interface as MultiWriterIDGenerator (#...Erik Johnston2020-08-2610-13/+13
* Remove `ChainedIdGenerator`. (#8123)Erik Johnston2020-08-191-6/+4
* Separate `get_current_token` into two. (#8113)Erik Johnston2020-08-191-0/+8
* Convert synapse.api to async/await (#8031)Patrick Cloke2020-08-061-1/+1
* Rename database classes to make some sense (#8033)Erik Johnston2020-08-0519-54/+54
* Stop using 'device_max_stream_id' (#7882)Erik Johnston2020-07-171-1/+1
* Use symbolic names for replication stream names (#7768)Richard van der Hoff2020-07-018-17/+17
* Fix bug in account data replication stream. (#7656)Erik Johnston2020-06-091-1/+7
* Merge pull request #7519 from matrix-org/rav/kill_py2_codeRichard van der Hoff2020-05-182-13/+4
|\
| * remove redundant `__func__`Richard van der Hoff2020-05-152-13/+4
* | Move event stream handling out of slave store. (#7491)Erik Johnston2020-05-152-97/+0
|/
* Allow configuration of Synapse's cache without using synctl or environment va...Amber Brown2020-05-111-2/+1
* Support any process writing to cache invalidation stream. (#7436)Erik Johnston2020-05-0711-77/+31
* Use `stream.current_token()` and remove `stream_positions()` (#7172)Erik Johnston2020-05-0111-77/+1
* Move catchup of replication streams to worker. (#7024)Erik Johnston2020-03-252-3/+14
* Comments from reviewErik Johnston2020-03-181-0/+3
* Change device list replication to match new semantics.Erik Johnston2020-02-281-12/+13
* Add 'device_lists_outbound_pokes' as extra table.Erik Johnston2020-02-281-1/+7
* Merge worker apps into one. (#6964)Erik Johnston2020-02-251-0/+20
* Allow moving group read APIs to workers (#6866)Erik Johnston2020-02-071-8/+6
* Detect unknown remote devices and mark cache as stale (#6776)Erik Johnston2020-01-281-1/+1
* Allow streaming cache invalidate all to workers. (#6749)Erik Johnston2020-01-221-1/+6
* Add `local_current_membership` table (#6655)Erik Johnston2020-01-151-1/+1
* Fixup synapse.replication to pass mypy checks (#6667)Erik Johnston2020-01-142-4/+5
* Change DataStores to accept 'database' param.Erik Johnston2019-12-0613-26/+39
* _CURRENT_STATE_CACHE_NAME is publicErik Johnston2019-12-041-2/+2
* Move cache invalidation to main data storeErik Johnston2019-12-041-1/+2
* document the REPLICATE command a bit better (#6305)Richard van der Hoff2019-11-041-1/+9
* 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 erikj/refactor_s...Erik Johnston2019-10-221-0/+3
|\
| * 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-2117-27/+29
|/
* Run Black. (#5482)Amber Brown2019-06-2013-84/+73
* Fixup bsaed on review commentsErik Johnston2019-05-171-1/+1
* Add basic editing supportErik Johnston2019-05-161-0/+1
* Fix relations in worker modeErik Johnston2019-05-161-3/+10
* Replace SlavedKeyStore with a shimRichard van der Hoff2019-04-081-14/+4
* Remove unused server_tls_certificates functions (#5028)Richard van der Hoff2019-04-081-3/+0
* Remove presence lists (#4989)Neil Johnson2019-04-031-10/+0
* Fix sync bug when accepting invites (#4956)Richard van der Hoff2019-04-021-9/+22
* Make EventStream rows have a typeRichard van der Hoff2019-03-271-2/+6
* Prefill client IPs cache on workersErik Johnston2019-03-061-0/+2
* Fixup slave storesErik Johnston2019-03-043-36/+26
* When presence is enabled don't send over replicationErik Johnston2019-02-271-2/+5
* Fix state cache invalidation on workersErik Johnston2019-02-221-6/+1
* Batch cache invalidation over replicationErik Johnston2019-02-181-7/+12
* Make workers work on Py3 (#4027)Amber Brown2018-10-136-30/+30
* merge (#3576)Amber Brown2018-09-141-7/+16
* Rename slave TransactionStore to SlaveTransactionStoreErik Johnston2018-08-151-1/+1
* Merge branch 'develop' of github.com:matrix-org/synapse into erikj/split_fede...Erik Johnston2018-08-091-1/+1
|\
| * Basic support for room versioningRichard van der Hoff2018-08-031-1/+1
* | Import all functions from TransactionStoreErik Johnston2018-08-061-11/+2
|/
* Use stream cache in get_linearized_receipts_for_roomErik Johnston2018-07-101-1/+1
* run isortAmber Brown2018-07-0917-28/+41
* Add UserErasureWorkerStore to workersErik Johnston2018-06-251-0/+2
* Split up ProfileStoreErik Johnston2018-03-131-0/+21
* Split Directory storeErik Johnston2018-03-051-5/+3
* Split registration storeErik Johnston2018-03-021-15/+3
* Merge pull request #2928 from matrix-org/erikj/read_marker_cachesErik Johnston2018-03-011-1/+1
|\
| * Fix typo in getting replication account data processingErik Johnston2018-03-011-1/+1
* | Merge pull request #2925 from matrix-org/erikj/split_sig_fedErik Johnston2018-03-011-47/+9
|\ \
| * | Remove unused DataStoreErik Johnston2018-03-011-1/+0
| * | Merge branch 'develop' of github.com:matrix-org/synapse into erikj/split_sig_fedErik Johnston2018-03-012-65/+11
| |\ \
| * | | Split out SignatureStore and EventFederationStoreErik Johnston2018-03-011-42/+8
* | | | Merge pull request #2927 from matrix-org/erikj/read_marker_cachesErik Johnston2018-03-011-0/+4
|\ \ \ \ | |_|/ / |/| | / | | |/ | |/|
| * | Improve caching for read_marker APIErik Johnston2018-03-011-0/+3
| * | Add some caches to help read marker APIErik Johnston2018-03-011-0/+1
| |/
* | Merge branch 'develop' of github.com:matrix-org/synapse into erikj/split_stre...Erik Johnston2018-03-012-19/+4
|\ \
| * \ Merge pull request #2923 from matrix-org/erikj/stream_ago_workerErik Johnston2018-03-011-1/+0
| |\ \
| | * | Calculate stream_ordering_month_ago correctly on workersErik Johnston2018-03-011-1/+0
| | |/
| * / Split up RoomStoreErik Johnston2018-03-011-17/+4
| |/
* / Split out stream storeErik Johnston2018-03-011-45/+9
|/
* Merge pull request #2904 from matrix-org/erikj/receipt_cache_invalidationErik Johnston2018-02-271-0/+2
|\
| * Fix missing invalidations for receipt storageErik Johnston2018-02-211-0/+2
* | Merge pull request #2903 from matrix-org/erikj/split_roommember_storeErik Johnston2018-02-271-28/+5
|\ \
| * \ Merge branch 'develop' of github.com:matrix-org/synapse into erikj/split_room...Erik Johnston2018-02-234-84/+23
| |\ \
| * | | Update copyrightErik Johnston2018-02-231-0/+1
| * | | Split out RoomMemberStoreErik Johnston2018-02-211-27/+3
* | | | Merge pull request #2901 from matrix-org/erikj/split_as_storesErik Johnston2018-02-271-28/+7
|\ \ \ \ | |_|/ / |/| | |
| * | | Update copyrightErik Johnston2018-02-231-0/+1
| * | | Split AS storesErik Johnston2018-02-211-28/+6
| |/ /
* | | Merge branch 'develop' of github.com:matrix-org/synapse into erikj/split_even...Erik Johnston2018-02-234-74/+21
|\ \ \
| * \ \ Merge pull request #2902 from matrix-org/erikj/split_events_storeErik Johnston2018-02-231-11/+3
| |\ \ \
| | * | | Split EventsWorkerStore into separate fileErik Johnston2018-02-231-1/+1
| | * | | Update copyrightErik Johnston2018-02-231-0/+1
| | |/ /
| | * / Split out get_events and co into a worker storeErik Johnston2018-02-211-11/+2
| | |/
| * | Merge pull request #2899 from matrix-org/erikj/split_pushersErik Johnston2018-02-231-9/+3
| |\ \
| | * | Update copyrightErik Johnston2018-02-231-0/+1
| | * | Split PusherStoreErik Johnston2018-02-211-9/+2
| | |/
| * | Merge pull request #2898 from matrix-org/erikj/split_push_rules_storeErik Johnston2018-02-231-17/+7
| |\ \
| | * | Update copyrightErik Johnston2018-02-231-0/+1
| | * | Split PushRulesStoreErik Johnston2018-02-211-17/+6
| | |/
| * | Update copyrightErik Johnston2018-02-231-0/+1
| * | Use absolute importsErik Johnston2018-02-231-2/+2
| * | Split AccountDataStore and TagStoreErik Johnston2018-02-211-34/+4
| |/
* / Split out EventPushActionWorkerStoreErik Johnston2018-02-211-20/+3
|/
* Fix commentErik Johnston2018-02-201-1/+1
* Use abstract base class to access stream IDsErik Johnston2018-02-201-2/+7
* Split ReceiptsStoreErik Johnston2018-02-201-28/+5
* Add event_creator workerErik Johnston2018-02-071-0/+20
* Store state groups separately from events (#2784)Erik Johnston2018-02-061-2/+2
* Pull out bits of StateStore to a mixinRichard van der Hoff2017-11-141-33/+6
* Make __init__ consitstent across Store heirarchyRichard van der Hoff2017-11-131-1/+1
* Fix replication. And notifyErik Johnston2017-07-201-0/+54
* Fix upErik Johnston2017-06-271-2/+1
* Make workers report to master for user ip updatesErik Johnston2017-06-271-0/+48
* Initialise exclusive_user_regexErik Johnston2017-06-211-0/+2
* Fix for workersErik Johnston2017-06-211-0/+3
* Add cache for is_host_joinedErik Johnston2017-06-131-1/+1
* Merge pull request #2266 from matrix-org/erikj/host_in_roomErik Johnston2017-06-121-1/+0
|\
| * Fix replicationErik Johnston2017-06-091-1/+0
* | Fix replicationErik Johnston2017-06-091-1/+1
|/
* Faster cache for get_joined_hostsErik Johnston2017-05-251-0/+2
* Add missing storage function to slave storeErik Johnston2017-05-221-0/+2
* Add new storage functions to slave storeErik Johnston2017-05-041-0/+3
* Remove unused cacheErik Johnston2017-04-241-3/+0
* Move get_presence_list_* to SlaveStoreErik Johnston2017-04-111-0/+10
* Reduce federation presence replication trafficErik Johnston2017-04-101-0/+1
* Change slave storage to use new replication interfaceErik Johnston2017-04-0310-171/+106
* Use presence replication stream to invalidate cacheErik Johnston2017-03-241-0/+1
* Replace some calls to cursor_to_dictErik Johnston2017-03-241-1/+0
* PEP8Erik Johnston2017-03-201-2/+0
* Don't send the full event json over replicationErik Johnston2017-03-171-28/+14
* Fix assertion to stop transaction queue getting wedgedRichard van der Hoff2017-03-151-0/+5
* Add new storage function to slave storeErik Johnston2017-03-131-0/+4
* Fix it for the workersErik Johnston2017-03-101-0/+8
* Don't log unknown cache warnings in workersErik Johnston2017-02-281-1/+3
* Aggregate event push actionsErik Johnston2017-02-141-0/+6
* Cache get_presence storageErik Johnston2017-02-131-1/+3
* Merge pull request #1912 from matrix-org/markjh/roominitialsyncErik Johnston2017-02-131-0/+6
|\
| * Add db functions needed for room initial sync to slaveMark Haines2017-02-131-0/+6
* | Fix replicationErik Johnston2017-02-021-0/+3
* | Only invalidate membership caches based on the cache streamErik Johnston2017-01-311-16/+5
|/
* Hook device list updates to replicationErik Johnston2017-01-271-0/+72
* Insert delta of current_state_events to be more efficientErik Johnston2017-01-201-10/+0
* Add cache to get_public_room_ids_at_stream_idErik Johnston2016-12-121-1/+2
* Invalidate retry cache in both directionsErik Johnston2016-11-222-6/+22
* Store federation stream positions in the databaseErik Johnston2016-11-211-0/+3
* Handle sending events and device messages over federationErik Johnston2016-11-173-6/+24
* Hook up the send queue and create a federation sender workerErik Johnston2016-11-162-0/+8
* Fix public room pagination for client_reader appErik Johnston2016-09-161-0/+1
* Add new storage function to slave storeErik Johnston2016-09-161-0/+1
* Use stream_change cache to make get_forward_extremeties_for_room cache more e...Erik Johnston2016-09-151-1/+4
* Add cache to get_forward_extremeties_for_roomErik Johnston2016-09-151-1/+1
* Stream public room changes down replicationErik Johnston2016-09-152-0/+39
* Track the max_stream_device_id in a separate table, since we delete from the ...Mark Haines2016-09-091-1/+1
* Merge branch 'develop' into markjh/direct_to_device_federationMark Haines2016-09-081-0/+3
|\
| * Add upgrade script that will slowly prune state_groups_state entriesErik Johnston2016-09-051-0/+3
* | Fix the stream change cache to work over replicationMark Haines2016-09-071-0/+11
|/
* Merge pull request #1060 from matrix-org/erikj/state_idsErik Johnston2016-09-011-0/+1
|\
| * Add storage function to SlaveStoreErik Johnston2016-08-311-0/+1
* | Add a replication stream for direct to device messagesMark Haines2016-08-311-0/+12
|/
* Merge pull request #1049 from matrix-org/erikj/presence_users_in_roomErik Johnston2016-08-301-2/+5
|\
| * Add to slave storeErik Johnston2016-08-301-0/+5
| * Use state handler instead of get_users_in_room/get_joined_hostsErik Johnston2016-08-261-2/+0
* | Add new direct message storage functions to slave storeErik Johnston2016-08-301-0/+30
|/
* Add is_host_joined to slave storageErik Johnston2016-08-261-0/+2
* Add new state storage funcs to replicationErik Johnston2016-08-261-0/+3
* Add appservice workerErik Johnston2016-08-182-0/+13
* Use cached get_user_by_access_token in slavesErik Johnston2016-08-162-2/+2
* Rename table. Add docs.Erik Johnston2016-08-151-1/+1
* Use cached version of get_aliases_for_roomErik Johnston2016-08-151-1/+1
* Implement cache replication streamErik Johnston2016-08-151-1/+29
* Merge branch 'develop' of github.com:matrix-org/synapse into erikj/fed_readerErik Johnston2016-07-291-2/+5
|\
| * Create separate methods for getting messages to pushMark Haines2016-07-281-2/+5
* | Add destination retry to slave storeErik Johnston2016-07-281-0/+30
* | Add slace storage functions for public room listErik Johnston2016-07-282-0/+44
* | Add get_auth_chain to slave storeErik Johnston2016-07-281-0/+4
* | Add more key storage funcs into slave storeErik Johnston2016-07-281-6/+10
* | Split out a FederationReader processErik Johnston2016-07-212-0/+34
|/
* pep8David Baker2016-06-241-1/+0
* Use similar naming we use in email notifs for pushDavid Baker2016-06-241-8/+0
* Remove event fetching from DB threadsErik Johnston2016-06-031-5/+0
* Merge pull request #827 from matrix-org/markjh/more_slaved_methodsMark Haines2016-06-033-6/+81
|\
| * Add methods to events, account data and receipt slavesMark Haines2016-06-033-6/+81
* | Merge pull request #824 from matrix-org/markjh/slaved_presence_storeMark Haines2016-06-031-0/+59
|\ \
| * | Add a slaved store for presenceMark Haines2016-06-031-0/+59
| |/
* | Add a comment explaining why the filter cache doesn't need exipiringMark Haines2016-06-031-0/+1
* | Add slaved stores for filters, tokens, and push rulesMark Haines2016-06-034-0/+151
|/
* Assert that stream replicated stream positions are intsMark Haines2016-05-133-7/+7
* Merge branch 'develop' into dbkr/email_notifs_on_pusherMark Haines2016-05-132-0/+63
|\
| * Add a slaved datastore for account dataMark Haines2016-05-131-0/+61
| * Make sure we advance our stream positionMark Haines2016-05-131-0/+2
* | Shift some of the state_group methods into the SlavedEventStoreMark Haines2016-05-131-0/+19
|/
* Pass through get_events to pusher tooDavid Baker2016-05-101-0/+1
* Pass through _get_event_txnDavid Baker2016-05-101-0/+1
* Fix backfill replication to advance the stream correctlyMark Haines2016-04-271-2/+2
* Merge pull request #743 from matrix-org/markjh/slave_pushersMark Haines2016-04-211-0/+52
|\
| * Replicate the pushersMark Haines2016-04-211-0/+52
* | Replicate push actionsMark Haines2016-04-211-0/+14
|/
* Merge pull request #738 from matrix-org/markjh/slaved_receiptsMark Haines2016-04-191-0/+61
|\
| * Add a slaved receipts storeMark Haines2016-04-191-0/+61
* | Replicate get_invited_rooms_for_userMark Haines2016-04-191-2/+7
|/
* Add tests for redactionsMark Haines2016-04-071-2/+2
* Add tests for get_latest_event_ids_in_room and get_current_stateMark Haines2016-04-071-0/+5
* Test that room membership is replicatedMark Haines2016-04-061-3/+4
* Add a slaved events store classMark Haines2016-04-065-0/+284