ora 0.12.7

Part of the Ora scheduler framework.
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

use std::time::Duration;

use flume::Sender;

use crate::proto::executors::v1::{ExecutorHeartbeat, executor_message::ExecutorMessageKind};

#[tracing::instrument(skip_all)]
pub(super) async fn heartbeat_loop(
    max_heartbeat_interval: Duration,
    server: Sender<ExecutorMessageKind>,
) {
    let target_heartbeat_interval = max_heartbeat_interval / 2;

    tracing::debug!(
        ?max_heartbeat_interval,
        ?target_heartbeat_interval,
        "sending heartbeats"
    );

    loop {
        tracing::debug!("sending heartbeat");
        if server
            .send(ExecutorMessageKind::Heartbeat(ExecutorHeartbeat {}))
            .is_err()
        {
            break;
        }

        tokio::time::sleep(target_heartbeat_interval).await;
    }
}