Crate licoup_workflow_runtime

Expand description

Event-driven workflow execution: durable admission, routing, node execution and the graph driver.

The generic execution machinery — capability adapters, the node facade, the continuous driver, and the in-process drive bookkeeping — is owned by acativa::runtime and re-exported here under the same module paths. What this crate owns is the LicoUp composition on top of it: the strategy service’s execute vocabulary, the Assistant preflight and package importer, the Membership-profile port surface, and the evolution seams that read the host’s catalog.

  licoup  ──►  licoup-workflow-runtime  ──►  licoup-workflow-store  ──►  licoup-workflow
    (composes)            (executes)                   (persists)               (pure machine)

Nothing here reaches back into the host. Everything the runtime needs from above arrives through ports: the host installs its answers once at its crate root, and a process that installs none runs fail-closed.

Re-exports§

pub use evolution::CallbackContextFacts;
pub use evolution::CallbackCostFacts;
pub use evolution::CallbackEvolutionEnricher;
pub use evolution::CallbackEvolutionPayload;
pub use evolution::CallbackFacts;
pub use evolution::CallbackObservationFacts;
pub use evolution::CallbackSuggestions;
pub use evolution::DefaultEvolutionContextPort;
pub use evolution::DefaultEvolutionStrategyPort;
pub use evolution::EffectRecheckContext;
pub use evolution::EvolutionContextPort;
pub use evolution::GroupBGapReport;
pub use evolution::GroupBIntegrationGaps;
pub use evolution::LedgerEvolutionCostPort;
pub use evolution::recheck_before_effect;
pub use ports::CandidateFilters;
pub use ports::HostPorts;
pub use ports::ModelFactsPort;
pub use ports::PriceFacts;
pub use ports::ProfileSnapshotAuthority;
pub use ports::SharedSnapshotAuthority;
pub use ports::TargetFacts;
pub use ports::host_ports;
pub use ports::install_host_ports;
pub use ports::project_profile_snapshot;
pub use ports::project_profile_snapshots;
pub use ports::rank_candidates;
pub use ports::route_receipt;

Modules§

adapter: Native capability adapter leaves used by node execution.
control: Controlled admission: verified principal, controlled store, and explicit conflict resolution.
driver: Continuous node driver with graceful lifecycle and source-identity result re-entry.
evolution: Evolution wiring connecting workflow runtime to observation, cost, context, and strategy ports.
node: Node facade for uniform operations and truthful capabilities.
ports: The facts and effects the workflow runtime reads but does not own.
routing: Routing and subscription: feature indexes/selectors, frozen targets, cursor, and fair wake.

Structs§

ActorTurnError: The dispatch error one actor turn port may report.
ActorTurnPort: The Conversation-dispatch seam for one Conversation-bound actor command. open registers the turn and returns its handle, run executes one opened turn to its terminal state, cancel signals one opened turn to stop, and abandon settles one opened turn that will never run. Composition happens where the persistent host runtime exists; the strategy service treats the port as opaque. The port and its disposition vocabulary are the engine’s drive-bookkeeping primitives.
AdmissionReceipt: Durable receipt issued upon successful admission into the queue.
AdmissionRequest: Admission request submitted to the Intervention Proxy.
AdoptedPlanningDefaultSeam
AgentModelOptionSeam
AssistantPreflight
BindingCandidate: Definition, binding, projection, and error vocabulary the store and the runtime both name. It is defined by the pure machine crate so neither of them has to own the other’s identity.
BindingValue: Definition, binding, projection, and error vocabulary the store and the runtime both name. It is defined by the pure machine crate so neither of them has to own the other’s identity.
CancellationFacts: Separate cancellation facts preserved truthfully.
ContinuousNodeDriver: Continuous driver orchestrating node facades, feature indexing, queues, and result re-entry.
CooperativeDrainAdapter: Cooperative drain adapter: supports Submit, safe-boundary Steer, Pause (via drain to safe boundary), Stop, and Observe. It truthfully exposes that in-flight pause and steer are not supported without killing processes.
DefaultEvolutionObservationPort
DispatchedEffectReport: Report for an individual recipient’s effect dispatch.
DriverStepOutcome: Outcome of one step of the continuous driver.
EffectRecheckReceipt
FairDispatchQueue: Fair dispatch queue maintaining separate Control and Data channels with strict capacity bounds and a deficit/quantum fair arbiter to prevent starvation.
FrozenTargetRecipient: Individual frozen recipient snapshot bound at admission.
FrozenTargets: Set of target recipients frozen at queue admission time.
GraphPauseReport: Graph-wide pause report collecting individual node outcomes truthfully.
GraphStopReport: Graph-wide stop report collecting individual node outcomes truthfully.
InMemoryControlledStore: In-memory controlled store implementing ControlledStore for tests and isolated execution.
InterventionProxy: Intervention Proxy: durably admits operations, enforcing authorization, idempotency, monotonic stops, revision ordering, and queue admission barriers.
InvocationRecord: Historical record of an execution attempt on a node.
NodeExecutionReceipt: Durable receipt issued upon settling an invocation completion.
NodeFacade: Facade presenting one uniform control surface for a node instance.
NodeFeatureIndex: Inverted feature index over active nodes for efficient characteristic-based routing.
NodeInvocation: Invocations dispatched to a node adapter.
NodeMetadata: Metadata describing an indexed node instance.
NodeObservation: Truthful observation of a node without starting or extending work.
NodeObservationSummary
PerNodePauseOutcome: Per-node outcome when pausing a graph.
PerNodeStopOutcome: Per-node outcome when stopping a graph.
PlanningScopeSeam
PreflightFailure
PreflightReceipt
PreparedPackage
QueueBounds: Bounded limits for a channel.
QueueCapacityExceeded: Error returned when queue bounds are exceeded.
QueuedItem: An admitted message queued for execution.
ResultReentry: Result re-entry with source identity.
SingleWriterSessionRegistry: Registry enforcing that one native session has at most one writer across all facades.
StrategyAuthorization: Definition, binding, projection, and error vocabulary the store and the runtime both name. It is defined by the pure machine crate so neither of them has to own the other’s identity.
StrategyDefinition: Definition, binding, projection, and error vocabulary the store and the runtime both name. It is defined by the pure machine crate so neither of them has to own the other’s identity.
StrategyDefinitionSummary: Definition, binding, projection, and error vocabulary the store and the runtime both name. It is defined by the pure machine crate so neither of them has to own the other’s identity.
StrategyDiagnostic: Definition, binding, projection, and error vocabulary the store and the runtime both name. It is defined by the pure machine crate so neither of them has to own the other’s identity.
StrategyEffectPermit: One effect permit: the exact command, authorization and effect identity the host issued it for.
StrategyError: Definition, binding, projection, and error vocabulary the store and the runtime both name. It is defined by the pure machine crate so neither of them has to own the other’s identity.
StrategyPackageImporter
StrategyProjection: Definition, binding, projection, and error vocabulary the store and the runtime both name. It is defined by the pure machine crate so neither of them has to own the other’s identity.
StrategyService
StrategySourceSeam
StrategyStore
StrategySuggestion: A strategy suggestion presented to the run’s decider.
StrategyVersionSeam
Subscription: Persistent subscription matching future events with a durable cursor.
SubscriptionRegistry: Subscription registry enforcing lifecycle and negotiation rules.
SyntheticCapabilityAdapter: Synthetic adapter for testing and deterministic verification of capability combinations.

