shotover 0.7.2

Shotover API for building custom transforms
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

//! Hot reload functionality for zero-downtime updates of Shotover instances.

pub mod client;
pub mod fd_utils;
pub mod json_parsing;
pub mod protocol;
pub mod server;

#[cfg(test)]
pub mod tests {
    use uds::tokio::UnixSeqpacketConn;

    pub async fn wait_for_unix_socket_connection(socket_path: &str, timeout_ms: u64) {
        for _ in 0..timeout_ms / 5 {
            if UnixSeqpacketConn::connect(socket_path).is_ok() {
                return;
            }
            tokio::time::sleep(std::time::Duration::from_millis(5)).await;
        }
        panic!(
            "Failed to connect to Unix socket at {} after waiting",
            socket_path
        );
    }
}