Lib.rs

集群模式

在 Rust 中创建和管理分布式应用程序。

秉承口号 - 插入 crate，它会自动处理。

用法

#[tokio::main]
async fn main() {
    let result = KubernetesDiscoverService::init("demo".to_string(), "default".to_string())
        .await;
    if let Ok(k8s) = result {
        let cluster = Arc::new(Cluster::default());
        let client = DiscoveryClient::new(k8s);
        tokio::spawn(start_cluster(cluster, client));
    }
}

Cluster 结构体提供了一组函数，例如 async fn primaries(&self) -> Option<HashSet<RestClusterNode>> 或 async fn is_active(&self) -> bool 与集群通信。