Struct WorkspaceManager 

pub struct WorkspaceManager { /* private fields */ }

Central registry of all active session workspaces.

Thread-safe via DashMap; every public method is either &self or returns a scoped reference guard.

The optional cache field holds an Arc-wrapped WorkspaceCache implementation. In single-pod deployments the default NoOpCache is used. Multi-pod deployments can supply a ValkeyCache (or any other implementation) via WorkspaceManager::with_cache.

Implementations

impl WorkspaceManager

pub fn new(db: PgPool) -> Self

Create a new, empty workspace manager backed by NoOpCache.

pub fn with_cache(db: PgPool, cache: Arc<dyn WorkspaceCache>) -> Self

Create a workspace manager with an explicit cache implementation.

Use this constructor when a ValkeyCache or other L2 cache is available. Pass Arc::new(NoOpCache) to opt-out of caching.

pub fn cache(&self) -> &dyn WorkspaceCache

Return a reference to the underlying cache implementation.

pub fn next_agent_name(&self, repo_id: &Uuid) -> String

Auto-assign the next agent name for a repository.

Returns “agent-1”, “agent-2”, etc. incrementing per repo.

pub async fn create_workspace( &self, session_id: SessionId, repo_id: RepoId, agent_id: AgentId, changeset_id: Uuid, intent: String, base_commit: String, mode: WorkspaceMode, agent_name: String, ) -> Result<SessionId>

Create a new workspace for a session and register it.

pub fn get_workspace( &self, session_id: &SessionId, ) -> Option<Ref<'_, SessionId, SessionWorkspace>>

Get an immutable reference to a workspace.

pub fn get_workspace_mut( &self, session_id: &SessionId, ) -> Option<RefMut<'_, SessionId, SessionWorkspace>>

Get a mutable reference to a workspace.

pub fn destroy_workspace( &self, session_id: &SessionId, ) -> Option<SessionWorkspace>

Remove and drop a workspace.

pub fn active_count(&self, repo_id: RepoId) -> usize

Count active workspaces for a specific repository.

pub fn active_sessions_for_repo( &self, repo_id: RepoId, exclude_session: Option<SessionId>, ) -> Vec<SessionId>

Return session IDs of all active workspaces for a repo, optionally excluding one session.

pub fn gc_expired(&self) -> Vec<SessionId>

Garbage-collect expired persistent workspaces.

Ephemeral workspaces are not GC’d here — they are destroyed when the session disconnects. This only handles persistent workspaces whose expires_at deadline has passed.

pub fn cleanup_disconnected(&self, active_session_ids: &[Uuid])

Destroy workspaces for sessions that no longer exist. Call this when a session disconnects or during periodic cleanup.

pub fn gc_expired_sessions( &self, idle_ttl: Duration, max_ttl: Duration, ) -> Vec<SessionId>

Remove workspaces that are idle beyond idle_ttl or alive beyond max_ttl.

Returns the list of expired session IDs. This complements [gc_expired] (which handles persistent workspace deadlines) by enforcing activity-based and hard-maximum lifetime limits on all workspaces.

pub fn total_active(&self) -> usize

Total number of active workspaces across all repos.

pub fn describe_other_modifiers( &self, file_path: &str, repo_id: RepoId, exclude_session: SessionId, ) -> String

Describe which other sessions have modified a given file.

Returns a formatted string like "fn create_task modified by agent-2" or "modified by agent-2, agent-3". Returns an empty string if no other session has touched the file.

pub fn list_sessions(&self, repo_id: RepoId) -> Vec<SessionInfo>

List all active sessions for a given repository.