mosaik 0.3.8

A Rust runtime for building self-organizing, leaderless distributed systems.
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

#![allow(unused)]

mod fut;
mod jwt;
mod ticket;
mod time;
mod tracing;

use futures::future::try_join_all;
pub use {fut::*, jwt::*, ticket::*, time::*};

pub async fn discover_all(
	networks: impl IntoIterator<Item = &mosaik::Network>,
) -> anyhow::Result<()> {
	let networks = networks.into_iter().collect::<Vec<_>>();
	try_join_all(networks.iter().enumerate().flat_map(|(i, net_i)| {
		networks
			.iter()
			.enumerate()
			.filter(move |(j, _)| i != *j)
			.map(move |(_, net_j)| {
				timeout_s(5, net_i.discovery().sync_with(net_j.local().addr()))
			})
	}))
	.await?;
	Ok(())
}