Function timeout

src/cluster/src/communication.rs:514–521

Helper for performing network I/O under a timeout. This is meant to be used on network calls performed after a connection to a peer has been successfully established, to avoid the `create_sockets` protocol becoming stuck because a peer goes away without resetting the connection. We assume fast same-datacenter connections, so we can choose a relatively small timeout.

(fut: F)

/// goes away without resetting the connection. We assume fast same-datacenter connections, so we
/// can choose a relatively small timeout.
async fn timeout<F, R>(fut: F) -> anyhow::Result<R>
where
    F: Future<Output = std::io::Result<R>>,
{
    let timeout = Duration::from_secs(1);
    let result = mz_ore::future::timeout(timeout, fut).await?;
    Ok(result)
}

#[cfg(test)]
mod turmoil_tests {