Struct nostr_database::memory::MemoryDatabase

pub struct MemoryDatabase { /* private fields */ }

Memory Database (RAM)

Implementations

impl MemoryDatabase

pub fn new() -> Self

New Memory database with default options

pub fn with_opts(opts: MemoryDatabaseOptions) -> Self

New Memory database

Trait Implementations

impl Clone for MemoryDatabase

fn clone(&self) -> MemoryDatabase

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for MemoryDatabase

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

Formats the value using the given formatter.

impl Default for MemoryDatabase

fn default() -> Self

Returns the “default value” for a type.

impl NostrDatabase for MemoryDatabase

fn backend(&self) -> Backend

Name of the backend database used (ex. rocksdb, lmdb, sqlite, indexeddb, …)

fn save_event<'life0, 'life1, 'async_trait>( &'life0 self, event: &'life1 Event, ) -> Pin<Box<dyn Future<Output = Result<bool, DatabaseError>> + Send + 'async_trait>>

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

Save Event into store

fn check_id<'life0, 'life1, 'async_trait>( &'life0 self, event_id: &'life1 EventId, ) -> Pin<Box<dyn Future<Output = Result<DatabaseEventStatus, DatabaseError>> + Send + 'async_trait>>

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

Check event status by ID

fn has_coordinate_been_deleted<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, coordinate: &'life1 Coordinate, timestamp: &'life2 Timestamp, ) -> Pin<Box<dyn Future<Output = Result<bool, DatabaseError>> + Send + 'async_trait>>

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

Check if Coordinate has been deleted before a certain Timestamp

fn event_id_seen<'life0, 'async_trait>( &'life0 self, event_id: EventId, relay_url: Url, ) -> Pin<Box<dyn Future<Output = Result<(), DatabaseError>> + Send + 'async_trait>>

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

Set EventId as seen by relay

fn event_seen_on_relays<'life0, 'life1, 'async_trait>( &'life0 self, event_id: &'life1 EventId, ) -> Pin<Box<dyn Future<Output = Result<Option<HashSet<Url>>, DatabaseError>> + Send + 'async_trait>>

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

Get list of relays that have seen the EventId

fn event_by_id<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 EventId, ) -> Pin<Box<dyn Future<Output = Result<Option<Event>, DatabaseError>> + Send + 'async_trait>>

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

Get Event by EventId

fn count<'life0, 'async_trait>( &'life0 self, filters: Vec<Filter>, ) -> Pin<Box<dyn Future<Output = Result<usize, DatabaseError>> + Send + 'async_trait>>

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

Count number of Event found by filters

fn query<'life0, 'async_trait>( &'life0 self, filters: Vec<Filter>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Event>, DatabaseError>> + Send + 'async_trait>>

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

Query store with filters

fn negentropy_items<'life0, 'async_trait>( &'life0 self, filter: Filter, ) -> Pin<Box<dyn Future<Output = Result<Vec<(EventId, Timestamp)>, DatabaseError>> + Send + 'async_trait>>

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

Get negentropy items

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

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

Delete all events that match the Filter

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

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

Wipe all data