Struct Message 

pub struct Message {
    pub msg_type: MessageType,
    pub session_id: Option<String>,
    pub payload: Option<MessagePayload>,
    pub timestamp: u64,
}

Protocol message envelope

Fields

msg_type: MessageType

Message type

session_id: Option<String>

Session ID (empty for HELLO)

payload: Option<MessagePayload>

Message payload

timestamp: u64

Timestamp (Unix millis)

Implementations

impl Message

pub fn hello(capabilities: Capabilities) -> Self

Create a HELLO message

pub fn accept(session_id: &str, capabilities: Capabilities) -> Self

Create an ACCEPT message

pub fn reject(code: RejectionCode, message: &str) -> Self

Create a REJECT message

pub fn data(session_id: &str, algorithm: Algorithm, content: String) -> Self

Create a DATA message

pub fn data_with_security( session_id: &str, algorithm: Algorithm, content: String, security: SecurityStatus, ) -> Self

Create a DATA message with security status

pub fn ping(session_id: &str) -> Self

Create a PING message

pub fn pong(session_id: &str) -> Self

Create a PONG message

pub fn close(session_id: &str) -> Self

Create a CLOSE message

pub fn to_json(&self) -> Result<String, Error>

Serialize to JSON

pub fn to_json_compact(&self) -> Result<String, Error>

Serialize to JSON (compact)

pub fn from_json(json: &str) -> Result<Self, Error>

Deserialize from JSON

pub fn get_capabilities(&self) -> Option<&Capabilities>

Get capabilities from HELLO/ACCEPT payload

pub fn get_data(&self) -> Option<&DataPayload>

Get data payload

pub fn get_rejection(&self) -> Option<&RejectionInfo>

Get rejection info

Trait Implementations

impl Clone for Message

fn clone(&self) -> Message

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Message

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Message

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Message

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

where __S: Serializer,

Serialize this value into the given Serde serializer.