mirror of
https://github.com/hanzoai/pubsub-go.git
synced 2026-10-30 18:23:30 +00:00
07b5d2b282
* Release v1.49.0 (#2025) Signed-off-by: Piotr Piotrowski <[email protected]> * [FIXED] Remove conn status listener on Consume and Messages cleanup (#2027) Signed-off-by: txuna <[email protected]> * Add agent reviews (#2035) Signed-off-by: Tomasz Pietrek <[email protected]> * [IMPROVED] Bump CI Go versions to 1.25/1.26 and simplify version management (#2039) Signed-off-by: Piotr Piotrowski <[email protected]> * [IMPROVED] Reject control characters in stream and consumer names (#2038) Signed-off-by: Piotr Piotrowski <[email protected]> * [IMPROVED] Deduplicate keys in KeyValue.Keys() and document ListKeys behavior (#2029) Un-deprecate Keys() and add deduplication using slices.Sort + slices.Compact to handle cases where the server returns duplicate keys during concurrent writes. Add documentation notes to ListKeys and ListKeysFiltered warning about possible duplicates on large buckets with frequent writes. Signed-off-by: Piotr Piotrowski <[email protected]> * Add missing AccountLimits fields in jetstream package (#2041) Signed-off-by: Piotr Piotrowski <[email protected]> * [IMPROVED] Bump dependencies and go version (#2044) Signed-off-by: Piotr Piotrowski <[email protected]> * [FIXED] Fix race condition in orderedSubscription.Drain() (#2030) Signed-off-by: Piotr Piotrowski <[email protected]> * [FIXED] Fix flaky TestConsumerPrioritized/messages test (#2033) Signed-off-by: Piotr Piotrowski <[email protected]> * [IMPROVED] De-flake TestAlwaysReconnectOnAccountMaxConnectionsExceededErr (#2042) Signed-off-by: Piotr Piotrowski <[email protected]> * [FIXED] Fix flaky TestKeyValueWithSources test (#2036) * [FIXED] Fix flaky TestKeyValueWithSources test Signed-off-by: Piotr Piotrowski <[email protected]> * Adjust timeout in test Signed-off-by: Piotr Piotrowski <[email protected]> * trigger ci Signed-off-by: Piotr Piotrowski <[email protected]> --------- Signed-off-by: Piotr Piotrowski <[email protected]> * [FIXED] Fixed OrderedConsumer.Consume race in handler (#2043) Signed-off-by: Piotr Piotrowski <[email protected]> * [FIXED] WebSocket close frame discarding buffered data frames (#2032) When a NATS server rejects a WebSocket connection (e.g., due to an expired JWT), it sends a -ERR protocol message followed by a WebSocket close frame. If both frames arrive in the same TCP read, the websocketReader.Read() method would process the close frame and immediately return io.EOF, discarding the -ERR data that had already been buffered in the pending list. This caused nats.Connect to return a generic EOF error instead of the proper authentication error (ErrAuthorization, ErrAuthExpired, etc.), making it difficult for users to diagnose connection failures. The fix defers the close frame's io.EOF when there is already pending data, storing it in a new closeErr field. The pending data is returned first, and the deferred error is returned on the subsequent Read() call. Signed-off-by: Waldemar Quevedo <[email protected]> * [IMPROVED] Wrap EOF/connection reset errors with TLS context after handshake (#2031) * Wrap EOF/connection reset errors with TLS context after handshake When a TLS proxy (e.g. nginx with mTLS) completes the TLS handshake but then closes the connection due to an untrusted client certificate, the client would receive a bare "EOF" or "connection reset by peer" with no indication that TLS was involved. This wraps such errors with context: "nats: connection closed by remote after TLS handshake: EOF" The wrapped error preserves the original via %w for backwards compatibility (errors.Is(err, io.EOF) still returns true). Signed-off-by: Waldemar Quevedo <[email protected]> * Wrap TLS errors in ErrTLS Signed-off-by: Piotr Piotrowski <[email protected]> --------- Signed-off-by: Waldemar Quevedo <[email protected]> Signed-off-by: Piotr Piotrowski <[email protected]> Co-authored-by: Piotr Piotrowski <[email protected]> * Release v1.50.0 (#2045) Signed-off-by: Piotr Piotrowski <[email protected]> --------- Signed-off-by: Piotr Piotrowski <[email protected]> Signed-off-by: txuna <[email protected]> Signed-off-by: Tomasz Pietrek <[email protected]> Signed-off-by: Waldemar Quevedo <[email protected]> Co-authored-by: Piotr Piotrowski <[email protected]> Co-authored-by: tuuna <[email protected]> Co-authored-by: Tomasz Pietrek <[email protected]> Co-authored-by: Waldemar Quevedo <[email protected]>
23 lines
642 B
AMPL
23 lines
642 B
AMPL
module github.com/nats-io/nats.go
|
|
|
|
go 1.25.0
|
|
|
|
require (
|
|
github.com/golang/protobuf v1.5.4
|
|
github.com/klauspost/compress v1.18.5
|
|
github.com/nats-io/jwt/v2 v2.8.1
|
|
github.com/nats-io/nats-server/v2 v2.12.6
|
|
github.com/nats-io/nkeys v0.4.15
|
|
github.com/nats-io/nuid v1.0.1
|
|
google.golang.org/protobuf v1.33.0
|
|
)
|
|
|
|
require (
|
|
github.com/antithesishq/antithesis-sdk-go v0.6.0-default-no-op // indirect
|
|
github.com/google/go-tpm v0.9.8 // indirect
|
|
github.com/minio/highwayhash v1.0.4-0.20251030100505-070ab1a87a76 // indirect
|
|
golang.org/x/crypto v0.49.0 // indirect
|
|
golang.org/x/sys v0.42.0 // indirect
|
|
golang.org/x/time v0.15.0 // indirect
|
|
)
|