Crabbit::StreamOptions
Arguments used when creating a stream with Environment#create_stream.
Typed options are translated to RabbitMQ stream queue arguments. Entries in arguments are preserved, and typed options with the same key take precedence.
Constructors
new(max_length_bytes : Int64 | Nil = nil, max_age : Time::Span | Nil = nil, segment_size_bytes : Int64 | Nil = nil, initial_cluster_size : Int32 | Nil = nil, leader_locator : String | Nil = nil, filter_size_bytes : Int32 | Nil = nil, arguments : Hash(String, String) = {} of String => String)
Creates stream arguments.
max_length_bytes limits retained bytes, max_age limits message age, segment_size_bytes selects the segment file size, initial_cluster_size controls initial replicas, leader_locator selects the queue leader strategy, and filter_size_bytes configures the bloom filter size. Numeric limits must be positive.