75e32f4d87
Implement NATS connection pooling and fix connection leaks ( #2840 )
...
* Initial plan
* Implement NATS connection pool with configuration options
Co-authored-by: asim <17530+asim@users.noreply.github.com >
* Implement connection pool for transport/nats
Co-authored-by: asim <17530+asim@users.noreply.github.com >
* Fix connection leaks in events/natsjs and config/source/nats
Co-authored-by: asim <17530+asim@users.noreply.github.com >
* Fix race condition in connection pool lastUsed field access
Co-authored-by: asim <17530+asim@users.noreply.github.com >
* Remove unused maxIdle field from connection pools
Co-authored-by: asim <17530+asim@users.noreply.github.com >
---------
Co-authored-by: copilot-swe-agent[bot] <198982749+Copilot@users.noreply.github.com >
Co-authored-by: asim <17530+asim@users.noreply.github.com >
2026-02-03 11:43:45 +00:00
cd2b40ca4a
Add a selection of plugins to the core repo ( #2755 )
...
* WIP
* fix: default memory registry, add registrations for mdns, nats
* fix: same for broker
* fix: add more
* fix: http port
* rename redis
* chore: linting
2025-05-15 18:47:35 +01:00
a7c31a0d2b
refactor all the things
2020-12-29 15:49:26 +00:00
3ce2ab88f5
broker/nats: remove embed nats server reference ( #1527 )
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2020-04-11 22:37:29 +03:00
f23638c036
fix import paths for v2 release
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2020-01-30 14:44:40 +03:00
1d311ab457
Embedded NATS Broker ( #1110 )
...
* if the address is produced by a default route don't hash it
* embedded nats
* fix url parsing
* don't override help
* add ready flag
2020-01-14 13:23:16 +00:00
0baea58938
wait nats drain since it's asynchronous
...
1. nats subscription draining is removed, since it is asynchronous,
and there is no reliable way to detect when it is finished.
Remove this option to avoid confusion.
2. nats connection draining is kept, and use 2 callbacks to detect
draining timeout (timeout is set via `nats.Options`) or finish.
3. Also honour options passed in `broker.Init()` (previously only
`broker.New()` is honoured).
2019-08-07 17:58:45 +08:00
1200386097
Add nats broker as a default
2019-05-29 16:46:57 +01:00
Copilot