Skip to main content

Crate orchestral_runtime

Crate orchestral_runtime 

Source
Expand description

§Orchestral Runtime

Thread Runtime with concurrency, interruption, scheduling, LLM planners, built-in actions, context building, and application-layer API.

Modules§

action
Orchestral Actions
agent
api
context
Orchestral Context
planner
Planner implementations for Orchestral.
sdk
SDK builder for programmatic Orchestral setup.
skill

Structs§

ActionContext
Execution context for actions
ActionExecutionOptions
ActionInput
Input data for action execution
ActionMeta
Action metadata for planner
ActionRegistry
Action registry for looking up actions by name
BlobHead
Blob metadata fetched from physical backend.
BlobId
Strongly-typed blob id.
BlobMeta
Blob metadata.
BlobRead
Read result.
BlobWriteRequest
Write request.
CancellationToken
A token which can be used to signal a cancellation request to one or more tasks.
ComponentRegistry
ContinuationState
Structured stage exit state consumed by runtime.
DagNode
A node in the execution DAG
DefaultConcurrencyPolicy
Default concurrency policy: Interrupt and start new
DefaultRuntimeComponentFactory
Default component factory providing in-memory stores and blob storage.
ExecutionDag
Execution DAG - supports dynamic modification
ExecutionProgressEvent
Realtime execution progress event.
Executor
The executor - orchestrates DAG execution
ExecutorContext
Executor context
HistoryItem
A single item in the conversation history
HookExecutionPolicy
HookRegistry
InMemoryBlobStore
Intent
User intent - the first-class input of the system
IntentContext
Additional context for an intent
Interaction
Interaction - a single trigger → response attempt
InteractionId
Strongly-typed Interaction ID.
InterpretRequest
Input payload for result interpretation.
InterpretResult
Output payload from interpreter.
MergeConcurrencyPolicy
Merge policy: Merge new inputs into the running interaction.
NoopResultInterpreter
Deterministic fallback interpreter.
NormalizedPlan
Normalized plan ready for execution
Orchestrator
Orchestrator - wires runtime + planner + executor for a minimal pipeline
ParallelConcurrencyPolicy
Parallel policy: Allow multiple interactions to run in parallel
Plan
Execution plan - the primary asset of the system
PlanNormalizer
Plan normalizer - the stability core
PlannerContext
Context provided to the planner
PlannerLoopContext
Agent-loop execution state surfaced back into the planner.
PlannerRuntimeInfo
Runtime host info visible to planner prompt.
QueueConcurrencyPolicy
Queue policy placeholder.
RejectWhenBusyConcurrencyPolicy
Reject policy: Reject new inputs when busy
RunningState
Running state information for concurrency decisions
RuntimeApp
Running app bundle created from unified config.
RuntimeBuildRequest
RuntimeHookContext
RuntimeHookEventEnvelope
SingleAction
Planner single-action output.
SpiMeta
Step
A single step in the execution plan
StepId
Strongly-typed Step ID.
StoreBundle
Task
Task - the stateful execution context
TaskId
Strongly-typed Task ID.
Thread
Thread - a long-lived context where interactions take place
ThreadId
Strongly-typed Thread ID.
ThreadRuntime
ThreadRuntime - manages thread lifecycle and interaction concurrency
ThreadRuntimeConfig
Configuration for ThreadRuntime
VerifyDecision
Structured verify result. This is the only terminal done gate.
WorkingSet
Working set - weakly-typed KV data container for inter-step communication

Enums§

ActionResult
Action execution result with retry semantics
BlobIoError
Storage-neutral blob errors.
BootstrapError
Runtime bootstrap errors.
ConcurrencyDecision
Decision on how to handle concurrent interactions
ContinuationStatus
Explicit continuation decision emitted by a completed stage.
Event
Event - append-only fact record
ExecutionResult
Execution result
FixError
Fix errors
HandleEventResult
Result of handling an event
HookDispatchMode
HookFailurePolicy
InteractionState
Interaction state
InterpretError
Result interpreter errors.
NodeState
Node state in the execution DAG
NormalizeError
Normalization errors
OrchestratorError
Orchestrator errors
OrchestratorResult
Orchestrator result for a handled event
PlanError
Planner errors
PlannerOutput
RuntimeError
Runtime errors
Scope
Data scope for WorkingSet Avoids naming conflicts and data pollution
SpiError
StepKind
Step type - distinguishes control semantics
StoreError
Store error types
TaskState
Task state machine - production-ready states
ValidationError
Validation errors
VerifyStatus
Final verification verdict.

Traits§

Action
Action trait - the core abstraction for atomic execution units
BlobStore
Blob store abstraction.
ConcurrencyPolicy
Concurrency policy trait
EventStore
EventStore trait - async interface for event storage
ExecutionProgressReporter
Sink interface for execution progress reporting.
InterpretDeltaSink
PlanFixer
Plan fixer trait
PlanValidator
Plan validator trait
Planner
Planner trait - generates execution plans from user intent
ResultInterpreter
Interpreter trait.
RuntimeComponentFactory
RuntimeHook
TaskStore
TaskStore trait - async interface for task persistence

Type Aliases§

ActionCall
Legacy alias preserved while call sites migrate.
ActionPreflightHook
BlobStream
Streaming blob body.