Struct RedbStore 

pub struct RedbStore {
    db: Arc<Database>,
    _tmp: Option<NamedTempFile>,
}

Implementation of OutgoingIndexStore and TicketQueueStore using redb database and postcard serializer.

The store is intentionally not cloneable to allow the owner to have complete ownership of the database.

Fields

db: Arc<Database>

_tmp: Option<NamedTempFile>

Implementations

impl RedbStore

pub fn new(path: impl AsRef<Path>) -> Result<Self, RedbStoreError>

Creates a new instance on the given path.

pub fn new_temp() -> Result<Self, RedbStoreError>

Creates a new instance using a temporary file.

The temporary file is automatically deleted when the store is dropped.

Trait Implementations

impl Debug for RedbStore

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

Formats the value using the given formatter.

impl OutgoingIndexStore for RedbStore

type Error = RedbStoreError

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 RedbStore

type Queue = RedbTicketQueue

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.