Commit Graph

79 Commits

Author SHA1 Message Date
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