|
|
29684f038e
|
nats: use new repo path
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2021-01-29 18:14:34 +03:00 |
|
magodo
|
4ac1ad4a6b
|
DrainXXX options for nats broker and subscriber
|
2021-01-29 18:14:34 +03:00 |
|
magodo
|
20453c885d
|
Revert "Use Drain() to unsuscribe or close connection"
This reverts commit 4d5859307ddbcc3c6af907ba0d0fac395b466836.
|
2021-01-29 18:14:34 +03:00 |
|
magodo
|
e2254ba411
|
Use Drain() to unsuscribe or close connection
|
2021-01-29 18:14:34 +03:00 |
|
maru
|
29bf388131
|
broker/nats.Connect: avoid conn leaks
|
2021-01-29 18:14:34 +03:00 |
|
|
|
ae10eb2ab8
|
propagate context and SuccessAutoAck option other brokers
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2021-01-29 18:14:34 +03:00 |
|
Asim Aslam
|
504bebc2e7
|
gofmt
|
2021-01-29 18:14:34 +03:00 |
|
Asim Aslam
|
0f64485fd7
|
update to match codec
|
2021-01-29 18:14:34 +03:00 |
|
Asim Aslam
|
4776921d4d
|
fix race condition in nats broker
|
2021-01-29 18:14:34 +03:00 |
|
Shannon Wynter
|
a3fcb74f93
|
Make nats reusable after disconnection
|
2021-01-29 18:14:34 +03:00 |
|
Stefan Obradovic
|
109f13d3f2
|
refactor(import): updated to use the new import path for go-nats
|
2021-01-29 18:14:34 +03:00 |
|
Asim Aslam
|
952a716c38
|
switch to stdlib context
|
2021-01-29 18:14:34 +03:00 |
|
Asim Aslam
|
3d5c81f672
|
syntactic sugar
|
2021-01-29 18:14:34 +03:00 |
|
Tobias Wellnitz, DH1TW
|
0b9f78d3ee
|
use golang.org/x/net/context instead of context package
|
2021-01-29 18:14:34 +03:00 |
|
Tobias Wellnitz, DH1TW
|
1bacad1fe8
|
simplified nats Option injection via Context
|
2021-01-29 18:14:34 +03:00 |
|
Tobias Wellnitz, DH1TW
|
45eff71f26
|
use golang.org/x/net/context instead of context.Context
|
2021-01-29 18:14:34 +03:00 |
|
Tobias Wellnitz, DH1TW
|
a78cdc8394
|
add option to inject nats.Options
|
2021-01-29 18:14:34 +03:00 |
|
darren-west
|
c67ac99441
|
added test for address and updated addrs to return real conn address
|
2021-01-29 18:14:34 +03:00 |
|
darren-west
|
260b112006
|
fixed setting of address through Init() function.
|
2021-01-29 18:14:34 +03:00 |
|
Asim Aslam
|
8898b42bda
|
use msg.Subject as topic
|
2021-01-29 18:14:34 +03:00 |
|
Asim Aslam
|
040c291e74
|
Add package comments
|
2021-01-29 18:14:34 +03:00 |
|
Asim Aslam
|
2f94cdd04c
|
fix double pointer for nats unmarshal
|
2021-01-29 18:14:34 +03:00 |
|
Asim Aslam
|
f8714d4cd9
|
We now support configurable codecs for broker
|
2021-01-29 18:14:34 +03:00 |
|
Asim
|
90f40cbad4
|
gofmt
|
2021-01-29 18:14:34 +03:00 |
|
Philipp Brüll
|
663066634d
|
set missing options
|
2021-01-29 18:14:34 +03:00 |
|
云景
|
f2882044cc
|
Replace nats package import path
|
2021-01-29 18:14:34 +03:00 |
|
Asim
|
a0e851fa4d
|
Update to match go-micro interface
|
2021-01-29 18:14:34 +03:00 |
|
Asim
|
0745de181c
|
Update to check tls config
|
2021-01-29 18:14:34 +03:00 |
|
Asim
|
96937ae487
|
Update to support tls config options
|
2021-01-29 18:14:34 +03:00 |
|
Asim
|
bf60028cf1
|
Support secure nats option
|
2021-01-29 18:14:34 +03:00 |
|
Asim
|
dd4a69b4a2
|
Update defaults
|
2021-01-29 18:14:34 +03:00 |
|
Asim
|
b71300b45b
|
Update to match go-micro options
|
2021-01-29 18:14:34 +03:00 |
|
Asim
|
a9dc71f4ad
|
update broker to match go-micro broker, TODO: finish rabbitmq queue fanout
|
2021-01-29 18:14:34 +03:00 |
|
Asim
|
56cf033626
|
Add String method to all interfaces
|
2021-01-29 18:14:34 +03:00 |
|
Asim
|
b73ddd8a03
|
Moving plugins to go-plugins
|
2021-01-29 18:14:34 +03:00 |
|
