quick_stream 0.1.3

Quick Stream is a Rust-based solution designed to efficiently handle data upsert operations with a focus on performance and scalability. Utilizing asynchronous programming and a dynamic sender-receiver model, Quick Stream aims to streamline the process of synchronizing large datasets with minimal overhead.
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
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52

#[cfg(all(unix, feature = "unix-signals"))]
use tokio_util::sync::CancellationToken;

#[cfg(all(unix, feature = "unix-signals"))]
pub(crate) async fn shutdown_unix(cancellation_token: CancellationToken) {
    use log::{error, info};
    use signal_hook::iterator::Signals;

    let mut signals = match Signals::new(&[signal_hook::consts::SIGINT, signal_hook::consts::SIGTERM, signal_hook::consts::SIGQUIT, signal_hook::consts::SIGKILL, signal_hook::consts::SIGSTOP]) {
        Ok(signals) => signals,
        Err(e) => {
            error!("Failed to create signal handler: {}", e);
            return;
        }
    };

    for signal in signals.forever() {
        match signal {
            signal_hook::consts::SIGINT => {
                // Handle SIGINT signal
                error!("Received SIGINT signal, shutting down");
                cancellation_token.cancel();
            }
            signal_hook::consts::SIGTERM => {
                // Handle SIGTERM signal
                error!("Received SIGTERM signal, shutting down");
                cancellation_token.cancel();
            }
            signal_hook::consts::SIGQUIT => {
                // Handle SIGQUIT signal
                error!("Received SIGQUIT signal, shutting down");
                cancellation_token.cancel();
            }
            signal_hook::consts::SIGKILL => {
                // Handle SIGKILL signal
                error!("Received SIGKILL signal, shutting down");
                cancellation_token.cancel();
            }
            signal_hook::consts::SIGSTOP => {
                // Handle SIGSTOP signal
                error!("Received SIGSTOP signal, shutting down");
                cancellation_token.cancel();
            }
            other => {
                // Handle other signals
                unreachable!("Other Signals Are Not Supported, Received Signal code: {}", other)
            }
        }
    }

    info!("Server Intiating Graceful Shutdown")
}