struct LavinMQ::AMQP::DelayedExchangeQueue::DelayedMessageStore::DelayedRequeuedStore::DelayedSegmentPosition

Defined in:

lavinmq/amqp/queue/delayed_exchange_queue/delayed_requeued_store.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(sp : SegmentPosition, expire_at : Int64) #

[View source]

Instance Method Detail

def clone #

[View source]
def copy_with(sp _sp = @sp, expire_at _expire_at = @expire_at) #

[View source]
def expire_at : Int64 #

def sp : SegmentPosition #