Struct RedbTicketQueue 

pub struct RedbTicketQueue {
    db: Weak<Database>,
    channel_id: ChannelId,
}

Implementation of TicketQueue using redb database and postcard serializer, associated with the RedbStore.

Fields

db: Weak<Database>

channel_id: ChannelId

Trait Implementations

impl TicketQueue for RedbTicketQueue

type Error = RedbStoreError

fn len(&self) -> Result<usize, Self::Error>

Number of tickets in the queue.

fn is_empty(&self) -> Result<bool, Self::Error>

Indicates whether the queue is empty.

fn push(&mut self, ticket: RedeemableTicket) -> Result<(), Self::Error>

Add a ticket to the queue.

fn pop(&mut self) -> Result<Option<RedeemableTicket>, Self::Error>

Remove and return the next ticket in-order from the queue.

fn peek(&self) -> Result<Option<RedeemableTicket>, Self::Error>

Return the next ticket in-order from the queue without removing it.

fn iter_unordered( &self, ) -> Result<impl Iterator<Item = Result<RedeemableTicket, Self::Error>>, Self::Error>

Iterate over all tickets in the queue in arbitrary order.

fn total_value( &self, epoch: u32, min_index: Option<u64>, ) -> Result<HoprBalance, Self::Error>

Computes the total value of tickets of the given epoch (and optionally minimum given index) in this queue.

fn drain(&mut self) -> Result<Vec<VerifiedTicket>, Self::Error>

Drains all the remaining tickets from the queue, rendering them no longer redeemable.