a38d7df106
go fmt
2026-02-04 14:37:40 +00:00
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
7b385bf163
minimize allocations in logger and tunnel code ( #1323 )
...
* logs alloc
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* fix allocs
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* fix allocs
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* tunnel allocs
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* try to fix tunnel
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* cache cipher for send
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* more logger
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* more logger
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* more logger
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* more logger
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* more logger
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* more logger
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* more logger
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2020-03-11 17:55:39 +00:00
8ee5607254
[WIP]: broker ErrorHandler option ( #1296 )
...
* broker ErrorHandler option
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* rewrite Event interface, add error
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* implement new interface
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* change ErrorHandler func to broker.Handler
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* fix
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2020-03-06 21:25:16 +00:00
d467236f8f
broker/nats: remove unused setPublishOption() ( #1234 )
...
broker/nats: remove unused setSubscribeOption()
2020-02-24 13:49:27 +00:00
117f56ebf7
prune util/log and user logger ( #1237 )
...
* prune util/log and user logger
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* plaintext logger
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* add newline
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2020-02-23 13:45:20 +00:00
79ad1e6fe3
various fixes for broker and messaging in server ( #1187 )
...
* provide broker disconnect messages in server
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* broker/eats: another fix
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2020-02-11 18:41:23 +00:00
2764de9a1a
broker/eats: broker disconnect fix ( #1186 )
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2020-02-11 15:46:50 +00: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
bdf1d20f4e
extract an ip that can be advertised in embedded nats
2020-01-18 15:39:26 +00:00
65df711b01
move nats local logic
2020-01-18 01:29:53 +00: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
a1eaf9cc20
linting fixes
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2019-12-04 00:22:02 +03: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
a29ce20e31
Changed default NATS address to nats://127.0.0.1:4222 in nats test
2019-06-06 12:06:14 +01:00
ca769444e7
set localhost for nats
2019-05-31 13:18:22 +01:00
1200386097
Add nats broker as a default
2019-05-29 16:46:57 +01:00
04e07f4b39
Move plugins to go-plugins
2015-11-25 00:17:15 +00:00
5d88115f2a
update links from myodc to micro
2015-11-20 16:17:33 +00:00
b91af916f9
Add pub/sub to client/server and make broker more low level
2015-06-12 19:52:27 +01:00
36b5ca46fe
Change initialisation and add metadata
2015-05-26 22:39:48 +01:00
32928bfb67
Publish/Subscribe with context
2015-05-23 23:16:26 +01:00
74fd1fc989
Restructure go-micro layout and plugins
2015-05-23 20:04:16 +01:00
asim