Struct DirectCommunicator 

pub struct DirectCommunicator<I: Invocation> { /* private fields */ }

Trait Implementations

impl<I: Invocation> Clone for DirectCommunicator<I>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<I: Invocation + 'static> Communicator for DirectCommunicator<I>

type Node = <<I as Invocation>::State as State>::Node

NodeInfo

type RoundNum = <I as Invocation>::RoundNum

The round number type.

type CoordNum = <I as Invocation>::CoordNum

The coordination number type.

type LogEntry = <<I as Invocation>::State as State>::LogEntry

The log entry type.

type Error = DirectCommunicatorError

The communication error type.

type SendPrepare = Pin<Box<dyn Future<Output = Result<Vote<<DirectCommunicator<I> as Communicator>::RoundNum, <DirectCommunicator<I> as Communicator>::CoordNum, <DirectCommunicator<I> as Communicator>::LogEntry, <DirectCommunicator<I> as Communicator>::Abstain>, <DirectCommunicator<I> as Communicator>::Error>> + Send>>

Type of future returned from send_prepare.

type Abstain = <I as Invocation>::Abstain

Information sent along with abstentions.

type SendProposal = Pin<Box<dyn Future<Output = Result<Acceptance<<DirectCommunicator<I> as Communicator>::CoordNum, <DirectCommunicator<I> as Communicator>::LogEntry, <DirectCommunicator<I> as Communicator>::Yea, <DirectCommunicator<I> as Communicator>::Nay>, <DirectCommunicator<I> as Communicator>::Error>> + Send>>

Type of future returned from send_proposal.

type Yea = <I as Invocation>::Yea

Information sent along with yea votes.

type Nay = <I as Invocation>::Nay

Information sent along with nay votes.

type SendCommit = Pin<Box<dyn Future<Output = Result<Committed, <DirectCommunicator<I> as Communicator>::Error>> + Send>>

Type of future returned from send_commit.

type SendCommitById = Pin<Box<dyn Future<Output = Result<Committed, <DirectCommunicator<I> as Communicator>::Error>> + Send>>

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.

impl<I: Debug + Invocation> Debug for DirectCommunicator<I>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.