struct NATS::JetStream::StreamConfig::ConsumerLimits

Overview

Defaults for consumers created on this stream, unless overridden in the consumer's config

Defined in:

jetstream/stream_config.cr

Constructors

Instance Method Summary

Constructor methods inherited from struct NATS::JetStream::Entity

new(pull : JSON::PullParser)
new(*, __pull_for_json_serializable pull : JSON::PullParser)
new

Constructor Detail

def self.new(pull : JSON::PullParser) #

Defaults for consumers created on this stream, unless overridden in the consumer's config


[View source]
def self.new(*, inactive_threshold : Time::Span | Nil = nil, max_ack_pending : Int32 | Nil = nil) #

[View source]

Instance Method Detail

def inactive_threshold : Time::Span | Nil #

[View source]
def max_ack_pending : Int32 | Nil #

[View source]