Struct OrchaStorage 

pub struct OrchaStorage { /* private fields */ }

Storage for orcha sessions backed by SQLite

Implementations

impl OrchaStorage

pub async fn new(config: OrchaStorageConfig) -> Result<Self, String>

Create new storage with the given configuration

pub async fn create_session( &self, session_id: SessionId, model: String, working_directory: String, rules: Option<String>, max_retries: u32, agent_mode: AgentMode, tree_id: Option<String>, ) -> Result<SessionInfo, String>

Create a new session

pub async fn get_session( &self, session_id: &SessionId, ) -> Result<SessionInfo, String>

Get session info

pub async fn update_state( &self, session_id: &SessionId, state: SessionState, ) -> Result<(), String>

Update session state

pub async fn increment_retry( &self, session_id: &SessionId, ) -> Result<u32, String>

Increment retry count

pub async fn list_sessions(&self) -> Vec<SessionInfo>

List all sessions

pub async fn delete_session(&self, session_id: &SessionId) -> Result<(), String>

Delete a session

pub async fn create_agent( &self, session_id: &SessionId, claudecode_session_id: String, subtask: String, is_primary: bool, parent_agent_id: Option<AgentId>, ) -> Result<AgentInfo, String>

Create a new agent for a session

pub async fn get_agent(&self, agent_id: &AgentId) -> Result<AgentInfo, String>

Get agent by ID

pub async fn list_agents( &self, session_id: &SessionId, ) -> Result<Vec<AgentInfo>, String>

List all agents for a session

pub async fn update_agent_state( &self, agent_id: &AgentId, state: AgentState, ) -> Result<(), String>

Update agent state

pub async fn get_agent_counts( &self, session_id: &SessionId, ) -> Result<(u32, u32, u32), String>

Get session agent counts (active, completed, failed)