Function fetch_and_store

gateway/src/proxy/port_policy.rs:211–225

(state: &Proxy, instance_id: &str)

}

async fn fetch_and_store(state: &Proxy, instance_id: &str) -> Result<(), FetchError> {
    let (ip, agent_port) = {
        let guard = state.lock();
        let ip = guard
            .instance_ip(instance_id)
            // Instance was recycled — never coming back under this id.
            .ok_or_else(|| FetchError::Permanent(anyhow::anyhow!("unknown instance")))?;
        (ip, guard.config.proxy.agent_port)
    };
    let policy = fetch_port_policy(ip, agent_port).await?;
    state
        .lock()
        .update_instance_port_policy(instance_id, policy);
    Ok(())
}

async fn fetch_port_policy(ip: Ipv4Addr, agent_port: u16) -> Result<PortPolicy, FetchError> {
    let url = format!("http://{ip}:{agent_port}/prpc");