Struct CoreCompartmentalizedPaxos 

pub struct CoreCompartmentalizedPaxos<'a> {
    pub proposers: Cluster<'a, Proposer>,
    pub proxy_leaders: Cluster<'a, ProxyLeader>,
    pub acceptors: Cluster<'a, Acceptor>,
    pub config: CompartmentalizedPaxosConfig,
}

Fields

proposers: Cluster<'a, Proposer>

proxy_leaders: Cluster<'a, ProxyLeader>

acceptors: Cluster<'a, Acceptor>

config: CompartmentalizedPaxosConfig

Trait Implementations

impl<'a> PaxosLike<'a> for CoreCompartmentalizedPaxos<'a>

type PaxosIn = Proposer

The nodes that receive inputs in Paxos. Usually the proposers.

type PaxosLog = Acceptor

The nodes that store logs in Paxos. Usually the acceptors.

type PaxosOut = ProxyLeader

The nodes that output the results of Paxos. Proposers in Paxos, Proxy leaders in Compartmentalized Paxos.

type Ballot = Ballot

fn payload_recipients(&self) -> &Cluster<'a, Self::PaxosIn>

fn log_stores(&self) -> &Cluster<'a, Self::PaxosLog>

fn get_recipient_from_ballot<L: Location<'a>>( ballot: Optional<Self::Ballot, L, Unbounded>, ) -> Optional<MemberId<Self::PaxosIn>, L, Unbounded>

fn build<P: PaxosPayload>( self, with_ballot: impl FnOnce(Stream<Ballot, Cluster<'a, Self::PaxosIn>, Unbounded>) -> Stream<P, Cluster<'a, Self::PaxosIn>, Unbounded>, a_checkpoint: Optional<usize, Cluster<'a, Acceptor>, Unbounded>, nondet_leader: NonDet, nondet_commit: NonDet, ) -> Stream<(usize, Option<P>), Cluster<'a, Self::PaxosOut>, Unbounded, NoOrder>

Non-Determinism

fn with_client<C: 'a, P: PaxosPayload>( self, clients: &Cluster<'a, C>, payloads: Stream<P, Cluster<'a, C>, Unbounded>, checkpoints: Optional<usize, Cluster<'a, Self::PaxosLog>, Unbounded>, nondet_commit: NonDet, nondet_order: NonDet, ) -> Stream<(usize, Option<P>), Cluster<'a, Self::PaxosOut>, Unbounded, NoOrder>

Non-Determinism