diff options
| author | Till <2353100+S7evinK@users.noreply.github.com> | 2022-08-09 11:15:58 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-08-09 11:15:58 +0200 |
| commit | 240ae257deb74b7be8a17500b77d5e1bca56e8f5 (patch) | |
| tree | aff298447bf98b601cc6bfb7b14f1ada006db83a /federationapi/queue | |
| parent | e930959e4911453ec51bba0b1469f4b15c594f32 (diff) | |
Add housekeeping function to delete old/expired EDUs (#2399)
* Add housekeeping function to delete old/expired EDUs
* Add migrations
* Evict EDUs from cache
* Fix queries
* Fix upgrade
* Use map[string]time.Duration to specify different expiry times
* Fix copy & paste mistake
* Set expires_at to tomorrow
* Don't allow NULL
* Add comment
* Add tests
* Use new testrig package
* Fix migrations
* Never expire m.direct_to_device
Co-authored-by: Neil Alexander <neilalexander@users.noreply.github.com>
Co-authored-by: kegsay <kegan@matrix.org>
Diffstat (limited to 'federationapi/queue')
| -rw-r--r-- | federationapi/queue/destinationqueue.go | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/federationapi/queue/destinationqueue.go b/federationapi/queue/destinationqueue.go index b6edec5d..0d937ffa 100644 --- a/federationapi/queue/destinationqueue.go +++ b/federationapi/queue/destinationqueue.go @@ -127,6 +127,7 @@ func (oq *destinationQueue) sendEDU(event *gomatrixserverlib.EDU, receipt *share oq.destination, // the destination server name receipt, // NIDs from federationapi_queue_json table event.Type, + nil, // this will use the default expireEDUTypes map ); err != nil { logrus.WithError(err).Errorf("failed to associate EDU with destination %q", oq.destination) return |