assay-domain 0.2.1

Shared workflow domain model (types + store traits) for the assay workflow engine, auth layer, and dashboard.
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

//! Engine-wide CDC outbox. Every state-mutating store method writes a
//! typed event via a subsystem wrapper (e.g. `WorkflowEventBus`) that
//! in turn calls [`EngineEventBus::publish_committed`]. Subscribers —
//! scheduler, task workers, SSE dashboards — consume from a node-local
//! `tokio::broadcast` fed by same-node writes plus a single PG `LISTEN`
//! bridge for cross-node bumps. Events are durable in the `engine_events`
//! table with a configurable TTL (default 3 days) so reconnecting
//! clients can replay from a cursor (`Last-Event-ID` in SSE, `after:
//! Option<i64>` on the bus).

pub mod trait_;
pub use trait_::*;

#[cfg(feature = "backend-postgres")]
pub mod pg;

#[cfg(feature = "backend-postgres")]
pub use pg::PgEngineEventBus;

#[cfg(feature = "backend-sqlite")]
pub mod sqlite;

#[cfg(feature = "backend-sqlite")]
pub use sqlite::SqliteEngineEventBus;