struct

NATS::JetStream::StreamConfig

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

Constructors

new(name : String, subjects : Nil | Array(String) = nil, description : Nil | String = nil, max_age : Time::Span | Nil = nil, max_bytes : Int64 | Nil = nil, max_msg_size : Int32 | Nil = nil, max_msgs : Int64 | Nil = nil, max_msgs_per_subject : Int64 | Nil = nil, max_consumers : Int32 | Nil = nil, no_ack : Bool | Nil = false, replicas : Int32 = 1, retention : RetentionPolicy | Nil = nil, allow_rollup_headers : Bool | Nil = nil, deny_delete : Bool | Nil = nil, allow_direct : Bool | Nil = nil, mirror_direct : Bool | Nil = nil, republish : NATS::JetStream::StreamConfig::Republish | Nil = nil, placement : NATS::JetStream::StreamConfig::Placement | Nil = nil, mirror : NATS::JetStream::StreamSource | Nil = nil, sources : Nil | Array(NATS::JetStream::StreamSource) = nil, discard_new_per_subject : Bool | Nil = nil, discard : DiscardPolicy | Nil = nil, allow_msg_ttl : Bool | Nil = false, allow_msg_counter : Bool | Nil = false, allow_msg_schedules : Bool | Nil = false, storage : Storage = :file, compression : NATS::JetStream::StreamConfig::Compression = :none)
Source

Instance methods

allow_direct?
Source
allow_msg_counter?
Source
allow_msg_schedules?
Source
allow_msg_ttl?
Source
allow_rollup_headers?
Source
compression
Source
deny_delete?
Source
deny_purge?
Source
description
Source
discard
Source
discard_new_per_subject?
Source
duplicate_window
Source
max_age
Source
max_bytes
Source
max_consumers
Source
max_msg_size
Source
max_msgs
Source
max_msgs_per_subject
Source
mirror
Source
mirror_direct?
Source
name

Name of this stream

Source
no_ack?
Source
placement
Source
replicas
Source
republish
Source
retention
Source
sealed?
Source
sources
Source
storage
Source
subjects

Which subjects this stream will listen for.

Source

Nested types