Skip to content

Commit 08e7a85

Browse files
author
Tim Middleton
committed
More topics updates
1 parent bcb9984 commit 08e7a85

File tree

3 files changed

+10
-12
lines changed

3 files changed

+10
-12
lines changed

coherence/topics.go

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -162,8 +162,6 @@ func GetNamedTopic[V any](ctx context.Context, session *Session, topicName strin
162162
return nil, getExistingError("NamedTopic", topicName)
163163
}
164164

165-
// check any topic options
166-
167165
session.debug("using existing NamedTopic: %v", existing)
168166
return existing, nil
169167
}
@@ -349,7 +347,7 @@ func newPublisher[V any](session *Session, bt *baseTopicsClient[V], result *publ
349347
ordering := options.GetOrdering()
350348
if _, ok := ordering.(*publisher.OrderByDefault); ok {
351349
// set the defaultOrderSeed to a non -1 value which means to use this number for the channel
352-
//hash all the time.
350+
// hash all the time.
353351
// #nosec G404 -- math/rand is fine here for non-security use
354352
tp.defaultOrderingSeed = rand.Int32() % tp.channelCount
355353
}

go.mod

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -11,13 +11,13 @@ toolchain go1.23.7
1111

1212
require (
1313
github.com/google/uuid v1.6.0
14-
golang.org/x/text v0.26.0
14+
golang.org/x/text v0.28.0
1515
google.golang.org/grpc v1.73.0
1616
google.golang.org/protobuf v1.36.6
1717
)
1818

1919
require (
20-
golang.org/x/net v0.41.0 // indirect
21-
golang.org/x/sys v0.33.0 // indirect
20+
golang.org/x/net v0.43.0 // indirect
21+
golang.org/x/sys v0.35.0 // indirect
2222
google.golang.org/genproto/googleapis/rpc v0.0.0-20250528174236-200df99c418a // indirect
2323
)

go.sum

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -20,12 +20,12 @@ go.opentelemetry.io/otel/sdk/metric v1.35.0 h1:1RriWBmCKgkeHEhM7a2uMjMUfP7MsOF5J
2020
go.opentelemetry.io/otel/sdk/metric v1.35.0/go.mod h1:is6XYCUMpcKi+ZsOvfluY5YstFnhW0BidkR+gL+qN+w=
2121
go.opentelemetry.io/otel/trace v1.35.0 h1:dPpEfJu1sDIqruz7BHFG3c7528f6ddfSWfFDVt/xgMs=
2222
go.opentelemetry.io/otel/trace v1.35.0/go.mod h1:WUk7DtFp1Aw2MkvqGdwiXYDZZNvA/1J8o6xRXLrIkyc=
23-
golang.org/x/net v0.41.0 h1:vBTly1HeNPEn3wtREYfy4GZ/NECgw2Cnl+nK6Nz3uvw=
24-
golang.org/x/net v0.41.0/go.mod h1:B/K4NNqkfmg07DQYrbwvSluqCJOOXwUjeb/5lOisjbA=
25-
golang.org/x/sys v0.33.0 h1:q3i8TbbEz+JRD9ywIRlyRAQbM0qF7hu24q3teo2hbuw=
26-
golang.org/x/sys v0.33.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k=
27-
golang.org/x/text v0.26.0 h1:P42AVeLghgTYr4+xUnTRKDMqpar+PtX7KWuNQL21L8M=
28-
golang.org/x/text v0.26.0/go.mod h1:QK15LZJUUQVJxhz7wXgxSy/CJaTFjd0G+YLonydOVQA=
23+
golang.org/x/net v0.43.0 h1:lat02VYK2j4aLzMzecihNvTlJNQUq316m2Mr9rnM6YE=
24+
golang.org/x/net v0.43.0/go.mod h1:vhO1fvI4dGsIjh73sWfUVjj3N7CA9WkKJNQm2svM6Jg=
25+
golang.org/x/sys v0.35.0 h1:vz1N37gP5bs89s7He8XuIYXpyY0+QlsKmzipCbUtyxI=
26+
golang.org/x/sys v0.35.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k=
27+
golang.org/x/text v0.28.0 h1:rhazDwis8INMIwQ4tpjLDzUhx6RlXqZNPEM0huQojng=
28+
golang.org/x/text v0.28.0/go.mod h1:U8nCwOR8jO/marOQ0QbDiOngZVEBB7MAiitBuMjXiNU=
2929
google.golang.org/genproto/googleapis/rpc v0.0.0-20250528174236-200df99c418a h1:v2PbRU4K3llS09c7zodFpNePeamkAwG3mPrAery9VeE=
3030
google.golang.org/genproto/googleapis/rpc v0.0.0-20250528174236-200df99c418a/go.mod h1:qQ0YXyHHx3XkvlzUtpXDkS29lDSafHMZBAZDc03LQ3A=
3131
google.golang.org/grpc v1.73.0 h1:VIWSmpI2MegBtTuFt5/JWy2oXxtjJ/e89Z70ImfD2ok=

0 commit comments

Comments
 (0)