reifydb-engine 0.4.9

Query execution and processing engine for ReifyDB
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

// SPDX-License-Identifier: Apache-2.0
// Copyright (c) 2025 ReifyDB

//! Subscription service trait for IoC-based integration.
//!
//! The engine defines this trait so DDL code can manage subscriptions
//! without a compile-time dependency on the subscription subsystem crate.
//! The subsystem implements this trait and registers it in IoC.

use std::sync::Arc;

use reifydb_core::interface::catalog::id::SubscriptionId;
use reifydb_rql::flow::flow::FlowDag;
use reifydb_transaction::transaction::Transaction;
use reifydb_type::Result;

/// Service interface for managing ephemeral subscriptions.
///
/// Implemented by `reifydb-sub-subscription` and registered in IoC as
/// `Arc<dyn SubscriptionService>`. The engine's DDL code resolves this
/// to create and drop subscriptions.
pub trait SubscriptionService: Send + Sync {
	/// Generate a new unique subscription ID.
	fn next_id(&self) -> SubscriptionId;

	/// Register a subscription with a pre-compiled flow DAG.
	fn register_subscription(
		&self,
		id: SubscriptionId,
		flow_dag: FlowDag,
		column_names: Vec<String>,
		txn: &mut Transaction<'_>,
	) -> Result<()>;

	/// Unregister a subscription.
	fn unregister_subscription(&self, id: &SubscriptionId) -> Result<()>;
}

/// Convenience type alias for IoC registration.
pub type SubscriptionServiceRef = Arc<dyn SubscriptionService>;