memberlist-net 0.8.3

memberlist's transport layer based on TCP and UDP.
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
46
47
48
49

#[cfg(all(feature = "encryption", feature = "compression"))]
use super::*;

#[cfg(all(feature = "encryption", feature = "compression"))]
pub async fn join<S1, S2, R>(
  s1: S1::Options,
  s2: S2::Options,
  kind: AddressKind,
) -> Result<(), AnyError>
where
  S1: StreamLayer<Runtime = R>,
  S2: StreamLayer<Runtime = R>,
  R: Runtime,
{
  use memberlist_core::transport::{tests::join as join_in, Lpe};
  use nodecraft::resolver::socket_addr::SocketAddrResolver;

  use crate::{NetTransport, NetTransportOptions};
  use nodecraft::CheapClone;

  let name = format!("{kind}_join");
  let label = Label::try_from(&name)?;
  let pk = SecretKey::from([1; 32]);

  let mut opts1 = NetTransportOptions::<_, _, S1>::with_stream_layer_options("node 1".into(), s1)
    .with_primary_key(Some(pk))
    .with_encryption_algo(EncryptionAlgo::PKCS7)
    .with_gossip_verify_outgoing(true)
    .with_compressor(Some(Compressor::default()))
    .with_label(label.cheap_clone());
  opts1.add_bind_address(kind.next(0));

  let mut opts2 = NetTransportOptions::<_, _, S2>::with_stream_layer_options("node 2".into(), s2)
    .with_primary_key(Some(pk))
    .with_encryption_algo(EncryptionAlgo::PKCS7)
    .with_gossip_verify_outgoing(true)
    .with_compressor(Some(Compressor::default()))
    .with_label(label);
  opts2.add_bind_address(kind.next(0));

  join_in::<
    _,
    NetTransport<_, SocketAddrResolver<R>, _, _>,
    NetTransport<_, SocketAddrResolver<R>, _, _>,
    _,
  >(opts1, opts2)
  .await?;
  Ok(())
}