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
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117

use crate::{NetTransport, NetTransportOptions};

use super::*;
use memberlist_core::{
  transport::{Lpe, MaybeResolvedAddress},
  Memberlist, Options,
};
use nodecraft::{resolver::socket_addr::SocketAddrResolver, CheapClone, Node};

pub async fn gossip_mismatched_keys<S, R>(
  s1: S::Options,
  s2: S::Options,
  kind: AddressKind,
) -> Result<(), AnyError>
where
  S: StreamLayer<Runtime = R>,
  R: Runtime,
{
  // Create two agents with different gossip keys
  let pk1 = SecretKey::Aes192(*b"4W6DGn2VQVqDEceOdmuRTQ==");

  let name1 = "gossip_mismatched_keys1";
  let mut opts =
    NetTransportOptions::<_, _, S>::with_stream_layer_options(SmolStr::from(name1), s1)
      .with_primary_key(Some(pk1))
      .with_encryption_algo(EncryptionAlgo::PKCS7)
      .with_gossip_verify_outgoing(true);
  opts.add_bind_address(kind.next(0));
  let m1 = Memberlist::<NetTransport<_, SocketAddrResolver<R>, S, _>, _>::new(
    opts,
    Options::default(),
  )
  .await?;
  let m1_addr = m1.advertise_address();

  let name2 = "gossip_mismatched_keys2";
  let pk2 = SecretKey::Aes192(*b"XhX/w702/JKKK7/7OtM9Ww==");
  let mut opts =
    NetTransportOptions::<_, _, S>::with_stream_layer_options(SmolStr::from(name2), s2)
      .with_primary_key(Some(pk2))
      .with_encryption_algo(EncryptionAlgo::PKCS7)
      .with_gossip_verify_outgoing(true);
  opts.add_bind_address(kind.next(0));
  let m2 = Memberlist::<NetTransport<_, SocketAddrResolver<R>, _, _>, _>::new(
    opts,
    Options::default(),
  )
  .await?;

  // Make sure we get this error on the joining side
  m2.join_many(
    [Node::new(
      name1.into(),
      MaybeResolvedAddress::resolved(*m1_addr),
    )]
    .into_iter(),
  )
  .await
  .map(|_| {})
  .map_err(Into::into)
}

pub async fn gossip_mismatched_keys_with_label<S, R>(
  s1: S::Options,
  s2: S::Options,
  kind: AddressKind,
) -> Result<(), AnyError>
where
  S: StreamLayer<Runtime = R>,
  R: Runtime,
{
  // Create two agents with different gossip keys
  let pk1 = SecretKey::Aes192(*b"4W6DGn2VQVqDEceOdmuRTQ==");

  let name1 = "gossip_mismatched_keys1";
  let label = Label::try_from("gossip_mismatched_keys")?;
  let mut opts =
    NetTransportOptions::<_, _, S>::with_stream_layer_options(SmolStr::from(name1), s1)
      .with_primary_key(Some(pk1))
      .with_encryption_algo(EncryptionAlgo::PKCS7)
      .with_gossip_verify_outgoing(true)
      .with_label(label.cheap_clone());
  opts.add_bind_address(kind.next(0));
  let m1 = Memberlist::<NetTransport<_, SocketAddrResolver<R>, _, _>, _>::new(
    opts,
    Options::default(),
  )
  .await?;
  let m1_addr = m1.advertise_address();

  let name2 = "gossip_mismatched_keys2";
  let pk2 = SecretKey::Aes192(*b"XhX/w702/JKKK7/7OtM9Ww==");
  let mut opts =
    NetTransportOptions::<_, _, S>::with_stream_layer_options(SmolStr::from(name2), s2)
      .with_primary_key(Some(pk2))
      .with_encryption_algo(EncryptionAlgo::PKCS7)
      .with_gossip_verify_outgoing(true)
      .with_label(label);
  opts.add_bind_address(kind.next(0));
  let m2 = Memberlist::<NetTransport<_, SocketAddrResolver<R>, _, _>, _>::new(
    opts,
    Options::default(),
  )
  .await?;

  // Make sure we get this error on the joining side
  m2.join_many(
    [Node::new(
      name1.into(),
      MaybeResolvedAddress::resolved(*m1_addr),
    )]
    .into_iter(),
  )
  .await
  .map(|_| {})
  .map_err(Into::into)
}