chaiwala 0.1.5

Service Layer for Kucoin Arbitrage, along with Continuous Deployment
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

use kucoin_arbitrage::monitor::counter;
use std::sync::Arc;
use std::time::Duration;
use tokio::sync::broadcast::Sender;
use tokio::sync::Mutex;
use tokio::time::sleep;

/// log counters
async fn log_mps(
    tx_message: Sender<String>,
    counters: Vec<Arc<Mutex<counter::Counter>>>,
    interval: u64,
) -> Result<(), kucoin_api::failure::Error> {
    let title = String::from("Broadcast channel data rate");
    log::info!("{title}");
    tx_message.send(title)?;
    for counter in counters.iter() {
        let (name, count) = {
            let p = counter.lock().await;
            (p.name, p.data_count)
        };
        let message = format!("{name:10}: {count:5} points ({:5}mps)", count / interval);
        log::info!("{message}");
        tx_message.send(message)?;
        // clear the data
        counter::reset(counter.clone()).await;
    }
    Ok(())
}
/// log counters as a task
pub async fn task_log_mps(
    tx_message: Sender<String>,
    counters: Vec<Arc<Mutex<counter::Counter>>>,
    interval: u64,
) -> Result<(), kucoin_api::failure::Error> {
    let monitor_delay = Duration::from_secs(interval);
    loop {
        sleep(monitor_delay).await;
        log_mps(tx_message.clone(), counters.clone(), interval)
            .await
            .expect("report status error");
    }
}