Enums§

ActivationRule: Activation rule for a matched subscription.
AdapterError: Adapter error kinds.
AdapterExecutionStatus: Live execution status of an adapter invocation.
AdmissionConflict: Explicit typed conflict when admission is rejected.
CancelOutcome: Separate cancellation facts preserved truthfully.
ChannelKind: Channel classification for queue prioritization and fair dispatch.
ControlOperation: Semantic control operations entering the admission queue.
ControlScope: Scope of a control command.
DeliveryMode: Delivery mode for a publication.
DriverError: Errors originating in continuous driver operations.
EffectRecheckFailure
NodeCapability: Declared uniform semantic capabilities of a node.
NodeExecutionError: Errors originating during node facade operations.
NodeExecutionOutcome: Final outcome of an invocation execution.
NodeLifecycleState: Node lifecycle state for routed work.
OperationGrant: Operation-scoped authorization grant.
PauseOutcome: Truthful outcome of a pause command.
PauseResult: Result of a pause operation.
RecipientEffectStatus: Live effect validity verification outcome for a frozen recipient.
ResumeOutcome: Truthful outcome of a resume command.
ResumeResult: Result of a resume operation.
SteerOutcome: Truthful outcome of a steer intervention.
SteerResult: Result of a steer operation.
StopResult: Result of a stop operation.
StrategyErrorCode: Definition, binding, projection, and error vocabulary the store and the runtime both name. It is defined by the pure machine crate so neither of them has to own the other’s identity.
SubscriptionPredicate: Predicate defining when a persistent subscription matches an event.
SubscriptionScope: Scope of a persistent subscription.
TargetSelector: Selector addressing explicit nodes or indexed characteristics.
TurnCancelDisposition: The Conversation-dispatch seam for one Conversation-bound actor command. open registers the turn and returns its handle, run executes one opened turn to its terminal state, cancel signals one opened turn to stop, and abandon settles one opened turn that will never run. Composition happens where the persistent host runtime exists; the strategy service treats the port as opaque. The port and its disposition vocabulary are the engine’s drive-bookkeeping primitives. The bounded outcome of one turn-cancel request routed through the port. The port converts adapter control results into these facts, so a raw adapter error can never fabricate an observed stop.
VerifiedPrincipal: Verified principal constructing an internal, non-serializable proof of authority.

Constants§

ASSISTANT_TEMPORARY_DEFINITION_PREFIX
STRATEGY_SCHEMA_VERSION

Traits§

ControlledStore: Port/contract for the controlled store managing graph state, revisions, and admission log.
EffectPort: The host’s effect seam: runtime resolution, sandbox admission, actor and script execution, lane dispatch and the owned-run stop record.
EvolutionCostPort
EvolutionObservationPort
EvolutionStrategyPort
NodeCapabilityAdapter: Abstract native capability adapter for node execution.
ResolvedRuntime: One runtime the host resolved for one requirement.
UsageLedgerPort: The numeric run usage ledger.

Functions§

preflight_assistant_graph
synthetic_fixture_package_bytes

Type Aliases§

AssistantWakePort: The notice seam for the designated Assistant. wake receives the Conversation id, the designated Assistant Membership id, and the identifier-only notice part already appended to the timeline; it opens one new Assistant turn for that notice only when no turn of that membership is in flight. Composition happens where the persistent host runtime exists. The seam itself is the engine’s run-wake port under this host’s own name.
WorkflowStore: Name the store by its domain boundary while preserving the established StrategyStore type for callers that still use strategy terminology.