Struct SensoriumLoop 

pub struct SensoriumLoop { /* private fields */ }

The SensoriumLoop orchestrates workers and gateways.

Flow: Gateway.start(db) → writes to conversations (processed=false) → Loop 1: polls conversations → matches message content against registered worker patterns in registration order; first match wins and is dispatched via tokio::spawn → Workers write ProcessEvents to process_events table → Loop 2: polls process_event_deliveries → retries delivery per gateway

Implementations

impl SensoriumLoop

pub fn new() -> Self

pub fn with_conversations_poll_interval(self, secs: u64) -> Self

pub fn with_process_event_deliveries_poll_interval(self, secs: u64) -> Self

pub fn register_worker( &mut self, pattern: &str, worker: Arc<dyn Worker>, ) -> Result<()>

pub fn workers(&self) -> &[WorkerRegistration]

pub fn register_gateway(&mut self, gateway: Arc<dyn Gateway>)

pub async fn run(self, db: DatabaseConnection) -> Result<()>

Trait Implementations

impl Default for SensoriumLoop

fn default() -> Self

Returns the “default value” for a type.