summary refs log tree commit diff
path: root/synapse/replication (follow)
Commit message (Expand)AuthorAgeFilesLines
* Add concept of StatelessEventContextErik Johnston2018-03-141-4/+6
* Merge pull request #2992 from matrix-org/erikj/implement_member_workreErik Johnston2018-03-142-3/+336
|\
| * Fix importsErik Johnston2018-03-142-7/+4
| * s/join/joined/ in notify_user_membership_changeErik Johnston2018-03-141-3/+3
| * Implement RoomMemberWorkerHandlerErik Johnston2018-03-132-0/+336
* | Split up ProfileStoreErik Johnston2018-03-131-0/+21
|/
* extra_users is actually a list of UserIDsErik Johnston2018-03-131-4/+4
* 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
|/
* Log in the correct placesErik Johnston2018-03-011-2/+4
* Don't do preserve_fn for every requestErik Johnston2018-03-011-1/+2
* Add some loggingErik Johnston2018-03-011-0/+2
* Make repl send_event idempotent and retry on timeoutsErik Johnston2018-03-011-6/+38
* Correctly send ratelimit and extra_users paramsErik Johnston2018-03-011-1/+13
* Calculate push actions on workerErik Johnston2018-02-281-1/+1
* 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
* Don't serialize current state over replicationErik Johnston2018-02-151-2/+2
* Don't log errors propogated from send_eventErik Johnston2018-02-151-1/+10
* Add event_creator workerErik Johnston2018-02-071-0/+20
* Add replication http endpoint for event sendingErik Johnston2018-02-072-0/+139
* Store state groups separately from events (#2784)Erik Johnston2018-02-061-2/+2
* Metrics for number of RDATA commands receivedRichard van der Hoff2018-01-151-5/+14
* Fix some logcontext leaks in replication resourceRichard van der Hoff2017-11-231-2/+4
* 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
* replace 'except:' with 'except Exception:'Richard van der Hoff2017-10-231-1/+1
* log when we get an exception handling replication updateshera2017-10-121-1/+5
* Fix replication. And notifyErik Johnston2017-07-202-0/+74
* Reduce log levels in tcp replicationErik Johnston2017-07-111-2/+2
* Serialize user ip command as jsonErik Johnston2017-06-271-5/+9
* Fix upErik Johnston2017-06-271-2/+1
* Make workers report to master for user ip updatesErik Johnston2017-06-275-0/+103
* Initialise exclusive_user_regexErik Johnston2017-06-211-0/+2
* Fix for workersErik Johnston2017-06-211-0/+3
* Initial worker implErik Johnston2017-06-161-0/+22
* 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
* | Add missing notifierErik Johnston2017-06-091-1/+2
|/
* 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
* Merge pull request #2115 from matrix-org/erikj/dedupe_federation_replErik Johnston2017-04-122-0/+11
|\
| * Move get_presence_list_* to SlaveStoreErik Johnston2017-04-111-0/+10
| * Reduce federation presence replication trafficErik Johnston2017-04-101-0/+1
* | Remove HTTP replication APIsErik Johnston2017-04-114-749/+0
|/
* TypoErik Johnston2017-04-101-1/+1
* Merge pull request #2109 from matrix-org/erikj/send_queue_fixErik Johnston2017-04-101-2/+2
|\
| * CommentsErik Johnston2017-04-101-2/+2
* | Up replication ping timeoutErik Johnston2017-04-101-2/+4
|/
* Merge pull request #2103 from matrix-org/erikj/no-double-encodeErik Johnston2017-04-071-28/+76
|\
| * Document types of the replication streamsErik Johnston2017-04-061-28/+76
* | Fix incorrect type when using InvalidateCacheCommandErik Johnston2017-04-061-1/+1
* | Add log linesErik Johnston2017-04-051-1/+2
* | Rearrange metricsErik Johnston2017-04-051-16/+31
* | Fix typoErik Johnston2017-04-051-2/+2
* | Fixup some metrics for tcp replErik Johnston2017-04-051-0/+16
|/
* Merge pull request #2097 from matrix-org/erikj/repl_tcp_clientErik Johnston2017-04-0511-171/+302
|\
| * Change slave storage to use new replication interfaceErik Johnston2017-04-0310-171/+106
| * Add basic replication client handler and factoryErik Johnston2017-04-031-0/+196
* | Merge pull request #2098 from matrix-org/erikj/repl_tcp_fixErik Johnston2017-04-043-6/+15
|\ \
| * | Advance replication streams even if nothing is listeningErik Johnston2017-04-043-6/+15
| |/
* / Fiddle tcp replication loggingErik Johnston2017-04-041-2/+2
|/
* Always advance stream tokensErik Johnston2017-04-031-1/+4
* Use callbacks to notify tcp replication rather than deferredsErik Johnston2017-03-311-14/+1
* Add a timestamp to USER_SYNC commandErik Johnston2017-03-313-9/+17
* Fix up docsErik Johnston2017-03-312-19/+3
* Add server side resource for tcp replicationErik Johnston2017-03-301-0/+300
* Initial TCP protocol implementationErik Johnston2017-03-303-0/+974
* Define the various streams we will replicateErik Johnston2017-03-302-0/+423
* Make federation send queue take the current positionErik Johnston2017-03-301-1/+1
* Add new storage functions for new replicationErik Johnston2017-03-301-1/+1
* 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-172-30/+16
* 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-312-19/+5
|/
* Rename funcErik Johnston2017-01-301-1/+1
* Hook device list updates to replicationErik Johnston2017-01-272-1/+91
* 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
* Add new API appservice specific public room listErik Johnston2016-12-061-1/+1
* Ensure only main or federation_sender process can send federation trafficErik Johnston2016-11-231-1/+1
* Explicit federation ackErik Johnston2016-11-231-5/+10
* Invalidate retry cache in both directionsErik Johnston2016-11-224-6/+84
* Store federation stream positions in the databaseErik Johnston2016-11-211-0/+3
* Handle sending events and device messages over federationErik Johnston2016-11-174-7/+25
* Hook up the send queue and create a federation sender workerErik Johnston2016-11-163-0/+32
* Fix check of wrong variableErik Johnston2016-10-111-1/+1
* Reduce DB hits for replicationErik Johnston2016-09-231-36/+103
* 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-153-1/+58
* Correctly handle typing stream id resettingErik Johnston2016-09-091-1/+8
* Drop replication log levelsErik Johnston2016-09-091-2/+2
* 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-012-23/+2
|\
| * Add storage function to SlaveStoreErik Johnston2016-08-311-0/+1
| * Remove state replication streamErik Johnston2016-08-301-23/+1
* | Add a replication stream for direct to device messagesMark Haines2016-08-312-1/+30
|/
* 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-152-2/+49
* 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
|/
* Allow external processes to mark a user as syncing. (#812)Mark Haines2016-06-022-0/+61
* Move typing handler out of the Handlers objectMark Haines2016-05-171-1/+1
* Move the presence handler out of the Handlers objectMark Haines2016-05-161-1/+1
* Assert that stream replicated stream positions are intsMark Haines2016-05-133-7/+7
* Merge branch 'develop' into dbkr/email_notifs_on_pusherMark Haines2016-05-133-1/+64
|\
| * Add a slaved datastore for account dataMark Haines2016-05-131-0/+61
| * Log the stream IDs in an order that makes senseMark Haines2016-05-131-1/+1
| * 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
* Don't warnErik Johnston2016-05-051-2/+0
* Add some log information at returned replication streamsErik Johnston2016-05-051-0/+11
* Report per request metrics for all of the things using request_handlerMark Haines2016-04-282-2/+4
* Fix backfill replication to advance the stream correctlyMark Haines2016-04-272-3/+3
* Merge pull request #743 from matrix-org/markjh/slave_pushersMark Haines2016-04-211-0/+52
|\
| * Replicate the pushersMark Haines2016-04-211-0/+52
* | Merge pull request #744 from matrix-org/markjh/replication_remove_pusherMark Haines2016-04-212-3/+57
|\ \
| * | Add a replication endpoint for deleting pushersMark Haines2016-04-212-3/+57
| |/
* / 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
* Separate generating the replication response...Mark Haines2016-04-051-44/+55
* Merge pull request #676 from matrix-org/markjh/replicate_stateIIIMark Haines2016-03-311-3/+14
|\
| * Use a namedtuple rather than tuple unpackingMark Haines2016-03-311-10/+6
| * Add replication streams for ex outliers and current state resetsMark Haines2016-03-301-1/+16
* | typoMatthew Hodgson2016-03-301-1/+1
|/
* Add a replication stream for state groupsMark Haines2016-03-301-7/+29
* Add replication stream for pushersMark Haines2016-03-151-1/+24
* s/stream_ordering/event_stream_ordering/ in pushMark Haines2016-03-041-1/+1
* Hook push rules up to the replication APIMark Haines2016-03-021-2/+26
* Add a /replication API for extracting the updates that happened onMark Haines2016-03-012-0/+334
generated by cgit-pink 1.4.1 (git 2.36.1) at 2024-11-21 23:30:51 +0000