class LavinMQ::Queue::UnackQueue

• LavinMQ::Queue::UnackQueue
• Reference
• Object

Defined in:

lavinmq/queue/unacked.cr

Constructors

• .new(capacity = 8)

Instance Method Summary

• #[](index) : Unack
• #[]?(index) : Unack | Nil
• #avg_bytesize
• #bytesize : UInt64
• #capacity
• #compact
• #delete(sp : SegmentPosition)
• #delete(consumer : Client::Channel::Consumer) : Array(SegmentPosition)
• #each_sp(&)
• #lock
• #locked_each(&)
• #max_bytesize(&blk : Unack -> _) : UInt32

  expensive calculation used for unacked queue details

• #min_bytesize(&blk : Unack -> _) : UInt32

  expensive calculation used for unacked queue details

• #purge
• #push(sp : SegmentPosition, consumer : Client::Channel::Consumer | Nil)
• #size
• #sum(&blk : Unack -> _) : UInt64
• #unlock

Constructor Detail

Instance Method Detail