Struct NodeContext 

pub struct NodeContext<'a, S: WorkflowState = State> { /* private fields */ }

节点上下文 — Runtime Handle（运行时句柄）。

泛型参数

• S — 类型化状态（默认 State = HashMap，向后兼容）

设计原则

NodeContext 是 Runtime Handle，不是 Runtime State。

• 节点只借用，不拥有。零复制透传给子组件
• 禁止放入：RuntimeEventEmitter、TraceId、SpanId、GraphHandle、ExecutorConfig

Effects 缓冲（v0.4+）

effects 字段收集节点产生的 Effect（领域事件）， 供上层（如 Executor）统一 apply 到 Typed State。

Implementations

impl<'a, S: WorkflowState> NodeContext<'a, S>

pub fn new( state: &'a mut S, branch: &'a mut BranchState, stream: Option<&'a dyn StreamSink>, cancel: CancellationToken, ) -> Self

创建新的 NodeContext。

pub fn state(&self) -> &S

获取类型化状态引用。

pub fn state_mut(&mut self) -> &mut S

获取类型化状态可变引用。

pub fn branch(&self) -> &BranchState

获取底层 BranchState 引用（用于 fork 等操作）。

pub fn branch_mut(&mut self) -> &mut BranchState

获取底层 BranchState 可变引用。

pub fn emit(&self, chunk: StreamChunk)

发射数据面事件（无 stream 则静默丢弃）。

pub fn emit_flow_event(&mut self, event: FlowEvent)

发射控制面 FlowEvent（缓冲到 NodeContext，供 Executor 收集转发）。

pub fn is_cancelled(&self) -> bool

检查是否已取消。

pub fn cancel_token(&self) -> &CancellationToken

获取取消令牌引用。

pub fn goto(&mut self, target: impl Into<String>)

跳转到指定节点。

pub fn end(&mut self)

结束执行。

pub fn pause(&mut self, barrier_id: BarrierId, timeout: Option<Duration>)

Barrier 挂起。

pub fn set_token_cost(&mut self, cost: f64)

设置 token 成本。

pub fn set_has_side_effects(&mut self)

标记有副作用。

pub fn emit_effect(&mut self, effect: S::Effect)

发射一个 Effect（强类型领域事件）到缓冲。

零序列化开销 — 直接存储 S::Effect。

pub fn consume_effects(&mut self) -> Vec<S::Effect>

消费 Effect 缓冲（返回所有收集的 Effect）。

pub fn effects_len(&self) -> usize

获取已收集的 Effect 数量（不消费）。

pub fn take_control(&mut self) -> (NextAction, Option<ExecutionSignal>)

消费控制信号（Executor 调用）。

pub fn take_metadata(&mut self) -> NodeMetadata

获取元数据（Executor 调用）。

pub fn stream(&self) -> Option<&'a dyn StreamSink>

获取数据面发射器引用。

pub fn take_flow_events(&mut self) -> Vec<FlowEvent>

消费 FlowEvent 缓冲（Executor 调用）。