class LavinMQ::StreamQueue::StreamQueueMessageStore
Defined in:
lavinmq/queue/stream_queue_message_store.crConstructors
Instance Method Summary
- #delete(sp) : Nil
- #drop_overflow
-
#find_offset(offset) : Tuple(Int64, UInt32, UInt32)
Used once when a consumer is started Populates
segment
andposition
by iterating through segments untiloffset
is found - #last_offset : Int64
- #max_age : Time::Span | Time::MonthSpan | Nil
- #max_age=(max_age : Time::Span | Time::MonthSpan | Nil)
- #max_length : Int64 | Nil
- #max_length=(max_length : Int64 | Nil)
- #max_length_bytes : Int64 | Nil
- #max_length_bytes=(max_length_bytes : Int64 | Nil)
- #new_messages : Channel(Bool)
-
#purge(max_count : Int = UInt32::MAX) : UInt32
Deletes all "ready" messages (not unacked)
- #push(msg) : SegmentPosition
- #shift?(consumer : Client::Channel::StreamConsumer) : Envelope | Nil
Instance methods inherited from class LavinMQ::Queue::MessageStore
[](sp : SegmentPosition) : BytesMessage
[],
avg_bytesize : UInt32
avg_bytesize,
bytesize : UInt64
bytesize,
close : Nil
close,
delete(sp) : Nildelete delete, empty? empty?, empty_change : Channel(Bool) empty_change, first? : Envelope | Nil first?, purge(max_count : Int = UInt32::MAX) : UInt32 purge, push(msg) : SegmentPosition push, requeue(sp : SegmentPosition) requeue, shift?(consumer = nil) : Envelope | Nil shift?, size : UInt32 size, unmap_segments(except : Enumerable(UInt32) = StaticArray(UInt32, 0).new(0_u32)) unmap_segments
Constructor methods inherited from class LavinMQ::Queue::MessageStore
new(data_dir : String, replicator : Replication::Server | Nil)
new
Constructor Detail
Instance Method Detail
def find_offset(offset) : Tuple(Int64, UInt32, UInt32)
#
Used once when a consumer is started
Populates segment
and position
by iterating through segments
until offset
is found
Description copied from class LavinMQ::Queue::MessageStore
Deletes all "ready" messages (not unacked)