struct NATS::JetStream::StreamConfig

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

Defined in:

Constructors

• .new(pull : JSON::PullParser)
• .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, storage : Storage = :file)

Instance Method Summary

• #allow_direct? : Bool | Nil
• #allow_rollup_headers? : Bool | Nil
• #deny_delete? : Bool | Nil
• #deny_purge? : Bool | Nil
• #description : String | Nil
• #discard : DiscardPolicy | Nil
• #discard_new_per_subject? : Bool | Nil
• #duplicate_window : Time::Span | Nil
• #max_age : Time::Span | Nil
• #max_bytes : Int64 | Nil
• #max_consumers : Int32 | Nil
• #max_msg_size : Int32 | Nil
• #max_msgs : Int64 | Nil
• #max_msgs_per_subject : Int64 | Nil
• #mirror : StreamSource | Nil
• #mirror_direct? : Bool | Nil
• #name : String

  Name of this stream

• #no_ack? : Bool | Nil
• #placement : Placement | Nil
• #replicas : Int32
• #republish : Republish | Nil
• #retention : RetentionPolicy | Nil
• #sealed? : Bool | Nil
• #sources : Array(StreamSource)
• #storage : Storage
• #subjects : Array(String)

  Which subjects this stream will listen for.

Constructor Detail

Instance Method Detail