Struct MemoryStore 

pub struct MemoryStore {
    tickets: HashMap<ChannelId, MemoryTicketQueue>,
    out_indices: HashMap<(ChannelId, u32), u64>,
}

Simple non-persistent ticket queue store backed by a HashMap and MemoryTicketQueue.

Useful for non-persistent and testing scenarios.

Fields

tickets: HashMap<ChannelId, MemoryTicketQueue>

out_indices: HashMap<(ChannelId, u32), u64>

Trait Implementations

impl Clone for MemoryStore

fn clone(&self) -> MemoryStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MemoryStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for MemoryStore

fn default() -> MemoryStore

Returns the “default value” for a type.

impl OutgoingIndexStore for MemoryStore

type Error = Infallible

fn load_outgoing_index( &self, channel_id: &ChannelId, epoch: u32, ) -> Result<Option<u64>, Self::Error>

Loads the last used outgoing ticket index for the given channel and epoch.

fn save_outgoing_index( &mut self, channel_id: &ChannelId, epoch: u32, index: u64, ) -> Result<(), Self::Error>

Saves the last used outgoing ticket index for the given channel and epoch.

fn delete_outgoing_index( &mut self, channel_id: &ChannelId, epoch: u32, ) -> Result<(), Self::Error>

Deletes the outgoing ticket index for the given channel and epoch.

fn iter_outgoing_indices( &self, ) -> Result<impl Iterator<Item = (ChannelId, u32)>, Self::Error>

Iterate over all channel IDs and epochs of outgoing ticket indices in the storage.

impl TicketQueueStore for MemoryStore

type Queue = MemoryTicketQueue

Type of per-channel incoming ticket queues.

fn open_or_create_queue( &mut self, channel_id: &ChannelId, ) -> Result<Self::Queue, <Self::Queue as TicketQueue>::Error>

Opens or creates a new queue in storage for the given channel.

fn delete_queue( &mut self, channel_id: &ChannelId, ) -> Result<Vec<VerifiedTicket>, <Self::Queue as TicketQueue>::Error>

Deletes the queue for the given channel.

fn iter_queues( &self, ) -> Result<impl Iterator<Item = ChannelId>, <Self::Queue as TicketQueue>::Error>

Iterate over all channel IDs of ticket queues in the storage.