pub struct Session {Show 26 fields
pub id: String,
pub config: SessionConfig,
pub state: SessionState,
pub messages: Vec<Message>,
pub context_usage: ContextUsage,
pub total_usage: TokenUsage,
pub total_cost: f64,
pub model_name: Option<String>,
pub tools: Vec<ToolDefinition>,
pub thinking_enabled: bool,
pub thinking_budget: Option<usize>,
pub llm_client: Option<Arc<dyn LlmClient>>,
pub created_at: i64,
pub updated_at: i64,
pub command_queue: SessionLaneQueue,
pub confirmation_manager: Arc<ConfirmationManager>,
pub permission_policy: Arc<RwLock<PermissionPolicy>>,
pub context_providers: Vec<Arc<dyn ContextProvider>>,
pub tasks: Vec<Task>,
pub parent_id: Option<String>,
pub memory: Arc<RwLock<AgentMemory>>,
pub current_plan: Arc<RwLock<Option<ExecutionPlan>>>,
pub security_guard: Option<Arc<SecurityGuard>>,
pub tool_metrics: Arc<RwLock<ToolMetrics>>,
pub cost_records: Vec<LlmCostRecord>,
pub loaded_skills: Vec<Skill>,
/* private fields */
}Fields§
§id: String§config: SessionConfig§state: SessionState§messages: Vec<Message>§context_usage: ContextUsage§total_usage: TokenUsage§total_cost: f64Cumulative dollar cost for this session
model_name: Option<String>Model name for cost calculation
tools: Vec<ToolDefinition>§thinking_enabled: bool§thinking_budget: Option<usize>§llm_client: Option<Arc<dyn LlmClient>>Per-session LLM client (overrides default if set)
created_at: i64Creation timestamp (Unix epoch seconds)
updated_at: i64Last update timestamp (Unix epoch seconds)
command_queue: SessionLaneQueuePer-session command queue (a3s-lane backed)
confirmation_manager: Arc<ConfirmationManager>HITL confirmation manager
permission_policy: Arc<RwLock<PermissionPolicy>>Permission policy for tool execution
context_providers: Vec<Arc<dyn ContextProvider>>Context providers for augmenting prompts with external context
tasks: Vec<Task>Task list for tracking
parent_id: Option<String>Parent session ID (for subagent sessions)
memory: Arc<RwLock<AgentMemory>>Agent memory system for this session
current_plan: Arc<RwLock<Option<ExecutionPlan>>>Current execution plan (if any)
security_guard: Option<Arc<SecurityGuard>>Security guard (if enabled)
tool_metrics: Arc<RwLock<ToolMetrics>>Per-session tool execution metrics
cost_records: Vec<LlmCostRecord>Per-call LLM cost records for cross-session aggregation
loaded_skills: Vec<Skill>Loaded skills for tool filter enforcement in the agent loop
Implementations§
Source§impl Session
impl Session
Sourcepub async fn new(
id: String,
config: SessionConfig,
tools: Vec<ToolDefinition>,
) -> Result<Self>
pub async fn new( id: String, config: SessionConfig, tools: Vec<ToolDefinition>, ) -> Result<Self>
Create a new session (async due to SessionLaneQueue initialization)
Sourcepub fn is_child_session(&self) -> bool
pub fn is_child_session(&self) -> bool
Check if this is a child session (has a parent)
Sourcepub fn parent_session_id(&self) -> Option<&str>
pub fn parent_session_id(&self) -> Option<&str>
Get the parent session ID if this is a child session
Sourcepub fn subscribe_events(&self) -> Receiver<AgentEvent>
pub fn subscribe_events(&self) -> Receiver<AgentEvent>
Get a receiver for session events
Sourcepub fn event_tx(&self) -> Sender<AgentEvent>
pub fn event_tx(&self) -> Sender<AgentEvent>
Get the event broadcaster
Sourcepub async fn set_confirmation_policy(&self, policy: ConfirmationPolicy)
pub async fn set_confirmation_policy(&self, policy: ConfirmationPolicy)
Update the confirmation policy
Sourcepub async fn confirmation_policy(&self) -> ConfirmationPolicy
pub async fn confirmation_policy(&self) -> ConfirmationPolicy
Get the current confirmation policy
Sourcepub async fn set_permission_policy(&self, policy: PermissionPolicy)
pub async fn set_permission_policy(&self, policy: PermissionPolicy)
Update the permission policy
Sourcepub async fn permission_policy(&self) -> PermissionPolicy
pub async fn permission_policy(&self) -> PermissionPolicy
Get the current permission policy
Sourcepub async fn check_permission(
&self,
tool_name: &str,
args: &Value,
) -> PermissionDecision
pub async fn check_permission( &self, tool_name: &str, args: &Value, ) -> PermissionDecision
Check permission for a tool invocation
Sourcepub async fn add_allow_rule(&self, rule: &str)
pub async fn add_allow_rule(&self, rule: &str)
Add an allow rule to the permission policy
Sourcepub async fn add_deny_rule(&self, rule: &str)
pub async fn add_deny_rule(&self, rule: &str)
Add a deny rule to the permission policy
Sourcepub async fn add_ask_rule(&self, rule: &str)
pub async fn add_ask_rule(&self, rule: &str)
Add an ask rule to the permission policy
Sourcepub fn add_context_provider(&mut self, provider: Arc<dyn ContextProvider>)
pub fn add_context_provider(&mut self, provider: Arc<dyn ContextProvider>)
Add a context provider to the session
Sourcepub fn remove_context_provider(&mut self, name: &str) -> bool
pub fn remove_context_provider(&mut self, name: &str) -> bool
Remove a context provider by name
Returns true if a provider was removed, false otherwise.
Sourcepub fn context_provider_names(&self) -> Vec<String>
pub fn context_provider_names(&self) -> Vec<String>
Get the names of all registered context providers
Sourcepub fn set_tasks(&mut self, tasks: Vec<Task>)
pub fn set_tasks(&mut self, tasks: Vec<Task>)
Set the task list (replaces entire list)
Broadcasts a TaskUpdated event after updating.
Sourcepub fn active_task_count(&self) -> usize
pub fn active_task_count(&self) -> usize
Get count of active (non-completed, non-cancelled) tasks
Sourcepub async fn set_lane_handler(
&self,
lane: SessionLane,
config: LaneHandlerConfig,
)
pub async fn set_lane_handler( &self, lane: SessionLane, config: LaneHandlerConfig, )
Set handler mode for a lane
Sourcepub async fn get_lane_handler(&self, lane: SessionLane) -> LaneHandlerConfig
pub async fn get_lane_handler(&self, lane: SessionLane) -> LaneHandlerConfig
Get handler config for a lane
Sourcepub async fn complete_external_task(
&self,
task_id: &str,
result: ExternalTaskResult,
) -> bool
pub async fn complete_external_task( &self, task_id: &str, result: ExternalTaskResult, ) -> bool
Complete an external task
Sourcepub async fn pending_external_tasks(&self) -> Vec<ExternalTask>
pub async fn pending_external_tasks(&self) -> Vec<ExternalTask>
Get pending external tasks
Sourcepub async fn dead_letters(&self) -> Vec<DeadLetter>
pub async fn dead_letters(&self) -> Vec<DeadLetter>
Get dead letters from the queue’s DLQ
Sourcepub async fn queue_metrics(&self) -> Option<MetricsSnapshot>
pub async fn queue_metrics(&self) -> Option<MetricsSnapshot>
Get queue metrics snapshot
Sourcepub async fn queue_stats(&self) -> SessionQueueStats
pub async fn queue_stats(&self) -> SessionQueueStats
Get queue statistics
Sourcepub async fn start_queue(&self) -> Result<()>
pub async fn start_queue(&self) -> Result<()>
Start the command queue scheduler
Sourcepub async fn stop_queue(&self)
pub async fn stop_queue(&self)
Stop the command queue scheduler
Sourcepub fn add_message(&mut self, message: Message)
pub fn add_message(&mut self, message: Message)
Add a message to history
Sourcepub fn update_usage(&mut self, usage: &TokenUsage)
pub fn update_usage(&mut self, usage: &TokenUsage)
Update context usage after a response
Sourcepub async fn compact(&mut self, llm_client: &Arc<dyn LlmClient>) -> Result<()>
pub async fn compact(&mut self, llm_client: &Arc<dyn LlmClient>) -> Result<()>
Compact context by summarizing old messages
Sourcepub fn set_completed(&mut self)
pub fn set_completed(&mut self)
Set session state to completed
Sourcepub fn to_session_data(&self, llm_config: Option<LlmConfigData>) -> SessionData
pub fn to_session_data(&self, llm_config: Option<LlmConfigData>) -> SessionData
Convert to serializable SessionData for persistence
Sourcepub fn restore_from_data(&mut self, data: &SessionData)
pub fn restore_from_data(&mut self, data: &SessionData)
Restore session state from SessionData
Note: This only restores serializable fields. Non-serializable fields (event_tx, command_queue, confirmation_manager) are already initialized in Session::new().