Function start

gateway/src/proxy.rs:241–268

(config: ProxyConfig, app_state: Proxy)

}

pub fn start(config: ProxyConfig, app_state: Proxy) -> Result<()> {
    std::thread::Builder::new()
        .name("proxy-main".to_string())
        .spawn(move || {
            // Create a new single-threaded runtime
            let rt = tokio::runtime::Builder::new_current_thread()
                .enable_all()
                .build()
                .or_panic("Failed to build Tokio runtime");

            let worker_rt = tokio::runtime::Builder::new_multi_thread()
                .thread_name("proxy-worker")
                .enable_all()
                .worker_threads(config.workers)
                .build()
                .or_panic("Failed to build Tokio runtime");

            // Run the proxy_main function in this runtime
            if let Err(err) = rt.block_on(proxy_main(&worker_rt, &config, app_state)) {
                error!(
                    "error on {}:{:?}: {err:?}",
                    config.listen_addr, config.listen_port
                );
            }
        })
        .context("Failed to spawn proxy-main thread")?;
    Ok(())
}

#[cfg(test)]
mod tests {