Skip to main content

Crate skg_orch_local

Crate skg_orch_local 

Source
Expand description

In-process implementation of layer0’s Orchestrator trait.

Dispatches to registered operators via HashMap<OperatorId, Arc<dyn Operator>>. Concurrent dispatch uses tokio::spawn. No durability — operators that fail are not retried and state is not persisted. Workflow signal semantics and a minimal query are implemented via an in-memory, per-workflow signal journal.

Structs§

LocalOrch
In-process orchestrator that dispatches to registered operators.