Class Engine

The schedules: get(name), and list() of every schedule that exists.

Adds an event to the batch of wf under key (see BatchOptions).

Flushes and closes.

Finishes an async completion from its token; resolves once recorded durably.

Debounces a start of wf under key (see DebounceOptions).

A run's journal as an export file (.fjnl) for Replayer, or null.

Fails an async completion.

Defines (or resizes) a concurrency and rate limit for steps.

Permits of a limit held right now.

Every limit this engine defined, by name, with its permits now.

This process's steps waiting for a permit of a limit right now.

The engine's counters summed over its shards.

Registers an object type: its handlers by name, exclusive unless marked with shared. Without handlers, returns a handle to call a type registered elsewhere (with workers, in the workers' module).

Key key of object type type.

Keys of object type type (up to limit per shard).

Registers a workflow definition's code (as Engine.open({ workflows }) does).

Creates a schedule (or updates its spec) that starts workflow on its cron or interval.

A handle to an existing schedule.

Serves the HTTP API and the web UI on a thread of its own (they call this engine through its event loop; nothing rides the step path). Off loopback a token is required. Returns the URL:

console.log(engine.serve());   // http://127.0.0.1:7601

The URL this engine's HTTP API is reached at from outside (behind a proxy): awaitCompletion's url is built from it.

Current counters for each shard, in shard-number order.

Signals the run id, starting it first with input if it is not running: both reach the engine before its next tick, so the signal is recorded before a new run's code first runs.

Starts a run of wf (a definition or a type name) under workflow ID id; resolves once the start is durable. delay or at starts it later: a durable timer (the run fusee.delay/<id>), then the start; result() waits through the delay.

Starts wf if it is not running and delivers an update in the same record; returns the run and the update's result.

Registers a workflow type (version 1 unless given). Without a function, returns a handle to start runs of a type registered elsewhere (with workers, in the workers' module).