Struct OutgoingIndexCache 

pub struct OutgoingIndexCache {
    cache: DashMap<(ChannelId, u32), Arc<OutgoingIndexEntry>>,
    removed: DashSet<(ChannelId, u32)>,
}

Fields

cache: DashMap<(ChannelId, u32), Arc<OutgoingIndexEntry>>

removed: DashSet<(ChannelId, u32)>

Implementations

impl OutgoingIndexCache

pub fn next(&self, channel_id: &ChannelId, epoch: u32) -> u64

Returns the next outgoing index for the given channel and epoch.

pub fn upsert(&self, channel_id: &ChannelId, epoch: u32, index: u64) -> u64

Inserts the index for the given channel and epoch, or updates the existing value if it is less than the provided index.

Returns the index value that is either:

• equal to index if no index for the given channel and epoch existed and the value was inserted, or
• equal to the existing index value, if the provided index is less than the existing index value, or
• equal to the provided index value if it is greater than the existing index value and the value is updated.

pub fn remove(&self, channel_id: &ChannelId, epoch: u32) -> bool

Removes the index for the given channel and epoch if it exists.

Returns true if the index was removed, false otherwise.

pub fn save<S: OutgoingIndexStore + Send + Sync + 'static>( &self, store: Arc<RwLock<S>>, ) -> Result<(), Error>

Synchronizes the current state with the provided store.

Saves only those values that were changed since the last save operation.

Trait Implementations

impl Debug for OutgoingIndexCache

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

Formats the value using the given formatter.

impl Default for OutgoingIndexCache

fn default() -> OutgoingIndexCache

Returns the “default value” for a type.