Crate juncture_core 

Re-exports

pub use checkpoint::CHECKPOINT_NS_SEPARATOR;

pub use checkpoint::CheckpointNamespace;

pub use checkpoint::CheckpointSaver;

pub use checkpoint::DeltaCounters;

pub use checkpoint::NamespaceSegment;

pub use checkpoint::generate_checkpoint_id;

pub use command::Command;

pub use command::CommandGoto;

pub use command::Final;

pub use command::Goto;

pub use command::GraphTarget;

pub use command::ParentCommand;

pub use command::SendTarget;

pub use config::CacheConfig;

pub use config::CachePolicy;

pub use config::EntrypointConfig;

pub use config::ResourceLimits;

pub use config::RunnableConfig;

pub use config::TaskConfig;

pub use edge::END;

pub use edge::Edge;

pub use edge::PathMap;

pub use edge::RouteResult;

pub use edge::Router;

pub use edge::START;

pub use edge::TriggerTable;

pub use error::ErrorCode;

pub use error::InvalidUpdateError;

pub use error::JunctureError;

pub use error::NodeTimeoutError;

pub use func::Runtime as FuncRuntime;

pub use func::compile_entrypoint;

pub use func::compile_entrypoint_with_config;

pub use graph::CircuitBreakerConfig;

pub use graph::CircuitBreakerState;

pub use graph::CircuitState;

pub use graph::CompiledGraph;

pub use graph::DrawableEdge;

pub use graph::DrawableGraph;

pub use graph::DrawableNode;

pub use graph::ErrorHandlerNode;

pub use graph::GraphOutput;

pub use graph::GraphOutputMetadata;

pub use graph::InterruptInfo;

pub use graph::NodeMetadata;

pub use graph::RetryPolicy;

pub use graph::RetryingNode;

pub use graph::StateFilter;

pub use graph::StateGraph;

pub use graph::StateUpdate;

pub use graph::StreamHandle;

pub use graph::SubgraphInfo;

pub use graph::TopologyError;

pub use interrupt::HIDDEN_TAG;

pub use interrupt::InterruptContext;

pub use interrupt::InterruptSignal;

pub use interrupt::ResumeValue;

pub use interrupt::Scratchpad;

pub use interrupt::generate_interrupt_id;

pub use interrupt::should_interrupt;

pub use llm::CallOptions;

pub use llm::ChatModel;

pub use llm::JsonSchema;

pub use llm::LlmError;

pub use llm::MessageChunk;

pub use llm::StructuredOutputModel;

pub use llm::ToolChoice;

pub use llm::ToolDefinition;

pub use node::IntoNode;

pub use node::Node;

pub use node::NodeError;

pub use observability::CacheKeyInput;

pub use observability::GraphLifecycleCallback;

pub use observability::MetricsCollector;

pub use prebuilt::PromptSource;

pub use prebuilt::ReactAgentConfig;

pub use pregel::BubbleUp;

pub use pregel::BudgetConfig;

pub use pregel::BudgetExceededAction;

pub use pregel::BudgetExceededReason;

pub use pregel::BudgetTracker;

pub use pregel::BudgetUsage;

pub use pregel::Durability;

pub use pregel::ExecutionConfig;

pub use pregel::ExecutionContext;

pub use pregel::FieldVersionTracker;

pub use pregel::GraphDrained;

pub use pregel::GraphInterrupt;

pub use pregel::HealthStatus;

pub use pregel::LoopStatus;

pub use pregel::NodeHealth;

pub use pregel::NodeHealthState;

pub use pregel::PendingTask;

pub use pregel::PregelLoop;

pub use pregel::PregelProtocol;

pub use pregel::StreamEvent as PregelStreamEvent;

pub use pregel::SuperstepResult;

pub use pregel::SyncAsyncFuture;

pub use pregel::TaskOutput;

pub use pregel::TaskTrigger;

pub use pregel::TimeoutPolicy;

pub use pregel::TriggerToNodes;

pub use pregel::apply_writes;

pub use pregel::compute_next_tasks;

