Class Engine

constructor

• new Engine(cfg: EngineConfig): Engine

  Parameters

  • cfg: EngineConfig

  Returns Engine

ReadonlyengineId

onSettled

Readonlysource

abortInFlight

• abortInFlight(): number

  Operator force-drain (#150): SIGKILL every live harness process group. Aborted dispatches resolve through the normal failure path — closing commits land and tasks are freed for retry — so drain() completes shortly after. Returns how many groups were signalled.

  Returns number

deferrals

• deferrals(): Deferral[]

  What the last tick held back and why, for the heartbeat (#97).

  Returns Deferral[]

drain

• drain(): Promise<void>

  Await every in-flight job (their closing commits included).

  Returns Promise<void>

inFlight

• inFlight(): number

  Returns number

inFlightDetail

• inFlightDetail(): InFlightJob[]

  What is currently dispatched, for drain reporting (#150).

  Returns InFlightJob[]

pushHealth

• pushHealth(): ReadonlyMap<string, number>

  Returns ReadonlyMap<string, number>

syncFromRemote

• syncFromRemote(): Promise<void>

  Fast-forward local run branches from origin before deriving (#104). A standalone orchestrator has no co-located server fetch loop to lean on, and an engine reading a materialized local branch never sees remote decisions otherwise — it re-derives yesterday's state forever. ff-only and idempotent (LocalGitSource.syncFromRemote): a diverged branch is refused and left for a human, never resolved silently. Failure is tolerated — a clone with no origin is a legal dev/test topology.

  Callers choose when: the run loop syncs on heartbeat/startup ticks only, because our own fetch touches FETCH_HEAD under the watched .git dir and a sync inside every refs-triggered tick would re-trigger itself.

  Returns Promise<void>

tick

• tick(): Promise<TickOutcome[]>

  One reconcile pass over every active run. Idempotent to re-run.

  Returns Promise<TickOutcome[]>