Struct HashtreeNostrBoundedEventCache 

pub struct HashtreeNostrBoundedEventCache<S> { /* private fields */ }

Implementations

impl<S> HashtreeNostrBoundedEventCache<S>

pub fn new( store: Arc<S>, root: Option<Cid>, source: EventSource, retention: EventRetentionPolicy, ) -> Self

pub fn with_priority(self, priority: i32) -> Self

pub async fn root_cid(&self) -> Option<Cid>

pub fn source(&self) -> &EventSource

pub fn retention(&self) -> &EventRetentionPolicy

pub fn source_route(&self, dataset_id: impl Into<String>) -> Result<SourceRoute>

Trait Implementations

impl<S: Clone> Clone for HashtreeNostrBoundedEventCache<S>

fn clone(&self) -> HashtreeNostrBoundedEventCache<S>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S> EventBus for HashtreeNostrBoundedEventCache<S>

where S: Store + 'static,

fn publish<'life0, 'async_trait>( &'life0 self, event: VerifiedEvent, _source: EventSource, ) -> Pin<Box<dyn Future<Output = Result<PublishReport>> + Send + 'async_trait>>

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

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

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