Struct Reactor 

pub struct Reactor { /* private fields */ }

ChangeListener -> InvalidationEngine -> Query Re-execution -> SSE Push

Implementations

impl Reactor

pub fn new( node_id: NodeId, db_pool: PgPool, registry: FunctionRegistry, config: ReactorConfig, ) -> Self

Create a new reactor.

pub fn node_id(&self) -> NodeId

Get the node ID.

pub fn session_server(&self) -> Arc<SessionServer>

Get the session server reference.

pub fn subscription_manager(&self) -> Arc<SubscriptionManager>

Get the subscription manager reference.

pub fn shutdown_receiver(&self) -> Receiver<()>

Get a shutdown receiver.

pub async fn register_session( &self, session_id: SessionId, sender: Sender<RealtimeMessage>, )

Register a new session.

pub async fn remove_session(&self, session_id: SessionId)

Remove a session and all its subscriptions.

pub async fn subscribe( &self, session_id: SessionId, client_sub_id: String, query_name: String, args: Value, auth_context: AuthContext, ) -> Result<(SubscriptionId, Value)>

Subscribe to a query.

pub async fn unsubscribe(&self, subscription_id: SubscriptionId)

Unsubscribe from a query.

pub async fn subscribe_job( &self, session_id: SessionId, client_sub_id: String, job_id: Uuid, auth_context: &AuthContext, ) -> Result<JobData>

Subscribe to job progress updates.

pub async fn unsubscribe_job(&self, session_id: SessionId, client_sub_id: &str)

Unsubscribe from job updates.

pub async fn subscribe_workflow( &self, session_id: SessionId, client_sub_id: String, workflow_id: Uuid, auth_context: &AuthContext, ) -> Result<WorkflowData>

Subscribe to workflow progress updates.

pub async fn unsubscribe_workflow( &self, session_id: SessionId, client_sub_id: &str, )

Unsubscribe from workflow updates.

pub async fn start(&self) -> Result<()>

Start the reactor (runs the change listener and invalidation loop).

pub fn stop(&self)

Stop the reactor.

pub async fn stats(&self) -> ReactorStats

Get reactor statistics.