datacake-cluster 0.1.0

Eventually consistent state replication as a library (consensus, RPC and conflict resolution) for building your own eventually consistent databases.
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

mod distributor;
mod poller;

use std::borrow::Cow;
use std::net::SocketAddr;

pub const MAX_CONCURRENT_REQUESTS: usize = 10;

#[derive(Debug, Default, Clone)]
/// Represents a set of changes to the membership of the cluster.
pub(crate) struct MembershipChanges {
    /// A set of nodes which have joined the cluster.
    pub(crate) joined: Vec<(Cow<'static, str>, SocketAddr)>,
    /// A set of nodes which have left the cluster.
    pub(crate) left: Vec<Cow<'static, str>>,
}

pub(crate) use distributor::{
    start_task_distributor_service,
    Mutation,
    TaskDistributor,
    TaskServiceContext,
};
pub(crate) use poller::{
    start_replication_cycle,
    ReplicationCycleContext,
    ReplicationHandle,
};