Struct StreamStore 

pub struct StreamStore { /* private fields */ }

Thread-safe store for multiple agent sessions

Implementations

impl StreamStore

pub fn new() -> Self

pub fn create_session(&self, task_id: &str, tag: &str) -> String

Create a new session for a task

pub fn push_event(&self, task_id: &str, event: StreamEvent)

Push an event to a session

pub fn set_session_id(&self, task_id: &str, session_id: &str)

Set the harness session ID for a task

pub fn set_pid(&self, task_id: &str, pid: u32)

Set the process ID for a task

pub fn get_output(&self, task_id: &str, limit: usize) -> Vec<String>

Get output lines for a task

pub fn get_all_output(&self, task_id: &str) -> Vec<String>

Get all output lines for a task, including any partial line

pub fn get_status(&self, task_id: &str) -> Option<SessionStatus>

Get session status

pub fn get_session_id(&self, task_id: &str) -> Option<String>

Get harness session ID for continuation

pub fn active_tasks(&self) -> Vec<String>

List all active task IDs

pub fn all_tasks(&self) -> Vec<String>

Get all task IDs

pub fn has_session(&self, task_id: &str) -> bool

Check if a session exists

pub fn remove_session(&self, task_id: &str) -> Option<SessionStream>

Remove a session

pub fn session_stats(&self, task_id: &str) -> Option<(usize, usize)>

Get session statistics

pub fn save_session_metadata( &self, task_id: &str, project_root: &Path, ) -> Result<()>

Save session metadata for later continuation

Persists the session ID, task ID, tag, and PID to a JSON file in the .scud/headless/ directory for use by the attach command.

pub fn load_session_metadata( task_id: &str, project_root: &Path, ) -> Result<Option<String>>

Load session metadata from disk

Returns the stored session_id if available for continuation.

Trait Implementations

impl Clone for StreamStore

fn clone(&self) -> StreamStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StreamStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for StreamStore

fn default() -> StreamStore

Returns the “default value” for a type.