Skip to main content

Module orchestration

Module orchestration 

Source
Expand description

Direct re-exports from echo_orchestration::workflow.

Modules§

checkpoint_store
Checkpoint persistent storage
state
Shared state (SharedState)

Structs§

Checkpoint
Checkpoint - snapshot of graph execution state
CheckpointInfo
Checkpoint info summary (used for list display)
ConcurrentWorkflow
Concurrent workflow: all registered agents execute in parallel; results are merged via a merge function.
ConcurrentWorkflowBuilder
ConcurrentWorkflow builder
DagEdge
Directed edge in the DAG (from -> to means to depends on from’s output)
DagNode
A node in the DAG
DagWorkflow
DAG workflow: nodes execute in topological order; independent nodes run concurrently.
DagWorkflowBuilder
DagWorkflow builder
FileCheckpointStore
File storage implementation (supports persistence)
Graph
Compiled graph workflow (immutable)
GraphBuilder
Graph workflow builder
GraphResult
Graph execution result
InterruptConfig
Interrupt configuration
InterruptState
Interrupt state - state when execution is paused
MemoryCheckpointStore
In-memory storage implementation (default, non-persistent)
SequentialWorkflow
Sequential workflow: each agent runs in registration order; the former’s output flows into the latter’s input.
SequentialWorkflowBuilder
SequentialWorkflow builder
SharedState
Shared state for graph workflows
StepOutput
Detailed output of a single step execution
WorkflowOutput
Complete output of a workflow execution
WorkflowStep
One step in a sequential workflow

Enums§

InterruptType
Interrupt type
RunUntilInterruptResult
Return type of run_until_interrupt
WorkflowEvent
Step-by-step events emitted during workflow execution.

Traits§

CheckpointStore
Checkpoint storage interface
Workflow
Unified workflow execution interface

Functions§

shared_agent
Wrap arbitrary impl Agent as a SharedAgent

Type Aliases§

SharedAgent
Shareable agent handle for safe access across async tasks.
SharedAgentMutexDeprecated
Backward-compatible type alias for call sites that still reference the old AsyncMutex pattern. Marked deprecated to encourage migration.