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>) -> AgentContext

创建新的上下文

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

创建带会话 ID 的上下文

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

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

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

设置配置

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

where T: DeserializeOwned,

获取值

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

where T: Serialize,

设置值

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) -> Receiver<AgentEvent>

订阅事件

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

where T: DeserializeOwned,

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

Trait Implementations

impl AsRef<AgentContext> for RichAgentContext

fn as_ref(&self) -> &AgentContext

Converts this type into a shared reference of the (usually inferred) input type.

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.

impl ContextExt for AgentContext

Implement ContextExt for CoreAgentContext using extension storage

async fn set_extension<T>(&self, value: T)

where T: Send + Sync + Serialize + 'static,

Set extension data

async fn get_extension<T>(&self) -> Option<T>

where T: Send + Sync + DeserializeOwned + 'static,

Get extension data

async fn remove_extension<T>(&self) -> Option<T>

where T: Send + Sync + DeserializeOwned + 'static,

Remove extension data

async fn has_extension<T>(&self) -> bool

where T: Send + Sync + 'static,

Check if extension exists

impl From<AgentContext> for RichAgentContext

fn from(inner: AgentContext) -> RichAgentContext

Converts to this type from the input type.

impl From<RichAgentContext> for AgentContext

fn from(rich: RichAgentContext) -> AgentContext

Converts to this type from the input type.