pub use pregel::execute_superstep;

pub use runtime::ExecutionInfo;

pub use runtime::Heartbeat;

pub use runtime::HeartbeatWatcher;

pub use runtime::ManagedValues;

pub use runtime::RunControl;

pub use runtime::Runtime;

pub use runtime::StreamWriterTrait;

pub use send::Send;

pub use state::AnyValueReducer;

pub use state::AppendReducer;

pub use state::Channel;

pub use state::Content;

pub use state::ContentPart;

pub use state::CowState;

pub use state::DeltaBlob;

pub use state::DeltaChannel;

pub use state::EphemeralChannel;

pub use state::FieldsChanged;

pub use state::FromState;

pub use state::ImageData;

pub use state::ImageSource;

pub use state::IntoState;

pub use state::LastValueAfterFinishChannel;

pub use state::LastWriteWinsReducer;

pub use state::Message;

pub use state::MessagesState;

pub use state::MessagesStateUpdate;

pub use state::Overwrite;

pub use state::REMOVE_ALL_MESSAGES;

pub use state::Reducer;

pub use state::RemoveMessage;

pub use state::ReplaceReducer;

pub use state::RingBufferChannel;

pub use state::Role;

pub use state::State;

pub use state::TokenUsage;

pub use state::ToolCall;

pub use state::UntrackedChannel;

pub use state::messages_reducer;

pub use store::EmbeddingFunc;

pub use store::FilterExpr;

pub use store::IndexConfig;

pub use store::Item;

pub use store::MemoryStore;

pub use store::SearchItem;

pub use store::SearchQuery;

pub use store::SearchResult;

pub use store::Store;

pub use store::StoreError;

pub use store::StoreOp;

pub use store::StoreResult;

pub use store::TTLConfig;

pub use stream::BatchTransformer;

pub use stream::DebugEvent;

pub use stream::EventEmitter;

pub use stream::FilterFieldsTransformer;

pub use stream::JsonParseTransformer;

pub use stream::MessageBatchConfig;

pub use stream::StreamConfig;

pub use stream::StreamEvent;

pub use stream::StreamMode;

pub use stream::StreamPart;

pub use stream::StreamResumption;

pub use stream::StreamTransformer;

pub use stream::StreamWriter;

pub use stream::TaskEventType;

pub use stream::ToolsEvent;

pub use stream::call_llm_streaming;

pub use subgraph::StateSubset;

pub use subgraph::SubgraphConfig;

pub use subgraph::SubgraphMount;

pub use subgraph::SubgraphNode;

pub use subgraph::SubgraphPersistence;

pub use subgraph::SubgraphTransformer;

pub use tools::NopToolInterceptor;

pub use tools::StatefulTool;

pub use tools::Tool;

pub use tools::ToolCallTransformer;

pub use tools::ToolError;

pub use tools::ToolExecutionTrace;

pub use tools::ToolInterceptor;

pub use tools::ToolNode;

pub use tools::ToolNodeConfig;

pub use tools::ToolRuntime;

pub use tools::tools_condition;

Modules

checkpoint

Checkpoint persistence types and traits

command

config

Configuration types for graph execution

edge

Edge system for graph routing

error

func

Functional API for defining workflows with plain functions

graph

Graph building, compilation, and topology validation

interrupt

Human-in-the-Loop (HITL) support

llm

node

Node system for graph execution

observability

prebuilt

pregel

Pregel execution engine

runtime

Runtime context for graph execution

send

Send API for dynamic fan-out

state

store

stream

subgraph

Subgraph support for nested graph execution

time

Platform-compatible time abstractions.

tools

tracing_wasm

WASM-compatible tracing helpers.

wasm_send

WASM-compatible Send wrappers.

Macros

info_span

Create a span (native path).

interrupt

Interrupt macro for human-in-the-loop interactions (task-local version)

interrupt_with_ctx

Interrupt macro for human-in-the-loop interactions (explicit context)

parent_command

Parent command macro for subgraph-to-parent routing

path_map

Construct a PathMap from key-value pairs.