Struct nostr_database::memory::MemoryDatabase

source · 
pub struct MemoryDatabase { /* private fields */ }
Expand description

Memory Database (RAM)

Implementations§

source§

impl MemoryDatabase

source

pub fn new() -> Self

New Memory database with default options

source

pub fn with_opts(opts: MemoryDatabaseOptions) -> Self

New Memory database

Trait Implementations§

source§

impl Debug for MemoryDatabase

source§

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

Formats the value using the given formatter. Read more
source§

impl Default for MemoryDatabase

source§

fn default() -> Self

Returns the “default value” for a type. Read more
source§

impl NostrDatabase for MemoryDatabase

§

type Err = DatabaseError

Error
source§

fn backend(&self) -> Backend

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

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

Save Event into store Read more
source§

fn bulk_import<'life0, 'async_trait>( &'life0 self, events: BTreeSet<Event> ) -> Pin<Box<dyn Future<Output = Result<(), Self::Err>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Bulk import events into database Read more
source§

fn has_event_already_been_saved<'life0, 'life1, 'async_trait>( &'life0 self, event_id: &'life1 EventId ) -> Pin<Box<dyn Future<Output = Result<bool, Self::Err>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Check if Event has already been saved
source§

fn has_event_already_been_seen<'life0, 'life1, 'async_trait>( &'life0 self, event_id: &'life1 EventId ) -> Pin<Box<dyn Future<Output = Result<bool, Self::Err>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Check if EventId has already been seen
source§

fn has_event_id_been_deleted<'life0, 'life1, 'async_trait>( &'life0 self, event_id: &'life1 EventId ) -> Pin<Box<dyn Future<Output = Result<bool, Self::Err>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Check if EventId has been deleted
source§

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

Check if event with Coordinate has been deleted before Timestamp
source§

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

Set EventId as seen by relay Read more
source§

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

Get list of relays that have seen the EventId
source§

fn event_by_id<'life0, 'async_trait>( &'life0 self, event_id: EventId ) -> Pin<Box<dyn Future<Output = Result<Event, Self::Err>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get Event by EventId
source§

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

Count number of Event found by filters Read more
source§

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

Query store with filters
source§

fn event_ids_by_filters<'life0, 'async_trait>( &'life0 self, filters: Vec<Filter>, order: Order ) -> Pin<Box<dyn Future<Output = Result<Vec<EventId>, Self::Err>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get event IDs by filters
source§

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

Get negentropy items
source§

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

Delete all events that match the Filter
source§

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

Wipe all data

Auto Trait Implementations§

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T> Instrument for T

source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> IntoNostrDatabase for T
where T: NostrDatabase + 'static,

source§

fn into_nostr_database(self) -> Arc<dyn NostrDatabase<Err = DatabaseError>>

source§

impl<T> NostrDatabaseExt for T
where T: NostrDatabase + ?Sized,

source§

fn profile<'life0, 'async_trait>( &'life0 self, public_key: PublicKey ) -> Pin<Box<dyn Future<Output = Result<Profile, Self::Err>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait,

Get profile metadata
source§

fn contacts_public_keys<'life0, 'async_trait>( &'life0 self, public_key: PublicKey ) -> Pin<Box<dyn Future<Output = Result<Vec<PublicKey>, Self::Err>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait,

Get contact list public keys
source§

fn contacts<'life0, 'async_trait>( &'life0 self, public_key: PublicKey ) -> Pin<Box<dyn Future<Output = Result<BTreeSet<Profile>, Self::Err>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait,

Get contact list with metadata of PublicKey
source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

source§

fn vzip(self) -> V

source§

impl<T> WithSubscriber for T

source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

impl<T> AsyncTraitDeps for T
where T: Debug + SendOutsideWasm + SyncOutsideWasm,

source§

impl<T> SendOutsideWasm for T
where T: Send,

source§

impl<T> SyncOutsideWasm for T
where T: Sync,