Struct ConcurrentDatabase

pub struct ConcurrentDatabase { /* private fields */ }

Thread-safe wrapper around an in-memory database

This provides a concurrent version of the InMemoryDatabase that can be safely shared between threads.

Implementations

impl ConcurrentDatabase

pub fn new() -> Self

Create a new concurrent database

pub fn with_max_age(max_age: Duration) -> Self

Create a new concurrent database with a specific maximum age

Trait Implementations

impl Database for ConcurrentDatabase

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

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

Check if the database is ready for queries

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

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

Get the current database status

fn update<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, api: &'life1 SafeBrowsingApi, threat_lists: &'life2 [ThreatDescriptor], ) -> Pin<Box<dyn Future<Output = Result<(), DatabaseError>> + Send + 'async_trait>>

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

Update the database with the latest threat lists

fn lookup<'life0, 'life1, 'async_trait>( &'life0 self, hash: &'life1 HashPrefix, ) -> Pin<Box<dyn Future<Output = Result<Option<(HashPrefix, Vec<ThreatDescriptor>)>, DatabaseError>> + Send + 'async_trait>>

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

Look up a hash prefix in the database

fn time_since_last_update<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Option<Duration>> + Send + 'async_trait>>

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

Get the time since the last successful update

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

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

Get database statistics

impl Default for ConcurrentDatabase

fn default() -> Self

Returns the “default value” for a type.