memberlist 0.8.2

A highly customable, adaptable, async runtime agnostic gossip protocol which helps manage cluster membership and member failure detection.
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
34
35
36
37
38
39
40
41
42
43
44
45

#[cfg(feature = "smol")]
use agnostic::smol::SmolRuntime;

use std::future::Future;

use memberlist_core::tests::{run as run_unit_test, state::*};
pub use memberlist_core::*;

#[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 agnostic::RuntimeLite;
  run_unit_test(SmolRuntime::block_on, fut);
}
#[path = "main/net.rs"]
#[cfg(feature = "memberlist-net")]
mod net;

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

#[path = "main/set_probe_channels.rs"]
mod set_probe_channels;

#[path = "main/set_ack_handler.rs"]
mod set_ack_handler;

#[path = "main/invoke_ack_handler.rs"]
mod invoke_ack_handler;

#[path = "main/invoke_ack_handler_channel_ack.rs"]
mod invoke_ack_handler_channel_ack;

#[path = "main/invoke_ack_handler_channel_nack.rs"]
mod invoke_ack_handler_channel_nack;