struct

NATS::JetStream::Consumer

Inherits NATS::JetStream::Entity / JSON::Serializable / Struct / Value / Object

Constructors

new(pull : JSON::PullParser)
Source

Instance methods

ack_floor

The number of messages that have been acknowledged for this consumer/stream

Source
cluster

Where this consumer's data lives in the cluster

Source
config

The configuration used to create this consumer (including its defaults)

Source
created

The timestamp when this consumer was created

Source
delivered

The number of times this consumer has delivered messages for this stream

Source
name

The name of this consumer

Source
num_ack_pending

The number of messages currently in-flight that are awaiting acknowledgement

Source
num_pending

The number of messages in the stream that this consumer has not delivered at all yet

Source
num_redelivered

The number of messages that have been redelivered

Source
num_waiting

The number of messages that are currently waiting

Source
push_bound?
Source
stream_name

The name of the stream this consumer sources its messages from

Source

Nested types