memberlist 0.8.0

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

use super::*;

macro_rules! set_ack_handler {
  ($rt: ident) => {
    paste::paste! {
      #[test]
      fn [< test_ $rt:snake _set_ack_handler >]() {
        [< $rt:snake _run >](async move {
          set_ack_handler::<[< $rt:camel Runtime >]>().await;
        });
      }
    }
  };
}

#[cfg(feature = "tokio")]
mod tokio {
  use agnostic::tokio::TokioRuntime;

  use super::*;

  set_ack_handler!(tokio);
}

#[cfg(feature = "smol")]
mod smol {

  use super::*;

  set_ack_handler!(smol);
}