Struct DefaultSubscriptionManager 

pub struct DefaultSubscriptionManager<S: Subscriptions> { /* private fields */ }

Default subscription manager implementation

Implementations

impl<S: Subscriptions> DefaultSubscriptionManager<S>

pub fn new() -> Self

Create a new subscription manager with all topics initialized

pub fn compare_with( &mut self, other: &mut DefaultSubscriptionManager<S>, ) -> Result<HashMap<S::Subscriptions, SubscriptionDiff<S>>, NetabaseError>

Compare this manager with another manager and return differences for all topics

pub fn with_topics(topics: &[S::Subscriptions]) -> Self

Initialize only specific topics

Trait Implementations

impl<S: Subscriptions> Default for DefaultSubscriptionManager<S>

fn default() -> Self

Returns the “default value” for a type.

impl<S: Subscriptions> SubscriptionManager<S> for DefaultSubscriptionManager<S>

type TopicType = <S as Subscriptions>::Subscriptions

Associated types for topic-specific operations

fn subscribe_item<T>( &mut self, topic: S::Subscriptions, key: Vec<u8>, data: &T, ) -> Result<(), NetabaseError>

where T: AsRef<[u8]>,

Add an item to the appropriate subscription tree(s)

fn unsubscribe_item( &mut self, topic: S::Subscriptions, key: &[u8], ) -> Result<Option<ModelHash>, NetabaseError>

Remove an item from the subscription tree(s)

fn topic_merkle_root( &mut self, topic: S::Subscriptions, ) -> Result<Option<[u8; 32]>, NetabaseError>

Get the merkle root for a specific topic

fn stats(&self) -> SubscriptionStats

Get statistics about the subscription manager