Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Remove old empty/redundant slaved stores. (#13349) | Nick Mills-Barrett | 2022-07-21 | 1 | -19/+0 |
| | |||||
* | Use cache store remove base slaved (#13329) | Nick Mills-Barrett | 2022-07-21 | 1 | -2/+1 |
| | | | This comes from two identical definitions in each of the base stores, and means the base slaved store is now empty and can be removed. | ||||
* | Remove redundant "coding: utf-8" lines (#9786) | Jonathan de Jong | 2021-04-14 | 1 | -1/+0 |
| | | | | | | | Part of #9744 Removes all redundant `# -*- coding: utf-8 -*-` lines from files, as python 3 automatically reads source code as utf-8 now. `Signed-off-by: Jonathan de Jong <jonathan@automatia.nl>` | ||||
* | Allow running sendToDevice on workers (#9044) | Erik Johnston | 2021-01-07 | 1 | -31/+1 |
| | |||||
* | Some cleanups to device inbox store. (#9041) | Erik Johnston | 2021-01-07 | 1 | -8/+0 |
| | |||||
* | Simplify super() calls to Python 3 syntax. (#8344) | Patrick Cloke | 2020-09-18 | 1 | -1/+1 |
| | | | | | | | This converts calls like super(Foo, self) -> super(). Generated with: sed -i "" -Ee 's/super\([^\(]+\)/super()/g' **/*.py | ||||
* | Make SlavedIdTracker.advance have same interface as MultiWriterIDGenerator ↵ | Erik Johnston | 2020-08-26 | 1 | -1/+1 |
| | | | | (#8171) | ||||
* | Rename database classes to make some sense (#8033) | Erik Johnston | 2020-08-05 | 1 | -3/+3 |
| | |||||
* | Stop using 'device_max_stream_id' (#7882) | Erik Johnston | 2020-07-17 | 1 | -1/+1 |
| | | | | | It serves no purpose and updating everytime we write to the device inbox stream means all such transactions will conflict, causing lots of transaction failures and retries. | ||||
* | Use symbolic names for replication stream names (#7768) | Richard van der Hoff | 2020-07-01 | 1 | -1/+2 |
| | | | This makes it much easier to find where streams are referenced. | ||||
* | Support any process writing to cache invalidation stream. (#7436) | Erik Johnston | 2020-05-07 | 1 | -4/+2 |
| | |||||
* | Use `stream.current_token()` and remove `stream_positions()` (#7172) | Erik Johnston | 2020-05-01 | 1 | -5/+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()`. | ||||
* | Change DataStores to accept 'database' param. | Erik Johnston | 2019-12-06 | 1 | -2/+3 |
| | |||||
* | Move storage classes into a main "data store". | Erik Johnston | 2019-10-21 | 1 | -1/+1 |
| | | | | | 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 Brown | 2019-06-20 | 1 | -3/+3 |
| | |||||
* | Fixup slave stores | Erik Johnston | 2019-03-04 | 1 | -11/+4 |
| | |||||
* | Make workers work on Py3 (#4027) | Amber Brown | 2018-10-13 | 1 | -6/+6 |
| | |||||
* | run isort | Amber Brown | 2018-07-09 | 1 | -3/+4 |
| | |||||
* | Change slave storage to use new replication interface | Erik Johnston | 2017-04-03 | 1 | -13/+10 |
| | | | | | | | As the TCP replication uses a slightly different API and streams than the HTTP replication. This breaks HTTP replication. | ||||
* | Fix it for the workers | Erik Johnston | 2017-03-10 | 1 | -0/+8 |
| | |||||
* | Handle sending events and device messages over federation | Erik Johnston | 2016-11-17 | 1 | -4/+11 |
| | |||||
* | Hook up the send queue and create a federation sender worker | Erik Johnston | 2016-11-16 | 1 | -0/+5 |
| | |||||
* | Track the max_stream_device_id in a separate table, since we delete from the ↵ | Mark Haines | 2016-09-09 | 1 | -1/+1 |
| | | | | inbox table | ||||
* | Fix the stream change cache to work over replication | Mark Haines | 2016-09-07 | 1 | -0/+11 |
| | |||||
* | Add a replication stream for direct to device messages | Mark Haines | 2016-08-31 | 1 | -0/+12 |
| | |||||
* | Add new direct message storage functions to slave store | Erik Johnston | 2016-08-30 | 1 | -0/+30 |