Struct AgentState 

pub struct AgentState {
    pub messages: Vec<Message>,
    pub iterations: usize,
    pub total_tool_calls: usize,
    pub output_tokens: usize,
    pub reasoning_tokens: usize,
    pub compact_count: usize,
    pub stop_reason: Option<StopReason>,
    pub last_response: Option<ChatResponse>,
}

Agent 类型化状态。

替代 HashMap<String, Value> 中通过 StateKey<T> 存取的模式。 所有字段编译期可见，零运行时类型检查开销。

Fields

messages: Vec<Message>

消息历史（Assistant + Tool + User）

iterations: usize

当前迭代轮次

total_tool_calls: usize

累计工具调用总数

output_tokens: usize

累计输出 Token 数（Text，不含 Thinking）

reasoning_tokens: usize

累计推理 Token 数（Thinking，不含 Text）

compact_count: usize

累计压缩次数

stop_reason: Option<StopReason>

停止原因（终态）

last_response: Option<ChatResponse>

最后一次 LLM 响应

Implementations

impl AgentState

pub fn from_messages(messages: Vec<Message>) -> Self

从初始消息列表创建 AgentState。

pub fn estimated_context_tokens(&self) -> usize

实时派生上下文 Token 数（从 messages 估算）。 供 BudgetCondition 判断是否需要压缩。

pub fn reached_max(&self, max_iterations: usize) -> bool

检查是否已达到最大迭代轮次。

pub fn exceeded_output(&self, max: Option<u32>) -> bool

检查是否超过总输出预算。

pub fn exceeded_reasoning(&self, max: Option<u32>) -> bool

检查是否超过总推理预算。

pub fn exceeded_output_with_extra(&self, max: Option<u32>, extra: usize) -> bool

检查加上额外 Token 后是否超过总输出预算。

用于 Mutation 未 apply 时的预判（节点 emit Mutation 之前）。

pub fn exceeded_reasoning_with_extra( &self, max: Option<u32>, extra: usize, ) -> bool

检查加上额外 Token 后是否超过总推理预算。

pub fn is_terminal(&self) -> bool

检查是否已终止（有 stop_reason）。

pub fn messages_ref(&self) -> &[Message]

获取当前消息引用。

Trait Implementations

impl Clone for AgentState

fn clone(&self) -> AgentState

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AgentState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for AgentState

fn default() -> AgentState

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for AgentState

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl LeafNode<AgentState> for PostLLMGuard

fn execute<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 mut LeafContext<'life2, AgentState>, ) -> Pin<Box<dyn Future<Output = Result<(), GraphError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

执行节点逻辑。

impl LeafNode<AgentState> for CompactorNode

fn execute<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 mut LeafContext<'life2, AgentState>, ) -> Pin<Box<dyn Future<Output = Result<(), GraphError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

执行节点逻辑。

impl LeafNode<AgentState> for BudgetCondition

fn execute<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 mut LeafContext<'life2, AgentState>, ) -> Pin<Box<dyn Future<Output = Result<(), GraphError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

执行节点逻辑。

impl LeafNode<AgentState> for LLMNode

fn execute<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 mut LeafContext<'life2, AgentState>, ) -> Pin<Box<dyn Future<Output = Result<(), GraphError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

执行节点逻辑。

impl LeafNode<AgentState> for ToolNode

fn execute<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 mut LeafContext<'life2, AgentState>, ) -> Pin<Box<dyn Future<Output = Result<(), GraphError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

执行节点逻辑。

impl MergeStrategy<AgentState> for AgentStateMerge

fn merge(branches: Vec<AgentState>) -> Result<AgentState, WorkflowError>

合并多个并行分支的状态。

fn default_instance() -> Self

创建策略的默认实例（供 ParallelNodeBuilder 使用）。 对于无状态策略（如 StateMerge、LastWriteWins），直接返回自身。

impl Serialize for AgentState

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StateMutation<AgentState> for AgentMutation

fn apply(self, state: &mut AgentState)

将此 Mutation 应用到目标 State。

fn combine(self, _other: Self) -> Option<Self>

将此 Mutation 合并到另一个同类型 Mutation 中（可选）。

impl WorkflowState for AgentState

type Mutation = AgentMutation

与此状态关联的 Mutation 类型。

fn apply_batch(&mut self, mutations: impl IntoIterator<Item = Self::Mutation>)

批量应用 Mutation — 唯一公开入口。

fn initial() -> Self

where Self: Default,

创建默认/初始状态。