Skip to content

Commit

Permalink
Update InactiveThreshold comments
Browse files Browse the repository at this point in the history
These hadn't been updated after nats-io/nats-server#3190 seemingly.
  • Loading branch information
neilalexander authored Oct 14, 2022
1 parent 885ad13 commit d5eb48b
Showing 1 changed file with 7 additions and 3 deletions.
10 changes: 7 additions & 3 deletions js.go
Original file line number Diff line number Diff line change
Expand Up @@ -1088,7 +1088,7 @@ type ConsumerConfig struct {
DeliverSubject string `json:"deliver_subject,omitempty"`
DeliverGroup string `json:"deliver_group,omitempty"`

// Ephemeral inactivity threshold.
// Inactivity threshold.
InactiveThreshold time.Duration `json:"inactive_threshold,omitempty"`

// Generally inherited by parent stream and other markers, now can be configured directly.
Expand Down Expand Up @@ -2465,8 +2465,12 @@ func MaxRequestMaxBytes(bytes int) SubOpt {
})
}

// InactiveThreshold indicates how long the server should keep an ephemeral
// after detecting loss of interest.
// InactiveThreshold indicates how long the server should keep an consumer
// after detecting a loss of interest. In NATS Server 2.8.4 and earlier, this
// option only applies to ephemeral consumers. In NATS Server 2.9.0 and later,
// this option applies to both ephemeral and durable consumers, allowing durable
// consumers to also be deleted automatically after the inactivity threshold has
// passed.
func InactiveThreshold(threshold time.Duration) SubOpt {
return subOptFn(func(opts *subOpts) error {
if threshold < 0 {
Expand Down

0 comments on commit d5eb48b

Please sign in to comment.