Skip to main content

Module machine

Module machine 

Source
Expand description

The persisted run snapshot and reducer event vocabulary, reduced by the generic engine’s machine.

Two kinds of facts stay LicoUp-owned here:

  • RunSnapshot is a persisted record (strategy_runs.snapshot_json): it carries the Conversation identity (conversationId), the Assistant Membership a run answers to (assistantMembershipId) and the committed route receipt (routeReceipt) — identities the generic engine groups under its own opaque contextId/runBinding pair. The engine never reads either shape, so the reducer carries them through sideband.
  • ReducerEvent is a persisted record (strategy_run_events.event_json) plus the durable transition intent (event inside it): it keeps the Assistant-owned failure events and the three-way advance/return/ terminate callback decision spelling. Shared variants translate 1:1 onto the engine’s event; the Assistant variants settle locally.

Structs§

JoinArrival
A predecessor’s arrival at a join, bound to the exact visit that arrived.
JoinArrivalReceipt
One join-ledger change this step made.
JoinLedger
One join’s arrivals, kept per visit rather than per node.
JoinSatisfaction
One join that fired, and the epoch it fired at.
ReducerDelta
What one reducer step changed.
ReducerOutput
RunCommand
RunSnapshot
SharedEntry
One value one writer published into a shared resource.
SharedResourceState
One shared resource’s versioned contents.
SharedWriteReceipt
One shared write this step accepted.
StaleJoinArrival
An arrival the join refused to count, and why. Never dropped in silence: a stale arrival is a durable fact about the run, not an implementation detail.
VisitFact
One node visit, as a fact.

Enums§

CommandKind
CommandStatus
ReducerEvent

Functions§

binding_session_key
effect_input_for
One deterministic actor-command input for a state: the run input wrapped with the state instruction when one exists. Registration and drive share this builder so a pre-registered entry turn sends exactly the prompt the emitted command would carry.
fallback_reason
The fallback reason a failed actor or workset command earns, when one is lawful. The engine’s rule reads shared fields only.
lineage_within_budget
Whether the run’s attempt lineage for one command stays inside the definition’s budget. The engine’s check reads shared fields only.
reduce
Reduce one event against one snapshot. Assistant-owned failure events settle under this crate’s own rules; every shared event runs through the engine’s reducer over the shared field projection, and the LicoUp-owned bindings ride the same step untouched.