Skip to main content

SubscriptionService

reifydb_engine::subscription

Trait SubscriptionService 

Source 
pub trait SubscriptionService: Send + Sync {
    // Required methods
    fn next_id(&self) -> SubscriptionId;
    fn register_subscription(
        &self,
        id: SubscriptionId,
        flow_dag: FlowDag,
        column_names: Vec<String>,
        txn: &mut Transaction<'_>,
    ) -> Result<()>;
    fn unregister_subscription(&self, id: &SubscriptionId) -> Result<()>;
    fn hydrate(
        &self,
        sub_id: SubscriptionId,
        engine: &StandardEngine,
        identity: IdentityId,
        lease: VersionLeaseGuard,
        max_rows: u64,
    ) -> StdResult<HydrateOutcome, HydrateError>;
}

Required Methods§

Source

fn next_id(&self) -> SubscriptionId

Source

fn register_subscription( &self, id: SubscriptionId, flow_dag: FlowDag, column_names: Vec<String>, txn: &mut Transaction<'_>, ) -> Result<()>

Source

fn unregister_subscription(&self, id: &SubscriptionId) -> Result<()>

Source

fn hydrate( &self, sub_id: SubscriptionId, engine: &StandardEngine, identity: IdentityId, lease: VersionLeaseGuard, max_rows: u64, ) -> StdResult<HydrateOutcome, HydrateError>

Implementors§