class AvalancheMQ::Queue::UnackQueue

• AvalancheMQ::Queue::UnackQueue
• Reference
• Object

Defined in:

avalanchemq/queue/unacked.cr

Constructors

• .new(capacity = 8)

Instance Method Summary

• #[](index) : Unack
• #[]?(index) : Unack | Nil
• #capacity
• #compact
• #delete(sp : SegmentPosition)
• #delete(consumer : Client::Channel::Consumer) : Array(SegmentPosition)
• #each_sp(&)
• #lock
• #locked_each(&)
• #push(sp : SegmentPosition, persistent : Bool, consumer : Client::Channel::Consumer | Nil)
• #size
• #sum(&blk : Unack -> _) : UInt64
• #unlock

Constructor Detail

Instance Method Detail