Struct TriggerRouter 

pub struct TriggerRouter { /* private fields */ }

Per-commit trigger dispatcher.

Implementations

impl TriggerRouter

pub fn from_registry(reg: &PluginRegistry) -> Result<Self, UniError>

Snapshot the registered triggers into a routing table.

Cheap for predicate-less subscriptions (one Arc clone for the trigger vector, then one pass to bucket by phase). For subscriptions carrying predicate_source, compiles the Cypher predicate into a DataFusion PhysicalExpr once and stashes it on the route — sub-millisecond per predicate, amortized against commit overhead.

Errors

Returns UniError::TriggerRejected (with a descriptive reason) if any subscription’s predicate_source fails to parse, references unknown columns, or fails type coercion. The error surfaces at commit time, not at registration — this is a deliberate trade-off to keep uni-plugin free of a uni-cypher dependency.

pub fn from_registry_with_queue( reg: &PluginRegistry, defer_queue: Option<Arc<DeferralQueue>>, ) -> Result<Self, UniError>

Variant that wires in a per-Uni deferral queue so TriggerOutcome::Defer enqueues for re-firing instead of being warned and dropped.

Errors

Same as Self::from_registry.

pub fn is_empty(&self) -> bool

True if no triggers are registered at any phase.

pub fn properties_referenced(&self) -> HashSet<String>

Union of node/edge property names that any compiled trigger predicate references (across all phases). Empty when no trigger has a predicate_source mentioning n.<prop> / old.<prop>. Drives predicate-gated property-bag materialization in MutationEvents::from_l0_with_probe.

pub fn dispatch_before( &self, ctx: TriggerContext<'_>, events: &MutationEvents, ) -> Result<(), UniError>

Fire BeforeMutation then BeforeCommit phases in order.

Returns Err(UniError::TriggerRejected) if a Synchronous trigger returns TriggerOutcome::Reject or Err. Async / EventualConsistency triggers are ignored at before-phases (they ride on after-phases only — firing async work pre-commit would let it observe a transaction that subsequently aborts).

Errors

UniError::TriggerRejected on reject or fire error.

pub fn dispatch_after( &self, ctx: TriggerContext<'_>, events: &MutationEvents, runtime: &Handle, )

Fire AfterMutation then AfterCommit phases. Cannot abort.

Synchronous after-phase triggers run inline (panics caught and logged). Async triggers are spawned on runtime. EventualConsistency triggers are spawned the same as Async in v1 (a real batched queue lands with M5g).