Struct GraphHandle 

pub struct GraphHandle { /* private fields */ }

Graph 执行句柄 — 用于与运行中的 Graph 交互。

通过 execute_stream() 返回，消费者使用此句柄提交 Barrier 决策或取消执行。

Implementations

impl GraphHandle

pub async fn decide( &self, barrier_id: BarrierId, decision: BarrierDecision, ) -> Result<(), GraphError>

提交 Barrier 决策（精确匹配）。

• barrier_id — 来自 GraphEvent::BarrierWaiting 的 ID
• decision — 审批决策

一次性语义： 每个 BarrierId 只能提交一次决策，重复提交返回错误。

pub async fn decide_wildcard( &self, node_id: impl Into<String>, decision: BarrierDecision, ) -> Result<(), GraphError>

提交通配决策 — 匹配指定 node_id 的所有 occurrence。

适用于“每次都 Approve“等场景。

handle.decide_wildcard("approve_deploy", BarrierDecision::Approve);
// 匹配 approve_deploy 的所有 occurrence

pub fn cancel(&self)

强制取消正在执行的 Graph。

发送取消信号后，executor 在主循环检测点响应：

• 立即终止执行，发送 GraphError 事件
• 如果正在等待 Barrier 决策，中断等待

多次调用安全（idempotent）。