Struct DevProxyRegistry 

pub struct DevProxyRegistry {
    routes: Arc<RwLock<HashMap<String, Route>>>,
}

"<project>-<agent_id>" → the container’s internal ip:port its dev server is actually listening on. Cleared per-agent when that agent’s container stops (ContainerManager::stop/remove in container.rs call unregister_agent — see that module’s cleanup_dev_proxy_routes).

Cheap to clone (one Arc inside) — held directly by AppState and passed to the proxy’s own axum router as state.

Fields

routes: Arc<RwLock<HashMap<String, Route>>>

Implementations

impl DevProxyRegistry

pub fn new() -> Self

pub fn routing_key(project: &str, agent_id: &str) -> String

The exact routing key both register and the Host-header lookup use — kept as one function so the two can never drift apart. Lowercased: hostnames are case-insensitive, and a browser may send whatever case the URL bar has, so registration and lookup must agree regardless of how either side capitalized project/agent_id.

pub async fn register(&self, project: &str, agent_id: &str, addr: SocketAddr)

pub async fn unregister_agent(&self, agent_id: &str)

Removes every registration belonging to agent_id, regardless of project name — called when that agent’s container stops so a dead container never keeps serving (stale) proxy traffic.

Matches on the stored agent_id field, NOT a key.ends_with(...) string check — agent ids can themselves contain hyphens (e.g. a named identity like korp-asaf), so a suffix match on the combined "<project>-<agent_id>" key could wrongly match a different agent’s registration whose id happens to end in the same substring.

pub async fn lookup(&self, key: &str) -> Option<SocketAddr>

Trait Implementations

impl Clone for DevProxyRegistry

fn clone(&self) -> DevProxyRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for DevProxyRegistry

fn default() -> DevProxyRegistry

Returns the “default value” for a type.