struct NATS::JetStream::Consumer

• NATS::JetStream::Consumer
• NATS::JetStream::Entity
• Struct
• Value
• Object

Defined in:

jetstream/consumer.cr

Constructors

• .new(pull : JSON::PullParser)

Instance Method Summary

• #ack_floor : Sequence

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

• #cluster : ClusterInfo | Nil

  Where this consumer's data lives in the cluster

• #config : ConsumerConfig

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

• #created : Time

  The timestamp when this consumer was created

• #delivered : Sequence

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

• #name : String

  The name of this consumer

• #num_ack_pending : Int64

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

• #num_pending : Int64

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

• #num_redelivered : Int64

  The number of messages that have been redelivered

• #num_waiting : Int64

  The number of messages that are currently waiting

• #push_bound? : Bool
• #stream_name : String

  The name of the stream this consumer sources its messages from

Constructor Detail

Instance Method Detail