Struct AgentContext 

pub struct AgentContext<B: ContextBackend> { /* private fields */ }

LLM 对话上下文管理器，kameo Actor。

管理三区 + 可选 Scratch 消息模型（immutable → compressed → incremental → scratch），提供：

• 消息增删改查（RequestAppend、RequestUpdate、RequestRemove 等）
• 对话发送（RequestSend、RequestSendStream），支持通过 super::CommonOpts::scratch 追加临时元数据
• 上下文压缩（RequestCompress）
• Token 估算（RequestEstimateTokens）
• 压缩订阅管理（RequestSubscribeCompressed、RequestUnsubscribeCompressed）

构造

let actor_ref = AgentContext::spawn(AgentContext::new(backend, vec![]));

Implementations

impl<B: ContextBackend> AgentContext<B>

pub fn new(backend: B, immutable: Vec<B::Message>) -> Self

创建新的上下文管理器。

• backend: 实现了 ContextBackend 的 LLM 后端实例
• immutable: 初始不可变消息（系统提示词等），放入 immutable 区

Trait Implementations

impl<B: ContextBackend> Actor for AgentContext<B>

type Args = AgentContext<B>

Arguments to initialize the actor.

type Error = Infallible

Actor error type.

fn name() -> &'static str

The name of the actor, which can be useful for logging or debugging.

async fn on_start( state: Self::Args, _actor_ref: ActorRef<Self>, ) -> Result<Self, Self::Error>

Called when the actor starts, before it processes any messages.

fn supervision_strategy() -> SupervisionStrategy

Defines the supervision strategy for this actor when acting as a supervisor.

fn on_message( &mut self, msg: Box<dyn DynMessage<Self>>, actor_ref: ActorRef<Self>, tx: Option<Sender<Result<Box<dyn Any + Send>, SendError<Box<dyn Any + Send>, Box<dyn Any + Send>>>>>, stop: &mut bool, ) -> impl Future<Output = Result<(), Box<dyn ReplyError>>> + Send

Called when the actor receives a message to be processed.

fn on_panic( &mut self, actor_ref: WeakActorRef<Self>, err: PanicError, ) -> impl Future<Output = Result<ControlFlow<ActorStopReason>, Self::Error>> + Send

Called when the actor encounters a panic or an error during “tell” message handling.

fn on_link_died( &mut self, actor_ref: WeakActorRef<Self>, id: ActorId, reason: ActorStopReason, ) -> impl Future<Output = Result<ControlFlow<ActorStopReason>, Self::Error>> + Send

Called when a linked actor dies.

fn on_stop( &mut self, actor_ref: WeakActorRef<Self>, reason: ActorStopReason, ) -> impl Future<Output = Result<(), Self::Error>> + Send

Called before the actor stops.

fn next( &mut self, actor_ref: WeakActorRef<Self>, mailbox_rx: &mut MailboxReceiver<Self>, ) -> impl Future<Output = Result<Option<Signal<Self>>, Self::Error>> + Send

Awaits the next signal typically from the mailbox.

impl<B: ContextBackend> Message<RequestAppend<<B as ContextBackend>::Message>> for AgentContext<B>

type Reply = ()

The reply sent back to the message caller.

async fn handle( &mut self, msg: RequestAppend<B::Message>, _ctx: &mut Context<Self, Self::Reply>, ) -> Self::Reply

Handler for this message.

fn name() -> &'static str

The name of the message, which can be useful for logging or debugging.

impl<B: ContextBackend> Message<RequestClear> for AgentContext<B>

type Reply = ()

The reply sent back to the message caller.

async fn handle( &mut self, _msg: RequestClear, _ctx: &mut Context<Self, Self::Reply>, ) -> Self::Reply

Handler for this message.

fn name() -> &'static str

The name of the message, which can be useful for logging or debugging.

impl<B: ContextBackend> Message<RequestCompress<<B as ContextBackend>::Opts>> for AgentContext<B>

type Reply = Result<(), AgentError>

The reply sent back to the message caller.

async fn handle( &mut self, msg: RequestCompress<B::Opts>, _ctx: &mut Context<Self, Self::Reply>, ) -> Self::Reply

Handler for this message.

fn name() -> &'static str

The name of the message, which can be useful for logging or debugging.

impl<B: ContextBackend> Message<RequestCompressed> for AgentContext<B>

type Reply = Vec<<B as ContextBackend>::Message>

The reply sent back to the message caller.

