Function mz_storage::boundary::tcp_boundary::server::handle_compute_inner
source · [−]async fn handle_compute_inner(
client_id: u64,
state: Arc<Mutex<Shared>>,
socket: TcpStream,
active_source_ids: &mut HashSet<SubscriptionId>,
render_requests: UnboundedSender<SourceInstanceRequest>,
storage_workers: usize
) -> Result<()>
Expand description
Inner portion to handle a compute client.