-
-
Notifications
You must be signed in to change notification settings - Fork 26
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Refactor some JetStream helper code, add support for specifying JetStream domain #3485
Conversation
…ream domain Signed-off-by: Neil Alexander <[email protected]>
Signed-off-by: Neil Alexander <[email protected]>
4391466
to
f5a45e8
Compare
Codecov ReportAttention: Patch coverage is
Additional details and impacted files@@ Coverage Diff @@
## main #3485 +/- ##
==========================================
- Coverage 49.41% 49.37% -0.04%
==========================================
Files 524 524
Lines 59800 59814 +14
==========================================
- Hits 29548 29536 -12
- Misses 26769 26788 +19
- Partials 3483 3490 +7
Flags with carried forward coverage won't be shown. Click here to find out more. ☔ View full report in Codecov by Sentry. |
Signed-off-by: Neil Alexander <[email protected]>
Sytest is unhappy until #3471 is merged. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I've been running this since about this comment and didn't encounter any issues with Jetstream. So changes seem to work out. (Also tested restarting external NATS, which looks fine)
Thanks!
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 [email protected]