Skip to content

Commit 414d5eb

Browse files
authored
Merge pull request #1499 from ripienaar/dependencies
Update dependencies
2 parents 607ceaa + 6e4b381 commit 414d5eb

File tree

3 files changed

+12
-11
lines changed

3 files changed

+12
-11
lines changed

cli/stream_command.go

Lines changed: 9 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -220,6 +220,9 @@ func configureStreamCommand(app commandHost) {
220220
f.Flag("max-msgs-per-subject", "Maximum amount of messages to keep per subject").Default("0").Int64Var(&c.maxMsgPerSubjectLimit)
221221
f.Flag("dupe-window", "Duration of the duplicate message tracking window").Default("").StringVar(&c.dupeWindow)
222222
f.Flag("mirror", "Completely mirror another stream").StringVar(&c.mirror)
223+
if edit {
224+
f.Flag("no-mirror", "Removes current mirror configuration").UnNegatableBoolVar(&c.noMirror)
225+
}
223226
f.Flag("source", "Source data from other Streams, merging into this one").PlaceHolder("STREAM").StringsVar(&c.sources)
224227
f.Flag("allow-batch", "Allow atomic batch publishing").IsSetByUser(&c.allowAtomicBatchIsSet).BoolVar(&c.allowAtomicBatch)
225228
f.Flag("allow-counter", "Configures the Stream as a distributed counter").IsSetByUser(&c.allowCounterIsSet).UnNegatableBoolVar(&c.allowCounter)
@@ -233,22 +236,21 @@ func configureStreamCommand(app commandHost) {
233236
f.Flag("subject-del-markers-ttl", "How long delete markers should persist in the Stream").PlaceHolder("DURATION").IsSetByUser(&c.subjectDeleteMarkerTTLSet).DurationVar(&c.subjectDeleteMarkerTTL)
234237
f.Flag("transform-source", "Stream subject transform source").PlaceHolder("SOURCE").StringVar(&c.subjectTransformSource)
235238
f.Flag("transform-destination", "Stream subject transform destination").PlaceHolder("DEST").StringVar(&c.subjectTransformDest)
239+
if edit {
240+
f.Flag("no-transform", "Removes current subject transform configuration").UnNegatableBoolVar(&c.noSubjectTransform)
241+
}
236242
f.Flag("metadata", "Adds metadata to the stream").PlaceHolder("META").IsSetByUser(&c.metadataIsSet).StringMapVar(&c.metadata)
237243
f.Flag("republish-source", "Republish messages to --republish-destination").PlaceHolder("SOURCE").StringVar(&c.repubSource)
238244
f.Flag("republish-destination", "Republish destination for messages in --republish-source").PlaceHolder("DEST").StringVar(&c.repubDest)
239245
f.Flag("republish-headers", "Republish only message headers, no bodies").UnNegatableBoolVar(&c.repubHeadersOnly)
246+
if edit {
247+
f.Flag("no-republish", "Removes current republish configuration").UnNegatableBoolVar(&c.noRepub)
248+
}
240249
if !edit {
241250
f.Flag("limit-consumer-inactive", "The maximum Consumer inactive threshold the Stream allows").PlaceHolder("THRESHOLD").DurationVar(&c.limitInactiveThreshold)
242251
f.Flag("limit-consumer-max-pending", "The maximum Consumer Ack Pending the stream Allows").PlaceHolder("PENDING").IntVar(&c.limitMaxAckPending)
243252
f.Flag("persist-mode", "Configures the persistence mode").EnumVar(&c.persistMode, "default", "async")
244253
}
245-
246-
if edit {
247-
f.Flag("no-republish", "Removes current republish configuration").UnNegatableBoolVar(&c.noRepub)
248-
f.Flag("no-transform", "Removes current subject transform configuration").UnNegatableBoolVar(&c.noSubjectTransform)
249-
f.Flag("no-mirror", "Removes current mirror configuration").UnNegatableBoolVar(&c.noMirror)
250-
}
251-
252254
f.Flag("json", "Produce JSON output").Short('j').UnNegatableBoolVar(&c.json)
253255

254256
f.PreAction(c.parseLimitStrings)

go.mod

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ require (
2020
github.com/klauspost/compress v1.18.0
2121
github.com/nats-io/jsm.go v0.2.5-0.20250919104130-fa5c81909624
2222
github.com/nats-io/jwt/v2 v2.8.0
23-
github.com/nats-io/nats-server/v2 v2.12.0-preview.2.0.20250917115845-b2e3354fc02f
23+
github.com/nats-io/nats-server/v2 v2.12.0
2424
github.com/nats-io/nats.go v1.45.0
2525
github.com/nats-io/nkeys v0.4.11
2626
github.com/nats-io/nuid v1.0.1

go.sum

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -105,13 +105,12 @@ github.com/mitchellh/reflectwalk v1.0.2 h1:G2LzWKi524PWgd3mLHV8Y5k7s6XUvT0Gef6zx
105105
github.com/mitchellh/reflectwalk v1.0.2/go.mod h1:mSTlrgnPZtwu0c4WaC2kGObEpuNDbx0jmZXqmk4esnw=
106106
github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 h1:C3w9PqII01/Oq1c1nUAm88MOHcQC9l5mIlSMApZMrHA=
107107
github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822/go.mod h1:+n7T8mK8HuQTcFwEeznm/DIxMOiR9yIdICNftLE1DvQ=
108-
github.com/nats-io/jsm.go v0.2.5-0.20250918105311-ea5c3082c339/go.mod h1:XchaF3GV+nNpFH8+ogfYypH81yq+Llq+DkGEqV68EPs=
109108
github.com/nats-io/jsm.go v0.2.5-0.20250919104130-fa5c81909624 h1:oQwgv2Ce6OHPUDHZBHO9CwfXr4f1RCh7xuYyXixBI6k=
110109
github.com/nats-io/jsm.go v0.2.5-0.20250919104130-fa5c81909624/go.mod h1:XchaF3GV+nNpFH8+ogfYypH81yq+Llq+DkGEqV68EPs=
111110
github.com/nats-io/jwt/v2 v2.8.0 h1:K7uzyz50+yGZDO5o772eRE7atlcSEENpL7P+b74JV1g=
112111
github.com/nats-io/jwt/v2 v2.8.0/go.mod h1:me11pOkwObtcBNR8AiMrUbtVOUGkqYjMQZ6jnSdVUIA=
113-
github.com/nats-io/nats-server/v2 v2.12.0-preview.2.0.20250917115845-b2e3354fc02f h1:4uzVTq8yy2fB6H5jpYhc+Mq/OihZFYY0IkIbcqhHk1M=
114-
github.com/nats-io/nats-server/v2 v2.12.0-preview.2.0.20250917115845-b2e3354fc02f/go.mod h1:nr8dhzqkP5E/lDwmn+A2CvQPMd1yDKXQI7iGg3lAvww=
112+
github.com/nats-io/nats-server/v2 v2.12.0 h1:OIwe8jZUqJFrh+hhiyKu8snNib66qsx806OslqJuo74=
113+
github.com/nats-io/nats-server/v2 v2.12.0/go.mod h1:nr8dhzqkP5E/lDwmn+A2CvQPMd1yDKXQI7iGg3lAvww=
115114
github.com/nats-io/nats.go v1.45.0 h1:/wGPbnYXDM0pLKFjZTX+2JOw9TQPoIgTFrUaH97giwA=
116115
github.com/nats-io/nats.go v1.45.0/go.mod h1:iRWIPokVIFbVijxuMQq4y9ttaBTMe0SFdlZfMDd+33g=
117116
github.com/nats-io/nkeys v0.4.11 h1:q44qGV008kYd9W1b1nEBkNzvnWxtRSQ7A8BoqRrcfa0=

0 commit comments

Comments
 (0)