Nick Mills-Barrett 21eeacc995

Federation Sender & Appservice Pusher Stream Optimisations (#13251) ...

* Replace `get_new_events_for_appservice` with `get_all_new_events_stream`

The functions were near identical and this brings the AS worker closer
to the way federation senders work which can allow for multiple workers
to handle AS traffic.

* Pull received TS alongside events when processing the stream

This avoids an extra query -per event- when both federation sender
and appservice pusher process events.

2022-07-15 09:36:56 +01:00

..

__init__.py

Federation Sender & Appservice Pusher Stream Optimisations (#13251)

2022-07-15 09:36:56 +01:00

per_destination_queue.py

Reduce amount of state we pull out when attempting to send catchup PDUs. (#12963)

2022-06-07 14:35:56 +01:00

transaction_manager.py

Additional constants for EDU types. (#12884)

2022-05-27 07:14:36 -04:00