async fn handle( &mut self, _msg: RequestCompressed, _ctx: &mut Context<Self, Self::Reply>, ) -> Self::Reply

Handler for this message.

fn name() -> &'static str

The name of the message, which can be useful for logging or debugging.

impl<B: ContextBackend> Message<RequestEstimateTokens> for AgentContext<B>

type Reply = usize

The reply sent back to the message caller.

async fn handle( &mut self, _msg: RequestEstimateTokens, _ctx: &mut Context<Self, Self::Reply>, ) -> Self::Reply

Handler for this message.

fn name() -> &'static str

The name of the message, which can be useful for logging or debugging.

impl<B: ContextBackend> Message<RequestExportAll> for AgentContext<B>

type Reply = Result<String, AgentError>

The reply sent back to the message caller.

async fn handle( &mut self, _msg: RequestExportAll, _ctx: &mut Context<Self, Self::Reply>, ) -> Self::Reply

Handler for this message.

fn name() -> &'static str

The name of the message, which can be useful for logging or debugging.

impl<B: ContextBackend> Message<RequestExportIncremental> for AgentContext<B>

type Reply = Result<String, AgentError>

The reply sent back to the message caller.

async fn handle( &mut self, _msg: RequestExportIncremental, _ctx: &mut Context<Self, Self::Reply>, ) -> Self::Reply

Handler for this message.

fn name() -> &'static str

The name of the message, which can be useful for logging or debugging.

impl<B: ContextBackend> Message<RequestExtend<<B as ContextBackend>::Message>> for AgentContext<B>

type Reply = ()

The reply sent back to the message caller.

async fn handle( &mut self, msg: RequestExtend<B::Message>, _ctx: &mut Context<Self, Self::Reply>, ) -> Self::Reply

Handler for this message.

fn name() -> &'static str

The name of the message, which can be useful for logging or debugging.

impl<B: ContextBackend> Message<RequestFindByRole> for AgentContext<B>

type Reply = Vec<<B as ContextBackend>::Message>

The reply sent back to the message caller.

async fn handle( &mut self, msg: RequestFindByRole, _ctx: &mut Context<Self, Self::Reply>, ) -> Self::Reply

Handler for this message.

fn name() -> &'static str

The name of the message, which can be useful for logging or debugging.

impl<B: ContextBackend> Message<RequestGet> for AgentContext<B>

type Reply = Option<<B as ContextBackend>::Message>

The reply sent back to the message caller.

async fn handle( &mut self, msg: RequestGet, _ctx: &mut Context<Self, Self::Reply>, ) -> Self::Reply

Handler for this message.

fn name() -> &'static str

The name of the message, which can be useful for logging or debugging.

impl<B: ContextBackend> Message<RequestImmutable> for AgentContext<B>

type Reply = Vec<<B as ContextBackend>::Message>

The reply sent back to the message caller.

async fn handle( &mut self, _msg: RequestImmutable, _ctx: &mut Context<Self, Self::Reply>, ) -> Self::Reply

Handler for this message.

fn name() -> &'static str

The name of the message, which can be useful for logging or debugging.

impl<B: ContextBackend> Message<RequestImportIncremental> for AgentContext<B>

type Reply = Result<(), AgentError>

The reply sent back to the message caller.

async fn handle( &mut self, msg: RequestImportIncremental, _ctx: &mut Context<Self, Self::Reply>, ) -> Self::Reply

Handler for this message.

fn name() -> &'static str

The name of the message, which can be useful for logging or debugging.

impl<B: ContextBackend> Message<RequestIncremental> for AgentContext<B>

type Reply = Vec<<B as ContextBackend>::Message>

The reply sent back to the message caller.

async fn handle( &mut self, _msg: RequestIncremental, _ctx: &mut Context<Self, Self::Reply>, ) -> Self::Reply

Handler for this message.

fn name() -> &'static str

The name of the message, which can be useful for logging or debugging.

impl<B: ContextBackend> Message<RequestInsert<<B as ContextBackend>::Message>> for AgentContext<B>

type Reply = Result<(), AgentError>

The reply sent back to the message caller.

async fn handle( &mut self, msg: RequestInsert<B::Message>, _ctx: &mut Context<Self, Self::Reply>, ) -> Self::Reply

Handler for this message.

fn name() -> &'static str

The name of the message, which can be useful for logging or debugging.

impl<B: ContextBackend> Message<RequestIsEmpty> for AgentContext<B>

type Reply = bool

The reply sent back to the message caller.

