Struct Message 

pub struct Message<T> {
    pub message_type: MessageType,
    pub correlation_id: Option<String>,
    pub payload: T,
}

Generic WebSocket message container for requests, responses, and events.

Example (Request)

{
  "type": "request",
  "correlation_id": "abc123",
  "payload": {
    "action": "createsession",
    "name": "My Session"
  }
}

Example (Response)

{
  "type": "response",
  "correlation_id": "abc123",
  "payload": {
    "action": "sessioncreated",
    "session_id": "sess_xyz",
    "name": "My Session"
  }
}

Example (Event)

{
  "type": "event",
  "payload": {
    "event": "nodestatechanged",
    "session_id": "sess_xyz",
    "node_id": "gain1",
    "state": { "Running": null }
  }
}

Fields

message_type: MessageType

The type of message (Request, Response, or Event)

correlation_id: Option<String>

Optional correlation ID for matching requests with responses. Present in Request and Response messages, absent in Event messages.

payload: T

The message payload (RequestPayload, ResponsePayload, or EventPayload)

Trait Implementations

impl<T: Clone> Clone for Message<T>

fn clone(&self) -> Message<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for Message<T>

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

Formats the value using the given formatter.

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

where T: Deserialize<'de>,

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<T> Serialize for Message<T>

where T: Serialize,

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

where __S: Serializer,

Serialize this value into the given Serde serializer.