Struct MessageId 

pub struct MessageId {
    pub sender: MemberId,
    pub seq: usize,
}

Simple message id for tests with monotonically incrementing sequence numbers per peer.

This contains the sender again as we need unique message ids and just using the sequence number would not be sufficient.

Fields

sender: MemberId

seq: usize

Implementations

impl MessageId

pub fn new(my_id: MemberId) -> Self

pub fn inc(&self) -> Self

Trait Implementations

impl Clone for MessageId

fn clone(&self) -> MessageId

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MessageId

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for MessageId

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for MessageId

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

Formats the value using the given formatter.

impl<DGM> ForwardSecureGroupMessage<usize, MessageId, DGM> for TestMessage<DGM>

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

fn id(&self) -> MessageId

Unique identifier of this message.

fn sender(&self) -> MemberId

Unique identifier of the sender of this message.

fn content(&self) -> ForwardSecureMessageContent<MemberId, MessageId>

Returns data required to manage group encryption and receive decrypted application messages.

fn direct_messages(&self) -> Vec<DirectMessage<MemberId, MessageId, DGM>>

Returns optional list of direct messages.

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>

impl<DGM> GroupMessage<usize, MessageId, DGM> for TestMessage<DGM>

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

fn id(&self) -> MessageId

Unique identifier of this message.

fn sender(&self) -> MemberId

Unique identifier of the sender of this message.

fn content(&self) -> GroupMessageContent<MemberId>

Returns content of either a control- or application message.

fn direct_messages(&self) -> Vec<DirectMessage<MemberId, MessageId, DGM>>

Returns optional list of direct messages.

impl Hash for MessageId

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl<DGM> Ordering<usize, MessageId, DGM> for MessageOrderer<DGM>

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

type State = MessageOrdererState<DGM>

type Error = MessageOrdererError

type Message = TestMessage<DGM>

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

fn next_application_message( y: Self::State, group_secret_id: GroupSecretId, nonce: XAeadNonce, 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>

impl PartialEq for MessageId

fn eq(&self, other: &MessageId) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for MessageId

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Copy for MessageId

impl Eq for MessageId

impl OperationId for MessageId

impl StructuralPartialEq for MessageId