Struct SledSeenTracker 

pub struct SledSeenTracker {
    tree: Tree,
}

A SeenTracker implementation using sled for storage.

Fields

tree: Tree

Implementations

impl SledSeenTracker

pub fn new(db: Db) -> Result<Self>

Creates a new SledSeenTracker.

Arguments

• db - The sled::Db instance to use for storage.

Errors

This function will return an error if the seen tree cannot be opened.

Trait Implementations

impl SeenTracker for SledSeenTracker

fn mark_seen<'life0, 'async_trait>( &'life0 self, msg_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Marks a message as seen.

fn is_seen<'life0, 'life1, 'async_trait>( &'life0 self, msg_id: &'life1 Uuid, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Checks if a message has been seen.

fn cleanup_old<'life0, 'async_trait>( &'life0 self, max_age: Duration, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Cleans up old seen message records.