dendrite/setup/jetstream
Neil f4506a0d82
Refactor some JetStream helper code, add support for specifying JetStream domain (#3485)
This should gracefully handle some more potential errors that the
consumer fetches can return with retries, as well as setting some client
settings for reconnects etc when using an external NATS Server.

Also allow specifying the JetStream domain in case of a leafnode
scenario and better manage client reuse across Dendrite. And also update
NATS Server to 2.10.24 for good measure.

This code is backported from Harmony.

Signed-off-by: Neil Alexander <git@neilalexander.dev>

---------

Signed-off-by: Neil Alexander <git@neilalexander.dev>
Co-authored-by: Neil Alexander <neilalexander@users.noreply.github.com>
Co-authored-by: Till <2353100+S7evinK@users.noreply.github.com>
2025-01-19 09:09:58 +00:00
..
helpers.go Refactor some JetStream helper code, add support for specifying JetStream domain (#3485) 2025-01-19 09:09:58 +00:00
log.go Unify logging by using logrus for jetstream logs (#2976) 2023-02-24 08:56:53 +01:00
nats.go Refactor some JetStream helper code, add support for specifying JetStream domain (#3485) 2025-01-19 09:09:58 +00:00
streams.go Introduce a new stream for the appservice consumer (#3277) 2023-12-12 12:13:55 +01:00