cruster 0.0.27

A Rust framework for building distributed, stateful entity systems with durable workflows
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

use async_trait::async_trait;

use crate::error::ClusterError;
use crate::runner_health::RunnerHealth;
use crate::types::RunnerAddress;

/// No-op runner health check that always reports alive.
pub struct NoopRunnerHealth;

#[async_trait]
impl RunnerHealth for NoopRunnerHealth {
    async fn is_alive(&self, _address: &RunnerAddress) -> Result<bool, ClusterError> {
        Ok(true)
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    #[tokio::test]
    async fn always_alive() {
        let health = NoopRunnerHealth;
        let addr = RunnerAddress::new("127.0.0.1", 9000);
        assert!(health.is_alive(&addr).await.unwrap());
    }
}