Commit Graph

173 Commits

Author SHA1 Message Date
ba47d82a5c fix import path for v2 release (#457)
* fix import path for v2 release

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-10 14:44:02 +03:00
19f60de8b9 go.mod per package (#450)
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-10 14:44:01 +03:00
438f53348e linting fixes, go.mod fixes
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-10 14:44:01 +03:00
Asim Aslam
d438bee8bf Go fmt and update go mod 2021-01-10 14:44:01 +03:00
a28169de2e stan broker, fix race on subscribe
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-10 14:44:01 +03:00
Asim Aslam
c55078a1c3 Update the location of data and cmd 2021-01-10 14:44:01 +03:00
09f946bd6b stan: fix error when multiple times calling Connect method
dont overwrite passed options to avoid error:
impossible to use custom ConnectionLostCB and ConnectRetry(true)

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-10 14:44:01 +03:00
44de02e879 stan: fix data race in Connect()
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-10 14:44:01 +03:00
Asim Aslam
7d84f2005b gofmt 2021-01-10 14:44:01 +03:00
Asim Aslam
2fcc1dbf5d change logger 2021-01-10 14:44:01 +03:00
fztcjjl
1291ceb68c use new NATS streaming client repo path 2021-01-10 14:44:01 +03:00
fztcjjl
54a1eae3e2 durable subscriptions for nats streaming 2021-01-10 14:44:01 +03:00
LocTD
de6f824e4a Provide a way to set native SubscriptionOption for stan broker through server.SubscriberOption 2021-01-10 14:44:01 +03:00
e545f8cbc4 broker stan: fix data race
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-10 14:44:01 +03:00
Yumin Wu
bf0aecf4f6 fix go-nats-streaming clientID 2021-01-10 14:44:01 +03:00
Yumin Wu
5e260a4cfa go-nats-streaming clientID 2021-01-10 14:44:01 +03:00
8d0a3fba24 broker: [stan] rework option naming, fix messages
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-10 14:44:01 +03:00
c37100b7e2 broker: stan add Reconnect and Timeout
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-10 14:44:01 +03:00
Asim Aslam
d2ea46c139 update comment 2021-01-10 14:44:01 +03:00
Asim Aslam
31d9c7f289 Rename SuccessAutoAck to AckOnSuccess 2021-01-10 14:44:01 +03:00
Asim Aslam
6eb8ae50d5 simplify stan handler error handling 2021-01-10 14:44:01 +03:00
6c04d1a29b propagate context and SuccessAutoAck option other brokers
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-10 14:44:01 +03:00
c5fc37933f initial import of stan - nats streaming broker
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-10 14:44:01 +03:00