Trait StateStore 

pub trait StateStore: Send + Sync {
    // Required methods
    fn save(
        &self,
        subscriptions: &HashMap<String, SubscriptionFilter>,
    ) -> Result<()>;
    fn load(&self) -> Result<HashMap<String, SubscriptionFilter>>;
}

Trait for persisting EventBus subscription state

Required Methods

fn save( &self, subscriptions: &HashMap<String, SubscriptionFilter>, ) -> Result<()>

Save all subscription filters

fn load(&self) -> Result<HashMap<String, SubscriptionFilter>>

Load all subscription filters

Implementors

impl StateStore for FileStateStore

impl StateStore for MemoryStateStore