summary refs log tree commit diff
path: root/synapse/storage/stream.py (follow)
Commit message (Collapse)AuthorAgeFilesLines
* Remove some unused functions (#711)Mark Haines2016-04-081-90/+0
| | | | | | | | * Remove some unused functions * get_room_events_stream is only used in tests * is_exclusive_room might actually be something we want
* Use a stream id generator for backfilled idsMark Haines2016-04-011-1/+1
|
* Don't cache events in get_recent_events_for_roomErik Johnston2016-03-231-14/+19
|
* Add commentErik Johnston2016-03-091-0/+3
|
* Return the correct token formErik Johnston2016-03-091-1/+1
|
* Use topological orders for initial sync timelineErik Johnston2016-03-091-2/+2
|
* Remove unused param from get_max_tokenErik Johnston2016-02-181-1/+1
|
* Fix SYN-627, events are in incorrect room in /syncErik Johnston2016-02-111-1/+1
|
* Return events in correct order for /eventsErik Johnston2016-02-111-8/+11
|
* Fix up logcontextsErik Johnston2016-02-081-4/+5
|
* Add descriptionsErik Johnston2016-02-031-0/+1
|
* Fix flake8 warnings for new flake8Daniel Wagner-Hall2016-02-021-1/+1
|
* s/get_room_changes_for_user/get_membership_changes_for_user/Erik Johnston2016-02-021-2/+2
|
* Fetch events in a separate transaction.Erik Johnston2016-02-021-26/+29
| | | | | | | | | This has a couple of benefits: - It reduces the time of transactions, allowing other database requests to run. - Fetching events is given a dedicated database thread, and so can't starve other database requests.
* Order things correctlyErik Johnston2016-02-011-0/+4
|
* Switch over /events to use per room cachesErik Johnston2016-02-011-2/+2
|
* Merge pull request #543 from matrix-org/erikj/syncErik Johnston2016-02-011-0/+7
|\ | | | | Cache get_room_changes_for_user
| * Cache get_room_changes_for_userErik Johnston2016-01-291-0/+7
| |
* | Only use room_ids if in get_room_events_stream if is_guestErik Johnston2016-02-011-5/+0
|/
* Prefill stream change cachesErik Johnston2016-01-291-8/+0
|
* Change name and doc has_entity_changedErik Johnston2016-01-281-1/+1
|
* Cache tags and account dataErik Johnston2016-01-281-4/+4
|
* Ensure keys to RoomStreamChangeCache are intsErik Johnston2016-01-281-5/+6
|
* Invalidate caches properly. Remove unused argErik Johnston2016-01-281-1/+1
|
* Allow paginating backwards from stream tokenErik Johnston2016-01-281-2/+14
|
* Return correct type of tokenErik Johnston2016-01-281-3/+6
|
* PEP8Erik Johnston2016-01-271-3/+6
|
* Use the same path for incremental with gap or without gapErik Johnston2016-01-271-3/+3
|
* Add cache to room streamErik Johnston2016-01-271-0/+133
|
* Add a Homeserver.setup method.Erik Johnston2016-01-261-13/+0
| | | | | | This is for setting up dependencies that require work on startup. This is useful for the DataStore that wants to read a bunch from the database before initiliazing.
* copyrightsMatthew Hodgson2016-01-071-1/+1
|
* Open up /events to anonymous users for room events onlyDaniel Wagner-Hall2015-11-051-8/+38
| | | | Squash-merge of PR #345 from daniel/anonymousevents
* Remove more unused parametersDaniel Wagner-Hall2015-11-021-2/+1
|
* DocsErik Johnston2015-10-281-0/+26
|
* Add room context apiErik Johnston2015-10-281-1/+110
|
* Allow users that have left a room to get the messages that happend in the ↵Mark Haines2015-09-091-1/+18
| | | | room before they left
* Remove undocumented and unimplemented 'feedback' parameter from the ↵Mark Haines2015-09-091-8/+2
| | | | Client-Server API
* Allow room initialSync for users that have left the room, returning a ↵Mark Haines2015-09-091-0/+15
| | | | snapshot of how the room was when they left it
* Move all the caches into their own package, synapse.util.cachesErik Johnston2015-08-111-1/+2
|
* Cache get_recent_events_for_roomErik Johnston2015-08-071-2/+2
|
* Use dictionary cache to do group -> state fetchingErik Johnston2015-08-051-2/+1
|
* Fix daedlockErik Johnston2015-05-151-0/+2
|
* Move fetching of events into their own transactionsErik Johnston2015-05-141-9/+10
|
* Fetch events from events_id in their own transactionsErik Johnston2015-05-131-10/+12
|
* Make get_current_token accept a direction parameter, which tells whether the ↵Erik Johnston2015-05-121-2/+18
| | | | source whether we want a token for going 'forwards' or 'backwards'
* Move storage.stream._StreamToken to types.RoomStreamTokenErik Johnston2015-05-111-85/+33
|
* Add more conditions on JOINs to make postgres go a little faster.Erik Johnston2015-04-301-3/+5
|
* Add support for postgres instead of mysql. Change sql accourdingly. blob + ↵Erik Johnston2015-04-141-8/+8
| | | | varbinary -> bytea. No support for UNSIGNED or CREATE INDEX IF NOT EXISTS.
* Remove unused importErik Johnston2015-04-091-1/+1
|
* Stream ordering and out of order insertions.Erik Johnston2015-04-091-20/+3
| | | | | | | Handle the fact that events can be persisted out of order, and so to get the "current max" stream token becomes non trivial - as we need to make sure that *all* stream tokens less than the current max have also successfully been persisted.
* Make work in both Maria and SQLite. Fix testsErik Johnston2015-04-011-6/+0
|
* Merge branch 'develop' of github.com:matrix-org/synapse into mysqlErik Johnston2015-03-201-1/+2
|\
| * Merge branch 'develop' of github.com:matrix-org/synapse into store_rearrangementErik Johnston2015-03-201-1/+2
| |\
| | * Add the tiniest of tiny one-element caches to get_room_events_max_id() as ↵Paul "LeoNerd" Evans2015-03-201-1/+2
| | | | | | | | | | | | it's read every time someone hits eventstream
| * | Rearrange storage modulesErik Johnston2015-03-201-0/+19
| |/
* | Rearrange storage modulesErik Johnston2015-03-201-0/+19
| |
* | Convert storage layer to be mysql compatibleErik Johnston2015-03-191-2/+2
|/
* Wrap all of get_app_service_rooms in a txn.Kegan Dougal2015-03-021-24/+22
|
* JOIN state_events rather than parsing unrecognized_keys to pull out member ↵Kegan Dougal2015-03-021-10/+4
| | | | state_keys
* PR tweaks: set earlier on and use 'as json' for compatKegan Dougal2015-03-021-4/+4
|
* PEP8Kegan Dougal2015-02-271-1/+0
|
* Check for membership invite events correctly.Kegan Dougal2015-02-261-2/+21
|
* Finish impl to get new events for AS. ASes should now be able to poll /eventsKegan Dougal2015-02-261-7/+55
|
* Comment unused variables.Kegan Dougal2015-02-251-2/+2
|
* Add stub functions and work out execution flow to implement AS event stream ↵Kegan Dougal2015-02-251-0/+21
| | | | polling.
* Fix token formattingMark Haines2015-01-301-2/+2
|
* Filter the recent events before applying the limit when doing an incremental ↵Mark Haines2015-01-301-6/+15
| | | | sync with a gap
* Merge branch 'client_v2_filter' into client_v2_syncMark Haines2015-01-291-3/+3
|\ | | | | | | | | Conflicts: synapse/rest/client/v2_alpha/__init__.py
| * SYN-252: Supply the stream and topological parts in the correct order to the ↵Mark Haines2015-01-291-3/+3
| | | | | | | | constructor
* | Use get_room_events_stream to get changes to the rooms if the number of ↵Mark Haines2015-01-291-0/+7
| | | | | | | | changes is small
* | Fix FormattingMark Haines2015-01-271-1/+0
| |
* | Start implementing incremental initial syncMark Haines2015-01-271-9/+32
|/
* get_room_events isn't called anywhereMark Haines2015-01-131-30/+0
|
* Fix stream token orderingMark Haines2015-01-131-72/+101
|
* SYN-178: Fix off by one.Kegan Dougal2015-01-121-2/+6
|
* Only fetch the columns we need.Erik Johnston2015-01-061-1/+1
|
* Merge pull request #28 from matrix-org/erikj-perfMark Haines2015-01-061-77/+68
|\ | | | | Database performance improvements.
| * PEP8Erik Johnston2015-01-061-1/+0
| |
| * Only fetch prev_content when a client is streaming/paginating. Use ↵Erik Johnston2015-01-061-77/+69
| | | | | | | | transactions for event streams.
* | Update copyright noticesMark Haines2015-01-061-1/+1
|/
* Don't return outliers when we get recent events for rooms.Erik Johnston2014-11-271-1/+1
|
* Fix pep8 codestyle warningsMark Haines2014-11-201-5/+6
|
* SYN-104: When going backwards the end token should be before the last eventMark Haines2014-11-181-0/+3
|
* Notify users about invites.Erik Johnston2014-11-101-2/+1
|
* Add transaction level logging and timing information. Add a _simple_delete ↵Erik Johnston2014-10-281-1/+4
| | | | method
* Add LIMIT to scalar subqueryErik Johnston2014-09-251-3/+6
|
* Rename deletions to redactionsErik Johnston2014-09-241-9/+9
|
* Add m.room.deletion. If an event is deleted it will be returned to clients ↵Erik Johnston2014-09-231-5/+25
| | | | 'pruned', i.e. all client specified keys will be removed.
* SYN-47: Fix bug where we still returned events for rooms we had left.Erik Johnston2014-09-191-1/+1
| | | | SYN-47 #resolve
* Add a .runInteraction() method on SQLBaseStore itself to wrap the .db_poolPaul "LeoNerd" Evans2014-09-121-1/+1
|
* When getting a state event also include the previous contentErik Johnston2014-09-061-8/+9
|
* fix the copyright holder from matrix.org to OpenMarket Ltd, as matrix.org ↵Matthew Hodgson2014-09-031-1/+1
| | | | hasn't been incorporated in time for launch.
* Get the equalities right.Erik Johnston2014-08-291-2/+5
|
* Initial room event stream token must be s0, not s1, or everyone will miss ↵Paul "LeoNerd" Evans2014-08-281-1/+1
| | | | the very first room event
* Merge branch 'develop' into storage_transactionsMark Haines2014-08-271-2/+2
|\ | | | | | | | | | | Conflicts: synapse/handlers/room.py synapse/storage/stream.py
| * WIP: Completely change how event streaming and pagination work. This ↵Erik Johnston2014-08-261-2/+2
| | | | | | | | reflects the change in the underlying storage model.
* | Merge branch 'develop' into storage_transactionsMark Haines2014-08-261-7/+5
|\| | | | | | | | | | | | | Conflicts: synapse/api/auth.py synapse/handlers/room.py synapse/storage/__init__.py
| * Fix pyflakes errorsMark Haines2014-08-261-2/+0
| |
| * Order 'get_recent_events_for_room' correctly.Erik Johnston2014-08-261-1/+1
| |
| * Don't return state event outlier's when paginating.Erik Johnston2014-08-221-1/+2
| |
| * Change IM sync api to also return the current presence list.Erik Johnston2014-08-211-3/+2
| |
* | Move the event storage into a single transactionMark Haines2014-08-261-5/+8
|/
* Make event stream storage return all membership events about the user, ↵Erik Johnston2014-08-201-4/+6
| | | | regardless of if they were in the room or not.
* Only hit get_room_events_stream if we have a valid user_idErik Johnston2014-08-191-0/+3
|
* Fix token to correct formatErik Johnston2014-08-191-1/+1
|
* Remove debug logging from token parsing funcs.Erik Johnston2014-08-191-2/+0
|
* Add comment about what strorage.stream doesErik Johnston2014-08-191-0/+20
|
* Change the way pagination works to support out of order events.Erik Johnston2014-08-191-29/+157
|
* Fix typos in SQL and where we still had rowid's (which no longer exist)Erik Johnston2014-08-181-6/+6
|
* Make snapshot_all_rooms return results in the correct form, including start ↵Erik Johnston2014-08-181-4/+21
| | | | and end tokens.
* Add two different columns for ordering the events table, one which can be ↵Erik Johnston2014-08-181-8/+9
| | | | used for pagination and one which can be as tokens for notifying clients. Also add a 'processed' field which is currently always set to True
* PEP8 cleanupsErik Johnston2014-08-151-2/+0
|
* Comment.Erik Johnston2014-08-151-0/+1
|
* Fix bug when generating a key when get_room_events_stream returned zero rowsErik Johnston2014-08-151-3/+7
|
* Actually use MAX_STREAM_SIZE constant.Erik Johnston2014-08-151-1/+1
|
* Fix pagination to work with new db schemaErik Johnston2014-08-151-7/+24
|
* Correctly return new token when returning events. Serialize events correctly.Erik Johnston2014-08-151-5/+13
|
* Start chagning the events stream to work with the new DB schemaErik Johnston2014-08-151-0/+31
|
* Fix up typos and correct sql queriesErik Johnston2014-08-141-7/+4
|
* Update StreamStoreErik Johnston2014-08-141-245/+36
|
* add in whitespace after copyright statements to improve legibilityMatthew Hodgson2014-08-131-0/+1
|
* Reference Matrix Home Servermatrix.org2014-08-121-0/+282
generated by cgit-pink 1.4.1 (git 2.36.1) at 2024-12-28 13:07:25 +0000