81 Commits (06cc0bb7627649344d3580f96fb0592048c2030b)

Author	SHA1	Message	Date
Erik Johnston	668f91d707	Fix check of wrong variable	8 years ago
Erik Johnston	748d8fdc7b	Reduce DB hits for replication ... Some streams will occaisonally advance their positions without actually having any new rows to send over federation. Currently this means that the token will not advance on the workers, leading to them repeatedly sending a slightly out of date token. This in turns requires the master to hit the DB to check if there are any new rows, rather than hitting the no op logic where we check if the given token matches the current token. This commit changes the API to always return an entry if the position for a stream has changed, allowing workers to advance their tokens correctly.	8 years ago
Erik Johnston	995f2f032f	Fix public room pagination for client_reader app	8 years ago
Erik Johnston	418bcd4309	Add new storage function to slave store	8 years ago
Erik Johnston	cb3edec6af	Use stream_change cache to make get_forward_extremeties_for_room cache more effective	8 years ago
Erik Johnston	55e6fc917c	Add cache to get_forward_extremeties_for_room	8 years ago
Erik Johnston	211786ecd6	Stream public room changes down replication	8 years ago
Erik Johnston	a4339de9de	Correctly handle typing stream id resetting	8 years ago
Erik Johnston	ab80d5e0a9	Drop replication log levels	8 years ago
Mark Haines	6a6cbfcf1e	Track the max_stream_device_id in a separate table, since we delete from the inbox table	8 years ago
Mark Haines	2a0159b8ae	Fix the stream change cache to work over replication	8 years ago
Erik Johnston	a99e933550	Add upgrade script that will slowly prune state_groups_state entries	8 years ago
Erik Johnston	826ca61745	Add storage function to SlaveStore	8 years ago
Mark Haines	1aa3e1d287	Add a replication stream for direct to device messages	8 years ago
Erik Johnston	3e784eff74	Remove state replication stream	8 years ago
Erik Johnston	41788bba50	Add to slave store	8 years ago
Erik Johnston	873f870e5a	Add new direct message storage functions to slave store	8 years ago
Erik Johnston	bed10f9880	Use state handler instead of get_users_in_room/get_joined_hosts	8 years ago
Erik Johnston	4daa397a00	Add is_host_joined to slave storage	8 years ago
Erik Johnston	50943ab942	Add new state storage funcs to replication	8 years ago
Erik Johnston	07229bbdae	Add appservice worker	8 years ago
Erik Johnston	949629291c	Do it in storage function	8 years ago
Erik Johnston	64a2acb161	Don't update caches replication stream if tokens haven't advanced	8 years ago
Erik Johnston	a2427981b7	Use cached get_user_by_access_token in slaves	8 years ago
Erik Johnston	d9664344ec	Rename table. Add docs.	8 years ago
Erik Johnston	0be963472b	Use cached version of get_aliases_for_room	8 years ago
Erik Johnston	64e7e11853	Implement cache replication stream	8 years ago
Mark Haines	0a7d3cd00f	Create separate methods for getting messages to push ... for the email and http pushers rather than trying to make a single method that will work with their conflicting requirements. The http pusher needs to get the messages in ascending stream order, and doesn't want to miss a message. The email pusher needs to get the messages in descending timestamp order, and doesn't mind if it misses messages.	8 years ago
Erik Johnston	ec8b217722	Add destination retry to slave store	8 years ago
Erik Johnston	76b89d0edb	Add slace storage functions for public room list	8 years ago
Erik Johnston	0fcbca531f	Add get_auth_chain to slave store	8 years ago
Erik Johnston	6ede23ff1b	Add more key storage funcs into slave store	8 years ago
Erik Johnston	aede7248ab	Split out a FederationReader process	8 years ago
David Baker	46b7362304	pep8	9 years ago
David Baker	870c45913e	Use similar naming we use in email notifs for push ... Fixes https://github.com/vector-im/vector-web/issues/1654	9 years ago
Erik Johnston	05e01f21d7	Remove event fetching from DB threads	9 years ago
Mark Haines	81cf449daa	Add methods to events, account data and receipt slaves ... Adds the methods needed by /sync to the slaved events, account data and receipt stores.	9 years ago
Mark Haines	3ae915b27e	Add a slaved store for presence	9 years ago
Mark Haines	f88d747f79	Add a comment explaining why the filter cache doesn't need exipiring	9 years ago
Mark Haines	0eae075723	Add slaved stores for filters, tokens, and push rules	9 years ago
Mark Haines	70599ce925	Allow external processes to mark a user as syncing. (#812) ... * Add infrastructure to the presence handler to track sync requests in external processes * Expire stale entries for dead external processes * Add an http endpoint for making users as syncing Add some docstrings and comments. * Fixes	9 years ago
Mark Haines	0cb441fedd	Move typing handler out of the Handlers object	9 years ago
Mark Haines	3b86ecfa79	Move the presence handler out of the Handlers object	9 years ago
Mark Haines	0466454b00	Assert that stream replicated stream positions are ints	9 years ago
Mark Haines	206eb9fd94	Shift some of the state_group methods into the SlavedEventStore	9 years ago
Mark Haines	3abab26458	Add a slaved datastore for account data	9 years ago
Mark Haines	0e792e7903	Log the stream IDs in an order that makes sense	9 years ago
Mark Haines	3547e66bc6	Make sure we advance our stream position	9 years ago
David Baker	5f46be19a7	Pass through get_events to pusher too	9 years ago
David Baker	d46b18a00f	Pass through _get_event_txn	9 years ago