Struct PTYManager 

pub struct PTYManager { /* private fields */ }

Manager for multiple PTY sessions

Handles lifecycle, message routing, and event aggregation for multiple Claude Code PTY sessions.

Implementations

impl PTYManager

pub fn new(logs_dir: PathBuf) -> Self

Create a new PTY manager

pub async fn set_permission_policy(&self, policy: Arc<dyn PermissionPolicy>)

Set permission policy

pub async fn init_slot(&self, slot: &Slot)

Initialize a slot

pub async fn spawn( &self, slot: &Slot, options: PTYSpawnOptions, ) -> Result<PTYAgentInfo>

Spawn a PTY session for a slot

pub async fn send( &self, slot_id: &str, message: &str, timeout_ms: u64, ) -> Result<PTYExecuteResult>

Send message and wait for response

pub async fn subscribe_session( &self, slot_id: &str, ) -> Result<Receiver<SessionEvent>>

Subscribe to session events (raw data/state/exit/etc.)

pub async fn execute_task( &self, slot: &Slot, task_id: &str, prompt: &str, ) -> Result<PTYExecuteResult>

Execute a task

pub async fn confirm( &self, slot_id: &str, response: ConfirmResponse, ) -> Result<()>

Send confirmation response

pub async fn write(&self, slot_id: &str, data: &str) -> Result<()>

Write raw input to the PTY (no state checks)

pub async fn interrupt(&self, slot_id: &str) -> Result<()>

Send interrupt signal

pub async fn get_screen(&self, slot_id: &str) -> Result<String>

Get screen content

pub async fn get_last_lines( &self, slot_id: &str, n: usize, ) -> Result<Vec<String>>

Get last N lines

pub async fn get_history(&self, slot_id: &str) -> Vec<Message>

Get chat history

pub async fn kill(&self, slot_id: &str) -> Result<()>

Kill a session

pub async fn restart( &self, slot: &Slot, options: PTYSpawnOptions, ) -> Result<PTYAgentInfo>

Restart a session

pub async fn get_status(&self, slot_id: &str) -> Option<PTYAgentInfo>

Get session status

pub async fn get_all_status(&self) -> Vec<PTYAgentInfo>

Get all session statuses

pub async fn is_available(&self, slot_id: &str) -> bool

Check if session is available (idle)

pub async fn is_running(&self, slot_id: &str) -> bool

Check if session is running

pub async fn get_stats(&self) -> ManagerStats

Get statistics

pub fn subscribe(&self) -> Receiver<ManagerEvent>

Subscribe to manager events

pub async fn shutdown(&self)

Shutdown all sessions