Struct ForwardSecureOrderer 

pub struct ForwardSecureOrderer<DGM> { /* private fields */ }

Simplified orderer for testing the “message encryption” group APIs.

NOTE: This orderer does not fullfill the full specification for correct ordering. It’s assuming that peers process all messages after each member has published max. one control or application message. On top it’s very inefficient, as every published message points at every previously published messages from all peers.

This is sufficient for the current testing setup but for anything “production ready” and more robust for all concurrency scenarios, a more sophisticated solution will be required.

Implementations

impl<DGM> ForwardSecureOrderer<DGM>

where DGM: Clone + AckedGroupMembership<MemberId, MessageId>,

pub fn init(my_id: MemberId) -> ForwardSecureOrdererState<DGM>

Trait Implementations

impl<DGM: Clone> Clone for ForwardSecureOrderer<DGM>

fn clone(&self) -> ForwardSecureOrderer<DGM>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<DGM: Debug> Debug for ForwardSecureOrderer<DGM>

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

Formats the value using the given formatter.

impl<DGM> ForwardSecureOrdering<usize, MessageId, DGM> for ForwardSecureOrderer<DGM>

where DGM: Debug + Clone + AckedGroupMembership<MemberId, MessageId> + Serialize + for<'a> Deserialize<'a>,

type State = ForwardSecureOrdererState<DGM>

type Error = ForwardSecureOrdererError

type Message = TestMessage<DGM>

fn next_control_message( y: Self::State, control_message: &ControlMessage<MemberId, MessageId>, direct_messages: &[DirectMessage<MemberId, MessageId, DGM>], ) -> Result<(Self::State, Self::Message), Self::Error>

fn next_application_message( y: Self::State, generation: Generation, ciphertext: Vec<u8>, ) -> Result<(Self::State, Self::Message), Self::Error>

fn queue( y: Self::State, message: &Self::Message, ) -> Result<Self::State, Self::Error>

fn set_welcome( y: Self::State, message: &Self::Message, ) -> Result<Self::State, Self::Error>

fn next_ready_message( y: Self::State, ) -> Result<(Self::State, Option<Self::Message>), Self::Error>