From f57444b21a5fef3de9f14bcaa7615a2c020698b2 Mon Sep 17 00:00:00 2001 From: roeschter Date: Mon, 11 May 2026 19:43:23 +0200 Subject: [PATCH] doc enhancements --- cli/consumer_command.go | 2 +- cli/stream_command.go | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/cli/consumer_command.go b/cli/consumer_command.go index edc39716..9650f1b3 100644 --- a/cli/consumer_command.go +++ b/cli/consumer_command.go @@ -154,7 +154,7 @@ func configureConsumerCommand(app commandHost) { } f.Flag("filter", "Filter Stream by subjects").PlaceHolder("SUBJECTS").StringsVar(&c.filterSubjects) if !edit { - f.Flag("flow-control", "Enable Push consumer flow control").IsSetByUser(&c.fcSet).UnNegatableBoolVar(&c.fc) + f.Flag("flow-control", "Enable Push consumer flow control. Note: This is distinct from the 'flow_control` ack mode.").IsSetByUser(&c.fcSet).UnNegatableBoolVar(&c.fc) f.Flag("heartbeat", "Enable idle Push consumer heartbeats (-1 disable)").StringVar(&c.idleHeartbeat) } diff --git a/cli/stream_command.go b/cli/stream_command.go index 04d60772..b27d0aec 100644 --- a/cli/stream_command.go +++ b/cli/stream_command.go @@ -222,11 +222,11 @@ func configureStreamCommand(app commandHost) { f.Flag("max-msgs", "Maximum amount of messages to keep").Default("0").Int64Var(&c.maxMsgLimit) f.Flag("max-msgs-per-subject", "Maximum amount of messages to keep per subject").Default("0").Int64Var(&c.maxMsgPerSubjectLimit) f.Flag("dupe-window", "Duration of the duplicate message tracking window").Default("").StringVar(&c.dupeWindow) - f.Flag("mirror", "Completely mirror another stream").StringVar(&c.mirror) + f.Flag("mirror", "Completely mirror another stream. Accepts mirror config as JSON. ").StringVar(&c.mirror) if edit { f.Flag("no-mirror", "Removes current mirror configuration").UnNegatableBoolVar(&c.noMirror) } - f.Flag("source", "Source data from other streams, merging into this one").PlaceHolder("STREAM").StringsVar(&c.sources) + f.Flag("source", "Source data from other streams, merging into this one. Accepts source config as JSON.").PlaceHolder("STREAM").StringsVar(&c.sources) f.Flag("allow-batch", "Allow atomic batch publishing").IsSetByUser(&c.allowAtomicBatchIsSet).BoolVar(&c.allowAtomicBatch) f.Flag("allow-fast", "Allow fast batch publishing").IsSetByUser(&c.allowFastBatchIsSet).BoolVar(&c.allowFastBatch) f.Flag("allow-counter", "Configures the stream as a distributed counter").IsSetByUser(&c.allowCounterIsSet).UnNegatableBoolVar(&c.allowCounter)