Struct AgentContext 

pub struct AgentContext {
    pub execution_id: String,
    pub session_id: Option<String>,
    /* private fields */
}

核心执行上下文 (Core Agent Context)

提供最小的内核原语用于 Agent 执行：

• 执行 ID 和会话 ID
• 父子上下文关系（用于嵌套执行）
• 通用键值存储
• 中断信号
• 事件总线
• 配置

示例

use mofa_kernel::agent::context::CoreAgentContext;

let ctx = CoreAgentContext::new("execution-123");
ctx.set("user_id", "user-456").await;
let value: Option<String> = ctx.get("user_id").await;

Fields

execution_id: String

执行 ID (唯一标识本次执行)

session_id: Option<String>

会话 ID (用于多轮对话)

Implementations

impl AgentContext

pub fn new(execution_id: impl Into<String>) -> Self

创建新的上下文

pub fn with_session( execution_id: impl Into<String>, session_id: impl Into<String>, ) -> Self

创建带会话 ID 的上下文

pub fn child(&self, execution_id: impl Into<String>) -> Self

创建子上下文 (用于子任务执行)

pub fn with_config(self, config: ContextConfig) -> Self

设置配置

pub async fn get<T: DeserializeOwned>(&self, key: &str) -> Option<T>

获取值

pub async fn set<T: Serialize>(&self, key: &str, value: T)

设置值

pub async fn remove(&self, key: &str) -> Option<Value>

删除值

pub async fn contains(&self, key: &str) -> bool

检查是否存在值

pub async fn keys(&self) -> Vec<String>

获取所有键

pub fn is_interrupted(&self) -> bool

检查是否被中断

pub fn trigger_interrupt(&self)

触发中断

pub fn clear_interrupt(&self)

清除中断状态

pub fn config(&self) -> &ContextConfig

获取配置

pub fn parent(&self) -> Option<&Arc<AgentContext>>

获取父上下文

pub async fn emit_event(&self, event: AgentEvent)

发送事件

pub async fn subscribe(&self, event_type: &str) -> EventReceiver

订阅事件

pub async fn find<T: DeserializeOwned>(&self, key: &str) -> Option<T>

从父上下文查找值 (递归向上查找)

Trait Implementations

impl Clone for AgentContext

fn clone(&self) -> AgentContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.