hydracache 0.50.0

User-facing HydraCache runtime crate.
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

use std::sync::Arc;

use hydracache::{
    ClusterGeneration, ClusterHealthReason, ClusterHealthState, HydraCache, InMemoryCluster,
};

#[tokio::test]
async fn component_lifecycle_feeds_staging_health() {
    let cluster = Arc::new(InMemoryCluster::new("orders"));
    let member = HydraCache::member()
        .shared_cluster(cluster)
        .node_id("member-a")
        .generation(ClusterGeneration::new(1))
        .start()
        .await
        .unwrap();

    assert_eq!(
        member.cluster_staging_health().unwrap().state,
        ClusterHealthState::Healthy
    );

    member.leave_cluster().await.unwrap();
    let health = member
        .cluster_staging_health()
        .expect("cluster runtime stays diagnosable after leave");

    assert!(matches!(
        health.state,
        ClusterHealthState::NotReady { ref reasons }
            if reasons.contains(&ClusterHealthReason::LifecycleNotRunning)
    ));
}