Commit Graph

14 Commits

Author SHA1 Message Date
Piotr Piotrowski
a06b6a92ee [IMPROVED] Move CI to github actions (#1623)
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
2024-09-05 11:12:17 +02:00
Piotr Piotrowski
6570ee2c8e [FIXED] Get rid of server dev dependencies in nats package (#1441)
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
Co-authored-by: masumomo <masumotomiki18@gmail.com>
2023-10-15 18:59:15 +02:00
Piotr Piotrowski
26b4ed8f3a Add coverage report for jetstream
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
2023-05-23 17:21:32 +02:00
Ivan Kozlovic
787e58b7c5 Updated TLS certs, move to Go 1.18, fix code due staticcheck report
Fixed a TLS test that fails on macOS but passes on Linux.

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2022-07-29 11:35:42 -06:00
Ivan Kozlovic
e3f6eb03d4 Updated server version and adjusted tests
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2022-04-15 19:33:47 -06:00
Ivan Kozlovic
752408408a Run coverage, but push to coverall only after_success
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-09-20 12:56:43 -06:00
Ivan Kozlovic
45b7e7725b JetStream: lot of changes
They will be described in the release notes, but gist:

Added:
- `DeliverSubject()` option to configure the deliver subject of a JetStream consumer created by the `js.Subscribe()` call (and variants)
- `BindDeliverSubject()` option to subscribe directly to a JetStream consumer deliver subject (bypassing any lookup or JetStream consumer creation)
- Fields `DeliverGroup` in `ConsumerConfig`, `PushBound` in `ConsumerInfo`. They help making prevent incorrect subscriptions to JetStream consumers
- Field `Last` in `SequencePair`

Changed:
- With a `PullSubscription`, calling `NextMsg()` or `NextMsgWithContext()` will now return `ErrTypeSubscription`. You must use the `Fetch()` API
- If the library created internally a JetStream consumer, the consumer will be deleted on `Unsubscribe()` or when the `Drain()` completes
- Fail multiple instances of a subscription on the same durable push consumer (only one active at a time). Also, consumers now have the concept of `DeliverGroup`, which is the queue group name they are created for. Only queue member from the same group can attach to this consumer, and a non queue subscription cannot attach to it. Note that this requires server v2.3.5
- Attempting to create a queue subscription with a consumer configuration that has idle heartbeats and/or flow control will now result in an error

Fixed:
- Possible lock inversion
- JetStream consumers could be incorrectly deleted on subscription's `Unsubscribe()`

Resolves #785
Resolves #776
Resolves #775
Resolves #748
Resolves #747

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-08-15 11:47:32 -06:00
Waldemar Quevedo
d3341963d9 Add go_test.mod and minimal go.mod
Signed-off-by: Waldemar Quevedo <wally@synadia.com>
2021-04-05 12:49:42 -07:00
Ivan Kozlovic
b4437f154b [FIXED] Data race between processMsg() and Stats()
Resolves #520

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2019-09-17 09:07:18 -06:00
Derek Collison
234e9d8119 Updates for rename and go.mod support
Signed-off-by: Derek Collison <derek@nats.io>
2019-05-10 13:24:55 -07:00
Peter Miron
acf11e4666 refactored to remove exported gnatsd dependency. (#315)
* refactored to remove exported gnatsd dependency.

* updated with prefix and coverage tests to accurately get coverage numbers for encoders packages.

* resolving coverage change issues.

* eliminated extra run of test for coverage.

* include -race in coverage

* updated to remove variable. thx @wallyqs
2017-08-18 14:11:32 -04:00
Derek Collison
c1c9ec3f56 Rename of repo to go-nats 2016-11-20 11:50:22 -08:00
Derek Collison
43c8fecf5e Remove channels for async subscribers, better slow consumer, etc 2016-01-17 17:05:00 -08:00
Derek Collison
0910dfc2e4 Better coverage support 2016-01-17 09:42:35 -08:00