serf 0.5.1

A decentralized solution for service discovery and orchestration that is lightweight, highly available, and fault tolerant.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use core::future::Future;
use serf_core::tests::run as run_unit_test;

#[cfg(feature = "net")]
#[path = "./main/net.rs"]
mod net;

#[cfg(feature = "tokio")]
fn tokio_run(fut: impl Future<Output = ()>) {
  let runtime = ::tokio::runtime::Builder::new_multi_thread()
    .worker_threads(32)
    .enable_all()
    .build()
    .unwrap();
  run_unit_test(|fut| runtime.block_on(fut), fut)
}

#[cfg(feature = "smol")]
fn smol_run(fut: impl Future<Output = ()>) {
  use serf::agnostic::{RuntimeLite, smol::SmolRuntime};
  run_unit_test(SmolRuntime::block_on, fut);
}