Skip to content

Commit

Permalink
Add PausedUntil to consumer config
Browse files Browse the repository at this point in the history
Signed-off-by: Neil Twigg <neil@nats.io>
  • Loading branch information
neilalexander committed Feb 12, 2024
1 parent 3fd6eb5 commit d6f4e20
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 0 deletions.
3 changes: 3 additions & 0 deletions jetstream/consumer_config.go
Expand Up @@ -217,6 +217,9 @@ type (
// associating metadata on the consumer. This feature requires
// nats-server v2.10.0 or later.
Metadata map[string]string `json:"metadata,omitempty"`

// PauseUntil is for suspending the consumer until the deadline.
PauseUntil time.Time `json:"pause_until,omitempty"`
}

// OrderedConsumerConfig is the configuration of an ordered JetStream
Expand Down
3 changes: 3 additions & 0 deletions js.go
Expand Up @@ -1167,6 +1167,9 @@ type ConsumerConfig struct {
// Keys starting with `_nats` are reserved.
// NOTE: Metadata requires nats-server v2.10.0+
Metadata map[string]string `json:"metadata,omitempty"`

// PauseUntil is for suspending the consumer until the deadline.
PauseUntil time.Time `json:"pause_until,omitempty"`
}

// ConsumerInfo is the info from a JetStream consumer.
Expand Down

0 comments on commit d6f4e20

Please sign in to comment.