struct Crabbit::StreamOptions

Crabbit::StreamOptions
Struct
Value
Object

Overview

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.

Defined in:

crabbit/types.cr

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.

Instance Method Summary

#arguments : Hash(String, String)
Returns the finalized RabbitMQ stream argument map.

Constructor Detail

def self.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.

[View source]

Instance Method Detail

def arguments : Hash(String, String) #

Returns the finalized RabbitMQ stream argument map.

[View source]