Struct ConcurrentSessionManager 

pub struct ConcurrentSessionManager { /* private fields */ }

并发安全会话管理器

使用读写分离锁，读操作可并发，写操作互斥。

Implementations

impl ConcurrentSessionManager

pub fn new(max_sessions: usize) -> Self

创建新的会话管理器

pub fn default_config() -> Self

使用默认配置创建

pub fn get_state_sync(&self, id: &SessionId) -> Option<AgentState>

同步获取会话状态（用于 AgentRuntime::status 同步方法）

Trait Implementations

impl Default for ConcurrentSessionManager

fn default() -> Self

Returns the “default value” for a type.

impl SessionManagerTrait for ConcurrentSessionManager

fn create<'life0, 'async_trait>( &'life0 self, config: SessionConfig, ) -> Pin<Box<dyn Future<Output = Layer2Result<SessionId>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

创建新会话

fn get<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = Layer2Result<Option<Session>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

获取会话

fn get_or_create<'life0, 'life1, 'async_trait>( &'life0 self, id: Option<&'life1 SessionId>, config: SessionConfig, ) -> Pin<Box<dyn Future<Output = Layer2Result<SessionId>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

获取或创建会话

fn save<'life0, 'life1, 'async_trait>( &'life0 self, session: &'life1 Session, ) -> Pin<Box<dyn Future<Output = Layer2Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

保存会话状态

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = Layer2Result<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

删除会话

fn list<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Layer2Result<Vec<SessionMeta>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

列出所有会话

fn update<'life0, 'life1, 'async_trait, F>( &'life0 self, id: &'life1 SessionId, update_fn: F, ) -> Pin<Box<dyn Future<Output = Layer2Result<bool>> + Send + 'async_trait>>

where F: FnOnce(&mut Session) + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

更新会话状态（带写锁）

fn read<'life0, 'life1, 'async_trait, F, T>( &'life0 self, id: &'life1 SessionId, read_fn: F, ) -> Pin<Box<dyn Future<Output = Layer2Result<Option<T>>> + Send + 'async_trait>>

where F: FnOnce(&Session) -> T + Send + 'async_trait, T: Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

读取会话状态（带读锁）

fn get_state<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = Layer2Result<Option<AgentState>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

获取会话状态

fn set_state<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 SessionId, state: AgentState, ) -> Pin<Box<dyn Future<Output = Layer2Result<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

设置会话状态

fn add_message<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 SessionId, message: Message, ) -> Pin<Box<dyn Future<Output = Layer2Result<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

添加消息到会话

fn get_messages<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = Layer2Result<Option<Vec<Message>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

获取会话消息列表

fn stats(&self) -> SessionStats

获取统计信息