Method new

gateway/src/main_service.rs:115–123

(options: ProxyOptions)

impl Proxy {
    pub async fn new(options: ProxyOptions) -> Result<Self> {
        let (port_policy_tx, port_policy_rx) = unbounded_channel();
        let inner = ProxyInner::new(options, port_policy_tx).await?;
        let proxy = Self {
            _inner: Arc::new(inner),
        };
        crate::proxy::port_policy::spawn_fetcher(proxy.clone(), port_policy_rx);
        Ok(proxy)
    }
}

impl ProxyInner {