async fn handle( &mut self, _msg: RequestIsEmpty, _ctx: &mut Context<Self, Self::Reply>, ) -> Self::Reply

Handler for this message.

fn name() -> &'static str

The name of the message, which can be useful for logging or debugging.

impl<B: ContextBackend> Message<RequestLen> for AgentContext<B>

type Reply = usize

The reply sent back to the message caller.

async fn handle( &mut self, _msg: RequestLen, _ctx: &mut Context<Self, Self::Reply>, ) -> Self::Reply

Handler for this message.

fn name() -> &'static str

The name of the message, which can be useful for logging or debugging.

impl<B: ContextBackend> Message<RequestMessages> for AgentContext<B>

type Reply = Vec<<B as ContextBackend>::Message>

The reply sent back to the message caller.

async fn handle( &mut self, _msg: RequestMessages, _ctx: &mut Context<Self, Self::Reply>, ) -> Self::Reply

Handler for this message.

fn name() -> &'static str

The name of the message, which can be useful for logging or debugging.

impl<B: ContextBackend> Message<RequestPop> for AgentContext<B>

type Reply = Option<<B as ContextBackend>::Message>

The reply sent back to the message caller.

async fn handle( &mut self, _msg: RequestPop, _ctx: &mut Context<Self, Self::Reply>, ) -> Self::Reply

Handler for this message.

fn name() -> &'static str

The name of the message, which can be useful for logging or debugging.

impl<B: ContextBackend> Message<RequestRemove> for AgentContext<B>

type Reply = Result<(), AgentError>

The reply sent back to the message caller.

async fn handle( &mut self, msg: RequestRemove, _ctx: &mut Context<Self, Self::Reply>, ) -> Self::Reply

Handler for this message.

fn name() -> &'static str

The name of the message, which can be useful for logging or debugging.

impl<B: ContextBackend> Message<RequestRetain> for AgentContext<B>

type Reply = ()

The reply sent back to the message caller.

async fn handle( &mut self, msg: RequestRetain, _ctx: &mut Context<Self, Self::Reply>, ) -> Self::Reply

Handler for this message.

fn name() -> &'static str

The name of the message, which can be useful for logging or debugging.

impl<B: ContextBackend> Message<RequestSend<<B as ContextBackend>::Opts>> for AgentContext<B>

type Reply = Result<<B as ContextBackend>::Response, AgentError>

The reply sent back to the message caller.

async fn handle( &mut self, msg: RequestSend<B::Opts>, _ctx: &mut Context<Self, Self::Reply>, ) -> Self::Reply

Handler for this message.

fn name() -> &'static str

The name of the message, which can be useful for logging or debugging.

impl<B: ContextBackend + Clone> Message<RequestSendStream<<B as ContextBackend>::Opts>> for AgentContext<B>

type Reply = Result<AgentSendStream<B>, AgentError>

The reply sent back to the message caller.

async fn handle( &mut self, msg: RequestSendStream<B::Opts>, _ctx: &mut Context<Self, Self::Reply>, ) -> Self::Reply

Handler for this message.

fn name() -> &'static str

The name of the message, which can be useful for logging or debugging.

impl<B: ContextBackend> Message<RequestSubscribeCompressed<<B as ContextBackend>::Message>> for AgentContext<B>

type Reply = ()

The reply sent back to the message caller.

async fn handle( &mut self, msg: RequestSubscribeCompressed<B::Message>, _ctx: &mut Context<Self, Self::Reply>, ) -> Self::Reply

Handler for this message.

fn name() -> &'static str

The name of the message, which can be useful for logging or debugging.

impl<B: ContextBackend> Message<RequestUnsubscribeCompressed> for AgentContext<B>

type Reply = ()

The reply sent back to the message caller.

async fn handle( &mut self, _msg: RequestUnsubscribeCompressed, _ctx: &mut Context<Self, Self::Reply>, ) -> Self::Reply

Handler for this message.

fn name() -> &'static str

The name of the message, which can be useful for logging or debugging.

impl<B: ContextBackend> Message<RequestUpdate<<B as ContextBackend>::Message>> for AgentContext<B>

type Reply = Result<(), AgentError>

The reply sent back to the message caller.

async fn handle( &mut self, msg: RequestUpdate<B::Message>, _ctx: &mut Context<Self, Self::Reply>, ) -> Self::Reply

Handler for this message.

fn name() -> &'static str

The name of the message, which can be useful for logging or debugging.