tatara-engine 0.2.256

Drivers, nix eval, cluster logic, P2P, and scheduling engine for tatara
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use std::time::Duration;
use tracing::debug;

/// Heartbeat stub for Phase 1 (embedded mode — no remote server).
/// Phase 2 will implement gRPC bidirectional heartbeat.
pub struct Heartbeat;

impl Heartbeat {
    pub fn new() -> Self {
        Self
    }

    pub async fn run(&self) -> anyhow::Result<()> {
        debug!("Heartbeat running in embedded mode (no-op)");
        // In embedded mode, server and client share process — no heartbeat needed.
        // Phase 2 will connect to a remote server via gRPC.
        loop {
            tokio::time::sleep(Duration::from_secs(60)).await;
        }
    }
}