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, first_seq : UInt64 | Nil = nil, subject_transform : NATS::JetStream::SubjectTransform | Nil = nil, consumer_limits : NATS::JetStream::StreamConfig::ConsumerLimits | Nil = nil, subject_delete_marker_ttl : Time::Span | Nil = nil, allow_atomic_publish : Bool | Nil = nil, allow_batch_publish : Bool | Nil = nil, persist_mode : PersistMode | Nil = nil, metadata : Nil | Hash(String, String) = nil, storage : Storage = :file, compression : NATS::JetStream::StreamConfig::Compression = :none)
SourceInstance methods
allow_atomic_publish?
Sourceallow_batch_publish?
Sourceallow_direct?
Sourceallow_msg_counter?
Sourceallow_msg_schedules?
Sourceallow_msg_ttl?
Sourceallow_rollup_headers?
Sourcecompression
Sourceconsumer_limits
Sourcecopy_with
Returns a copy of this config with the given settings changed, leaving this one untouched.
config.copy_with(max_age: 7.days, max_msgs: 1_000_000_i64)
deny_delete?
Sourcedeny_purge?
Sourcedescription
Sourcediscard
Sourcediscard_new_per_subject?
Sourceduplicate_window
Sourcefirst_seq
Sourcemax_age
Sourcemax_bytes
Sourcemax_consumers
Sourcemax_msg_size
Sourcemax_msgs
Sourcemax_msgs_per_subject
Sourcemetadata
Sourcemirror
Sourcemirror_direct?
Sourceno_ack?
Sourcepersist_mode
Sourceplacement
Sourcereplicas
Sourcerepublish
Sourceretention
Sourcesealed?
Sourcesources
Sourcestorage
Sourcesubject_delete_marker_ttl
Sourcesubject_transform
SourceNested types
- NATS::JetStream::StreamConfig::Compression
- NATS::JetStream::StreamConfig::ConsumerLimits
- NATS::JetStream::StreamConfig::DiscardPolicy
- NATS::JetStream::StreamConfig::PersistMode
- NATS::JetStream::StreamConfig::Placement
- NATS::JetStream::StreamConfig::Republish
- NATS::JetStream::StreamConfig::RetentionPolicy
- NATS::JetStream::StreamConfig::Storage