Skip to content

Commit 48244d3

Browse files
aholstensonaholstenson
committed
feat: Update github.com/nats-io/nats.go to v1.32.0
1 parent b5fbd01 commit 48244d3

5 files changed

Lines changed: 14 additions & 20 deletions

File tree

‎go.mod‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ require (
88
github.com/grpc-ecosystem/go-grpc-middleware/v2 v2.0.1
99
github.com/levelfourab/sprout-go v0.14.0
1010
github.com/nats-io/nats-server/v2 v2.10.7
11-
github.com/nats-io/nats.go v1.31.0
11+
github.com/nats-io/nats.go v1.32.0
1212
github.com/onsi/ginkgo/v2 v2.13.2
1313
github.com/onsi/gomega v1.30.0
1414
go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.46.1
@@ -49,7 +49,7 @@ require (
4949
github.com/kr/text v0.2.0 // indirect
5050
github.com/minio/highwayhash v1.0.2 // indirect
5151
github.com/nats-io/jwt/v2 v2.5.3 // indirect
52-
github.com/nats-io/nkeys v0.4.6 // indirect
52+
github.com/nats-io/nkeys v0.4.7 // indirect
5353
github.com/nats-io/nuid v1.0.1 // indirect
5454
github.com/opencontainers/runtime-spec v1.0.2 // indirect
5555
github.com/pkg/errors v0.9.1 // indirect
@@ -71,9 +71,9 @@ require (
7171
go.uber.org/automaxprocs v1.5.3 // indirect
7272
go.uber.org/dig v1.17.0 // indirect
7373
go.uber.org/multierr v1.11.0 // indirect
74-
golang.org/x/crypto v0.16.0 // indirect
74+
golang.org/x/crypto v0.18.0 // indirect
7575
golang.org/x/net v0.18.0 // indirect
76-
golang.org/x/sys v0.15.0 // indirect
76+
golang.org/x/sys v0.16.0 // indirect
7777
golang.org/x/text v0.14.0 // indirect
7878
golang.org/x/time v0.5.0 // indirect
7979
golang.org/x/tools v0.14.0 // indirect

‎go.sum‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -88,10 +88,10 @@ github.com/nats-io/jwt/v2 v2.5.3 h1:/9SWvzc6hTfamcgXJ3uYRpgj+QuY2aLNqRiqrKcrpEo=
8888
github.com/nats-io/jwt/v2 v2.5.3/go.mod h1:iysuPemFcc7p4IoYots3IuELSI4EDe9Y0bQMe+I3Bf4=
8989
github.com/nats-io/nats-server/v2 v2.10.7 h1:f5VDy+GMu7JyuFA0Fef+6TfulfCs5nBTgq7MMkFJx5Y=
9090
github.com/nats-io/nats-server/v2 v2.10.7/go.mod h1:V2JHOvPiPdtfDXTuEUsthUnCvSDeFrK4Xn9hRo6du7c=
91-
github.com/nats-io/nats.go v1.31.0 h1:/WFBHEc/dOKBF6qf1TZhrdEfTmOZ5JzdJ+Y3m6Y/p7E=
92-
github.com/nats-io/nats.go v1.31.0/go.mod h1:di3Bm5MLsoB4Bx61CBTsxuarI36WbhAwOm8QrW39+i8=
93-
github.com/nats-io/nkeys v0.4.6 h1:IzVe95ru2CT6ta874rt9saQRkWfe2nFj1NtvYSLqMzY=
94-
github.com/nats-io/nkeys v0.4.6/go.mod h1:4DxZNzenSVd1cYQoAa8948QY3QDjrHfcfVADymtkpts=
91+
github.com/nats-io/nats.go v1.32.0 h1:Bx9BZS+aXYlxW08k8Gd3yR2s73pV5XSoAQUyp1Kwvp0=
92+
github.com/nats-io/nats.go v1.32.0/go.mod h1:Ubdu4Nh9exXdSz0RVWRFBbRfrbSxOYd26oF0wkWclB8=
93+
github.com/nats-io/nkeys v0.4.7 h1:RwNJbbIdYCoClSDNY7QVKZlyb/wfT6ugvFCiKy6vDvI=
94+
github.com/nats-io/nkeys v0.4.7/go.mod h1:kqXRgRDPlGy7nGaEDMuYzmiJCIAAWDK0IMBtDmGD0nc=
9595
github.com/nats-io/nuid v1.0.1 h1:5iA8DT8V7q8WK2EScv2padNa/rTESc1KdnPw4TC2paw=
9696
github.com/nats-io/nuid v1.0.1/go.mod h1:19wcPz3Ph3q0Jbyiqsd0kePYG7A95tJPxeL+1OSON2c=
9797
github.com/onsi/ginkgo/v2 v2.13.2 h1:Bi2gGVkfn6gQcjNjZJVO8Gf0FHzMPf2phUei9tejVMs=
@@ -178,8 +178,8 @@ go.uber.org/zap v1.26.0/go.mod h1:dtElttAiwGvoJ/vj4IwHBS/gXsEu/pZ50mUIRWuG0so=
178178
golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
179179
golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
180180
golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
181-
golang.org/x/crypto v0.16.0 h1:mMMrFzRSCF0GvB7Ne27XVtVAaXLrPmgPC7/v0tkwHaY=
182-
golang.org/x/crypto v0.16.0/go.mod h1:gCAAfMLgwOJRpTjQ2zCCt2OcSfYMTeZVSRtQlPC7Nq4=
181+
golang.org/x/crypto v0.18.0 h1:PGVlW0xEltQnzFZ55hkuX5+KLyrMYhHld1YHO4AKcdc=
182+
golang.org/x/crypto v0.18.0/go.mod h1:R0j02AL6hcrfOiy9T4ZYp/rcWeMxM3L6QYxlOuEG1mg=
183183
golang.org/x/lint v0.0.0-20190930215403-16217165b5de/go.mod h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc=
184184
golang.org/x/mod v0.2.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA=
185185
golang.org/x/mod v0.3.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA=
@@ -207,8 +207,8 @@ golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7w
207207
golang.org/x/sys v0.0.0-20210330210617-4fbd30eecc44/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
208208
golang.org/x/sys v0.0.0-20210510120138-977fb7262007/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
209209
golang.org/x/sys v0.0.0-20220715151400-c0bba94af5f8/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
210-
golang.org/x/sys v0.15.0 h1:h48lPFYpsTvQJZF4EKyI4aLHaev3CxivZmv7yZig9pc=
211-
golang.org/x/sys v0.15.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
210+
golang.org/x/sys v0.16.0 h1:xWw16ngr6ZMtmxDyKyIgsE93KNKz5HKmMa3b8ALHidU=
211+
golang.org/x/sys v0.16.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
212212
golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
213213
golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
214214
golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=

‎internal/events/errors.go‎

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -8,10 +8,6 @@ var ErrPublishTimeout = errors.New("publish timeout")
88
// ErrUnboundSubject is used when a subject is not bound to a stream.
99
var ErrUnboundSubject = errors.New("unbound subject, no stream found for subject")
1010

11-
// ErrNoStreamResponse is used when a stream response is expected but none is received.
12-
// This is occurs when publishing events to a stream that does not exist.
13-
var ErrNoStreamResponse = errors.New("no stream response")
14-
1511
// ErrWrongSequence is used when the expected sequence number does not match the
1612
// actual sequence number.
1713
var ErrWrongSequence = errors.New("wrong sequence")

‎internal/events/events.go‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -107,7 +107,7 @@ func (m *Manager) Events(ctx context.Context, config *EventConsumeConfig) (*Even
107107
maxEvents = 1
108108
}
109109
messages, err := consumer.Messages(
110-
jetstream.PullExpiry(200*time.Millisecond),
110+
jetstream.PullExpiry(1*time.Second),
111111
jetstream.PullMaxMessages(maxEvents),
112112
)
113113
if err != nil {

‎internal/events/publish.go‎

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -126,9 +126,7 @@ func (m *Manager) Publish(ctx context.Context, config *PublishConfig) (*Publishe
126126
span.RecordError(err)
127127
span.SetStatus(codes.Error, "failed to publish message")
128128

129-
if errors.Is(err, jetstream.ErrNoStreamResponse) {
130-
return nil, ErrNoStreamResponse
131-
} else if errors.Is(err, nats.ErrNoResponders) {
129+
if errors.Is(err, jetstream.ErrNoStreamResponse) || errors.Is(err, nats.ErrNoResponders) {
132130
return nil, ErrUnboundSubject
133131
} else if errors.Is(err, nats.ErrTimeout) {
134132
return nil, ErrPublishTimeout

0 commit comments

Comments
 (0)