Struct HoprNodeDb 

pub struct HoprNodeDb { /* private fields */ }

Implementations

impl HoprNodeDb

pub async fn new( directory: &Path, cfg: HoprNodeDbConfig, ) -> Result<Self, NodeDbError>

pub async fn new_in_memory() -> Result<Self, NodeDbError>

pub fn config(&self) -> &HoprNodeDbConfig

Trait Implementations

impl Clone for HoprNodeDb

fn clone(&self) -> HoprNodeDb

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl HoprDbPeersOperations for HoprNodeDb

type Error = NodeDbError

fn add_network_peer<'life0, 'life1, 'async_trait>( &'life0 self, peer: &'life1 PeerId, origin: PeerOrigin, mas: Vec<Multiaddr>, backoff: f64, quality_window: u32, ) -> Pin<Box<dyn Future<Output = Result<(), NodeDbError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Adds a peer to the backend.

fn remove_network_peer<'life0, 'life1, 'async_trait>( &'life0 self, peer: &'life1 PeerId, ) -> Pin<Box<dyn Future<Output = Result<(), NodeDbError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Removes the peer from the backend.

fn update_network_peer<'life0, 'async_trait>( &'life0 self, new_status: PeerStatus, ) -> Pin<Box<dyn Future<Output = Result<(), NodeDbError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Updates stored information about the peer. Should fail if the peer does not exist in the store.

fn get_network_peer<'life0, 'life1, 'async_trait>( &'life0 self, peer: &'life1 PeerId, ) -> Pin<Box<dyn Future<Output = Result<Option<PeerStatus>, NodeDbError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Gets stored information about the peer.

fn get_network_peers<'a, 'async_trait>( &'a self, selector: PeerSelector, sort_last_seen_asc: bool, ) -> Pin<Box<dyn Future<Output = Result<BoxStream<'a, PeerStatus>, NodeDbError>> + Send + 'async_trait>>

where Self: 'async_trait, 'a: 'async_trait,

Returns a stream of all stored peers, optionally matching the given PeerSelector filter.

fn network_peer_stats<'life0, 'async_trait>( &'life0 self, quality_threshold: f64, ) -> Pin<Box<dyn Future<Output = Result<Stats, NodeDbError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns the statistics on the stored peers.

impl HoprDbTicketOperations for HoprNodeDb

type Error = NodeDbError

fn stream_tickets<'c, 'async_trait, S, I>( &'c self, selectors: I, ) -> Pin<Box<dyn Future<Output = Result<BoxStream<'c, RedeemableTicket>, Self::Error>> + Send + 'async_trait>>

where S: 'async_trait + Into<TicketSelector>, I: 'async_trait + IntoIterator<Item = S> + Send, Self: 'async_trait, 'c: 'async_trait,

Retrieve acknowledged winning tickets, according to the given selectors.

fn insert_ticket<'life0, 'async_trait>( &'life0 self, ticket: RedeemableTicket, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Inserts a new winning ticket into the DB.

fn mark_tickets_as<'life0, 'async_trait, S, I>( &'life0 self, selectors: I, mark_as: TicketMarker, ) -> Pin<Box<dyn Future<Output = Result<usize, Self::Error>> + Send + 'async_trait>>

where S: 'async_trait + Into<TicketSelector> + Send, I: 'async_trait + IntoIterator<Item = S> + Send, Self: 'async_trait, 'life0: 'async_trait,

Marks tickets as the given TicketMarker, removing them from the DB and updating the ticket statistics for each ticket’s channel.

fn mark_unsaved_ticket_rejected<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, issuer: &'life1 Address, ticket: &'life2 Ticket, ) -> Pin<Box<dyn Future<Output = Result<(), NodeDbError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Updates the ticket statistics according to the fact that the given ticket has been rejected by the packet processing pipeline.

fn update_ticket_states_and_fetch<'a, 'async_trait, S, I>( &'a self, selectors: I, new_state: AcknowledgedTicketStatus, ) -> Pin<Box<dyn Future<Output = Result<BoxStream<'a, RedeemableTicket>, Self::Error>> + Send + 'async_trait>>

where S: 'async_trait + Into<TicketSelector>, I: 'async_trait + IntoIterator<Item = S> + Send, Self: 'async_trait, 'a: 'async_trait,

Updates the state of the tickets matching the given selectors.

fn update_ticket_states<'life0, 'async_trait, S, I>( &'life0 self, selectors: I, new_state: AcknowledgedTicketStatus, ) -> Pin<Box<dyn Future<Output = Result<usize, Self::Error>> + Send + 'async_trait>>

where S: 'async_trait + Into<TicketSelector>, I: 'async_trait + IntoIterator<Item = S> + Send, Self: 'async_trait, 'life0: 'async_trait,

Updates state of the tickets matching the given selector.

fn get_ticket_statistics<'life0, 'async_trait>( &'life0 self, channel_id: Option<ChannelId>, ) -> Pin<Box<dyn Future<Output = Result<ChannelTicketStatistics, NodeDbError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves the ticket statistics for the given channel.

fn reset_ticket_statistics<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), NodeDbError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Resets the ticket statistics about neglected, rejected, and redeemed tickets.

fn get_tickets_value<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 ChannelId, epoch: u32, ) -> Pin<Box<dyn Future<Output = Result<HoprBalance, NodeDbError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Counts the total value of tickets matching the channel.

fn get_or_create_outgoing_ticket_index<'life0, 'life1, 'async_trait>( &'life0 self, channel_id: &'life1 ChannelId, epoch: u32, ) -> Pin<Box<dyn Future<Output = Result<Option<u64>, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Gets the index of the next outgoing ticket for the given channel.

fn update_outgoing_ticket_index<'life0, 'life1, 'async_trait>( &'life0 self, channel_id: &'life1 ChannelId, epoch: u32, index: u64, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Stores the ticket index of the next outgoing ticket for the given channel.

fn remove_outgoing_ticket_index<'life0, 'life1, 'async_trait>( &'life0 self, channel_id: &'life1 ChannelId, epoch: u32, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

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