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 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