async fn handle_cluster_proxy_inner( cluster_id: String, replica_id: String, process: usize, path: &str, config: Extension<Arc<ClusterProxyConfig>>, req: Request<Body>, ) -> Result<Response, (StatusCode, String)>