mosaik 0.3.17

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
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

#![allow(clippy::doc_markdown)]

//! # Primitives
//!
//! Shared types and traits used across all mosaik subsystems.
//!
//! Key types:
//!
//! - [`Digest`] — a blake3 hash used as the basis for all identifiers
//!   ([`NetworkId`](crate::NetworkId), [`StreamId`](crate::StreamId),
//!   [`GroupId`](crate::GroupId), [`StoreId`](crate::StoreId)).
//! - [`UniqueId`] — a compile-time-friendly identifier derived from a
//!   human-readable string via the [`unique_id!`](crate::unique_id) (alias
//!   [`id!`](crate::id)) macro.
//! - [`Tag`] — a short label attached to a node's discovery entry for
//!   role-based filtering.
//! - [`Datum`] — the marker trait for any type that can be sent over streams or
//!   stored in collections (`Serialize + DeserializeOwned + Clone + Send + Sync
//!   + 'static`).
//! - [`Ticket`] / [`TicketValidator`] — opaque credentials and their
//!   validators, used to gate access to streams and collections (e.g. TEE
//!   attestation quotes).

mod channel;
mod chex;
mod fmt;
mod fut;
mod id;
mod iter;
mod queue;

pub mod datum;
pub mod encoding;

/// Public API re-exported byte types.
pub use bytes::{self, Bytes, BytesMut};
/// Internal primitives.
pub(crate) use {
	channel::UnboundedChannel,
	chex::const_hex,
	encoding::{EncodeError, deserialize, serialize, serialize_to_writer},
	fut::BoxPinFut,
	fut::InternalFutureExt,
	iter::IntoIterOrSingle,
	queue::AsyncWorkQueue,
};
/// Public API re-exported primitives.
pub use {
	datum::{Datum, Encoded},
	fmt::*,
	id::{Digest, Tag, UniqueId},
};

/// Used internally as a sentinel type for generic parameters.
#[doc(hidden)]
pub enum Variant<const U: usize = 0> {}

use {backoff::backoff::Backoff, std::sync::Arc};

pub type BackoffFactory = Arc<
	dyn Fn() -> Box<dyn Backoff + Send + Sync + 'static> + Send + Sync + 'static,
>;

/// Used internally as a sealed trait to prevent external implementations of
/// certain traits.
#[doc(hidden)]
pub(crate) mod sealed {
	pub trait Sealed {}
}