Commit Graph

45 Commits

Author SHA1 Message Date
d5f177cc4e update workflows
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2022-03-05 19:07:59 +03:00
a5167a9a96 update import paths
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-10-27 23:01:59 +03:00
960033dfe2 use native nats headers
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-09-23 08:11:37 +03:00
13d35f035c update all
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-09-10 23:56:28 +03:00
4eae208e72 cleanup
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-03-24 23:19:12 +03:00
57dc17d58c use own fork
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-29 18:20:06 +03:00
Asim Aslam
d0a6c86597 replace config/cmd with cmd 2021-01-29 18:14:34 +03:00
72d07c504c broker error handler support and interface changes (#501)
* broker: update to micro broker changes

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-29 18:14:34 +03:00
907c0501d1 fix import path for v2 release (#457)
* fix import path for v2 release

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-29 18:14:34 +03:00
Asim Aslam
e144e143de Go fmt and update go mod 2021-01-29 18:14:34 +03:00
Asim Aslam
410418a7cc Update the location of data and cmd 2021-01-29 18:14:34 +03:00
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
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