Struct paxakos::leases::master::communicator::LeaseRecordingCommunicator

pub struct LeaseRecordingCommunicator<C: Communicator> { /* fields omitted */ }

Implementations

impl<C: Communicator> LeaseRecordingCommunicator<C>

pub fn from(communicator: C) -> Self

pub fn subscribe(&mut self) -> Subscription<NodeIdOf<C>>

Trait Implementations

impl<C, Y> Communicator for LeaseRecordingCommunicator<C> where
    C: Communicator<Yea = Y>,
    Y: ToLeaseDuration + Debug + Send + Sync + 'static, 

type Node = NodeOf<C>

NodeInfo

type RoundNum = RoundNumOf<C>

The round number type.

type CoordNum = CoordNumOf<C>

The coordination number type.

type LogEntry = LogEntryOf<C>

The log entry type.

type Error = ErrorOf<C>

The communication error type.

type SendPrepare = <C as Communicator>::SendPrepare

Type of future returned from send_prepare.

type Abstain = AbstainOf<C>

Information sent along with abstentions.

type SendProposal = LocalBoxFuture<'static, Result<AcceptanceFor<Self>, Self::Error>>

Type of future returned from send_proposal.

type Yea = YeaOf<C>

Information sent along with yea votes.

type Nay = NayOf<C>

Information sent along with nay votes.

type SendCommit = <C as Communicator>::SendCommit

Type of future returned from send_commit.

type SendCommitById = <C as Communicator>::SendCommitById

Type of future returned from send_commit_by_id.

fn send_prepare<'a>(
    &mut self,
    receivers: &'a [Self::Node],
    round_num: Self::RoundNum,
    coord_num: Self::CoordNum
) -> Vec<(&'a Self::Node, Self::SendPrepare)>

Send a prepare message to all receivers.

fn send_proposal<'a>(
    &mut self,
    receivers: &'a [Self::Node],
    round_num: Self::RoundNum,
    coord_num: Self::CoordNum,
    log_entry: Arc<Self::LogEntry>
) -> Vec<(&'a Self::Node, Self::SendProposal)>

Send a proposal message to all receivers.

fn send_commit<'a>(
    &mut self,
    receivers: &'a [Self::Node],
    round_num: Self::RoundNum,
    coord_num: Self::CoordNum,
    log_entry: Arc<Self::LogEntry>
) -> Vec<(&'a Self::Node, Self::SendCommit)>

Send a commit message to all receivers.

fn send_commit_by_id<'a>(
    &mut self,
    receivers: &'a [Self::Node],
    round_num: Self::RoundNum,
    coord_num: Self::CoordNum,
    log_entry_id: <Self::LogEntry as LogEntry>::Id
) -> Vec<(&'a Self::Node, Self::SendCommitById)>

Send a commit-by-id message to all receivers.