Struct Engine 

pub struct Engine {
    pub config: EngineConfig,
    pub metrics: Metrics,
    pub changed: Arc<Notify>,
    /* private fields */
}

Fields

config: EngineConfig

metrics: Metrics

changed: Arc<Notify>

Implementations

impl Engine

pub fn open(store: Store, config: EngineConfig, clock: Clock) -> Result<Engine>

Open the engine and recover every non-terminal execution from history.

pub fn now(&self) -> u64

pub fn register_definition(&mut self, ir: WorkflowIr) -> Result<bool>

pub fn definitions(&self) -> Vec<Arc<WorkflowIr>>

pub fn definition( &self, name: &str, version: Option<&str>, ) -> Option<Arc<WorkflowIr>>

pub fn start( &mut self, workflow: &str, version: Option<&str>, input: Value, execution_id: Option<String>, ) -> Result<StartResult>

pub fn cancel(&mut self, id: &str, reason: &str) -> Result<ExecutionState>

pub fn signal(&mut self, id: &str, name: &str, payload: Value) -> Result<u64>

Send a typed signal to a running execution. The payload is validated against the workflow’s signal declaration (defaults applied) and buffered until an await step takes it. Returns the history sequence number of the recorded signal.

pub fn query(&self, id: &str, name: &str) -> Result<Value>

Evaluate a declared query against the current state of an execution. Steps that have not completed read as null.

pub fn execution(&self, id: &str) -> Result<ExecutionState>

pub fn history(&self, id: &str) -> Result<Vec<HistoryEvent>>

pub fn list_executions( &self, status: Option<&str>, workflow: Option<&str>, limit: u32, ) -> Result<Vec<ExecutionSummary>>

pub fn active_count(&self) -> usize

pub fn tick(&mut self) -> Result<Vec<TaskAssignment>>

Periodic work: timers, retries, deadlines, worker liveness, built-ins.

pub fn register_worker(&mut self, req: RegisterWorker) -> Result<Registration>

pub fn heartbeat(&mut self, session_id: &str) -> Result<HeartbeatAck>

pub fn unregister_worker(&mut self, session_id: &str) -> Result<()>

pub fn workers(&self) -> Result<Vec<WorkerInfo>>

pub fn poll(&mut self, session_id: &str) -> Result<Option<TaskAssignment>>

Hand the oldest matching queued task to a worker, if any.

pub fn complete(&mut self, token: &str, output: Value) -> Result<ResultAck>

Record a successful task result.

pub fn fail(&mut self, token: &str, error: TaskError) -> Result<ResultAck>

Record a failed attempt.

pub fn store_stats(&self) -> Result<Vec<(String, u64)>>

pub fn enable_telemetry(&mut self, config: TelemetryConfig)

Export OpenTelemetry traces of executions (see crate::telemetry).

pub fn session_worker(&self, session_id: &str) -> Option<&str>

The worker id that owns a session, if the session exists.

pub fn token_worker(&self, token: &str) -> Option<&str>

The worker id a task token was issued to, if the token is known.

pub fn session_count(&self) -> usize

pub fn refresh_definitions(&mut self) -> Result<usize>

Load definitions registered in the store since this engine opened (another server registered them). Used by cluster standbys, whose engine only reads. Returns how many were new.

impl Engine

pub fn shared_context(&self) -> Option<Arc<Ctx>>

The shared-mode context, when this engine runs in shared mode.

pub fn session_worker_lookup(&mut self, session_id: &str) -> Option<String>

Engine::session_worker that also finds sessions opened on other servers (shared mode).

pub fn token_worker_lookup(&self, token: &str) -> Option<String>

Engine::token_worker that also finds tokens issued by other servers (shared mode).