NATS::JetStream::StreamConfig
Inherits NATS::JetStream::Entity / JSON::Serializable / Struct / Value / Object
Constructors
new(pull : JSON::PullParser)
Sourcenew(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)
SourceInstance methods
allow_direct?
Sourceallow_msg_counter?
Sourceallow_msg_schedules?
Sourceallow_msg_ttl?
Sourceallow_rollup_headers?
Sourcecompression
Sourcedeny_delete?
Sourcedeny_purge?
Sourcedescription
Sourcediscard
Sourcediscard_new_per_subject?
Sourceduplicate_window
Sourcemax_age
Sourcemax_bytes
Sourcemax_consumers
Sourcemax_msg_size
Sourcemax_msgs
Sourcemax_msgs_per_subject
Sourcemirror
Sourcemirror_direct?
Sourceno_ack?
Sourceplacement
Sourcereplicas
Sourcerepublish
Sourceretention
Sourcesealed?
Sourcesources
Sourcestorage
Source