1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

//! Emits a heartbeat internal metric.
use std::time::{Duration, Instant};

use tokio::time::interval;

use crate::internal_events::Heartbeat;

/// Emits Heartbeat event every second.
pub async fn heartbeat() {
    let since = Instant::now();
    let mut interval = interval(Duration::from_secs(1));
    loop {
        interval.tick().await;
        emit!(Heartbeat { since });
    }
}