Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Improve type checking in `replication.tcp.Stream` (#7291) | Richard van der Hoff | 2020-04-17 | 4 | -122/+142 |
| | | | | | | | The general idea here is to get rid of the type: ignore annotations on all of the current_token and update_function assignments, which would have caught #7290. After a bit of experimentation, it seems like the least-awful way to do this is to pass the offending functions in as parameters to the Stream constructor. Unfortunately that means that the concrete implementations no longer have the same constructor signature as Stream itself, which means that it gets hard to correctly annotate STREAMS_MAP. I've also introduced a couple of new types, to take out some duplication. | ||||
* | Fix 'generator object is not subscriptable' error (#7290) | Richard van der Hoff | 2020-04-16 | 1 | -1/+2 |
| | | | | | | Some of the query functions return generators rather than lists, so we can't index into the result. Happily we already have a copy of the results. (think this was introduced in #7024) | ||||
* | Fix race in replication (#7226) | Erik Johnston | 2020-04-07 | 1 | -1/+2 |
| | | | | Fixes a race between handling `POSITION` and `RDATA` commands. We do this by simply linearizing handling of them. | ||||
* | Move catchup of replication streams to worker. (#7024) | Erik Johnston | 2020-03-25 | 4 | -60/+132 |
| | | | 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. | ||||
* | Convert `*StreamRow` classes to inner classes (#7116) | Richard van der Hoff | 2020-03-23 | 2 | -96/+101 |
| | | | | | This just helps keep the rows closer to their streams, so that it's easier to see what the format of each stream is. | ||||
* | Fix processing of `groups` stream, and use symbolic names for streams (#7117) | Richard van der Hoff | 2020-03-23 | 1 | -18/+52 |
| | | | | | | `groups` != `receipts` Introduced in #6964 | ||||
* | Remove concept of a non-limited stream. (#7011) | Erik Johnston | 2020-03-20 | 1 | -40/+26 |
| | |||||
* | Change device list replication to match new semantics. | Erik Johnston | 2020-02-28 | 1 | -4/+9 |
| | | | | | Instead of sending down batches of user ID/host tuples, send down a row per entity (user ID or host). | ||||
* | Increase MAX_EVENTS_BEHIND for replication clients | Erik Johnston | 2020-02-21 | 1 | -1/+1 |
| | |||||
* | Allow streaming cache invalidate all to workers. (#6749) | Erik Johnston | 2020-01-22 | 1 | -5/+21 |
| | |||||
* | Port synapse.replication.tcp to async/await (#6666) | Erik Johnston | 2020-01-16 | 2 | -21/+13 |
| | | | | | | | | | | * Port synapse.replication.tcp to async/await * Newsfile * Correctly document type of on_<FOO> functions as async * Don't be overenthusiastic with the asyncing.... | ||||
* | Fixup synapse.replication to pass mypy checks (#6667) | Erik Johnston | 2020-01-14 | 3 | -35/+42 |
| | |||||
* | lint | Andrew Morgan | 2019-11-08 | 1 | -2/+1 |
| | |||||
* | Remove content from being sent for account data rdata stream | Andrew Morgan | 2019-11-08 | 1 | -3/+3 |
| | |||||
* | make user signatures a separate stream | Hubert Chathi | 2019-10-30 | 2 | -0/+19 |
| | |||||
* | Remove unnecessary parentheses around return statements (#5931) | Andrew Morgan | 2019-08-30 | 1 | -4/+4 |
| | | | | | Python will return a tuple whether there are parentheses around the returned values or not. I'm just sick of my editor complaining about this all over the place :) | ||||
* | Replace returnValue with return (#5736) | Amber Brown | 2019-07-23 | 2 | -7/+7 |
| | |||||
* | Run Black. (#5482) | Amber Brown | 2019-06-20 | 3 | -100/+104 |
| | |||||
* | Fix relations in worker mode | Erik Johnston | 2019-05-16 | 2 | -5/+7 |
| | |||||
* | Combine the CurrentStateDeltaStream into the EventStream | Richard van der Hoff | 2019-03-27 | 3 | -23/+33 |
| | |||||
* | Make EventStream rows have a type | Richard van der Hoff | 2019-03-27 | 1 | -12/+86 |
| | | | | ... as a precursor to combining it with the CurrentStateDelta stream. | ||||
* | Skip building a ROW_TYPE when building updates | Richard van der Hoff | 2019-03-27 | 1 | -2/+2 |
| | | | | | We're about to turn it straight into a JSON object anyway so building a ROW_TYPE is a bit pointless, and reduces flexibility in the update_function. | ||||
* | Add parse_row method to replication stream class | Richard van der Hoff | 2019-03-27 | 1 | -0/+15 |
| | | | | This will allow individual stream classes to override how a row is parsed. | ||||
* | move FederationStream out to its own file | Richard van der Hoff | 2019-03-27 | 3 | -22/+41 |
| | |||||
* | move EventsStream out to its own file | Richard van der Hoff | 2019-03-27 | 3 | -23/+42 |
| | |||||
* | Move replication.tcp.streams into a package | Richard van der Hoff | 2019-03-27 | 2 | -0/+532 |