Struct DirectMessage

pub struct DirectMessage<ID, OP, DGM>
where
    DGM: AckedGroupMembership<ID, OP>,
{
    pub recipient: ID,
    pub content: DirectMessageContent<ID, OP, DGM>,
}

Direct message that should be sent to a single member.

The direct message must be distributed to the other group members through Authenticated Causal Broadcast, calling the process function on the recipient when they are delivered.

If direct messages are sent along with a control message, we assume that the direct message for the appropriate recipient is delivered in the same call to process. Our algorithm never sends a direct message without an associated broadcast control message.

Fields

recipient: ID

content: DirectMessageContent<ID, OP, DGM>

Implementations

impl<ID, OP, DGM> DirectMessage<ID, OP, DGM>

where DGM: AckedGroupMembership<ID, OP>,

pub fn message_type(&self) -> DirectMessageType

Trait Implementations

impl<ID: Clone, OP: Clone, DGM> Clone for DirectMessage<ID, OP, DGM>

where DGM: AckedGroupMembership<ID, OP> + Clone,

fn clone(&self) -> DirectMessage<ID, OP, DGM>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<ID: Debug, OP: Debug, DGM> Debug for DirectMessage<ID, OP, DGM>

where DGM: AckedGroupMembership<ID, OP> + Debug,

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

Formats the value using the given formatter.

impl<'de, ID, OP, DGM> Deserialize<'de> for DirectMessage<ID, OP, DGM>

where DGM: AckedGroupMembership<ID, OP> + Deserialize<'de>, ID: Deserialize<'de>, OP: Deserialize<'de>,

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<ID, OP, DGM> Serialize for DirectMessage<ID, OP, DGM>

where DGM: AckedGroupMembership<ID, OP> + Serialize, ID: Serialize, OP: Serialize,

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

where __S: Serializer,

Serialize this value into the given Serde serializer.