Struct DcpMessage 

pub struct DcpMessage {
    pub message_type: MessageType,
    pub flags: u8,
    pub payload: Vec<u8>,
}

DCP message representing a complete binary message with envelope and payload

Fields

message_type: MessageType

Message type

flags: u8

Flags (streaming, compressed, signed)

payload: Vec<u8>

Payload data

Implementations

impl DcpMessage

pub fn new(message_type: MessageType, flags: u8, payload: Vec<u8>) -> Self

Create a new DCP message

pub fn tool(payload: Vec<u8>) -> Self

Create a tool invocation message

pub fn resource(payload: Vec<u8>) -> Self

Create a resource request message

pub fn prompt(payload: Vec<u8>) -> Self

Create a prompt message

pub fn response(payload: Vec<u8>) -> Self

Create a response message

pub fn error(payload: Vec<u8>) -> Self

Create an error message

pub fn stream(payload: Vec<u8>) -> Self

Create a streaming message

pub fn is_streaming(&self) -> bool

Check if this is a streaming message

pub fn is_compressed(&self) -> bool

Check if this message is compressed

pub fn is_signed(&self) -> bool

Check if this message is signed

pub fn with_streaming(self) -> Self

Set the streaming flag

pub fn with_compressed(self) -> Self

Set the compressed flag

pub fn with_signed(self) -> Self

Set the signed flag

pub fn encode(&self) -> Vec<u8>

Encode the message to bytes (envelope + payload)

pub fn decode(bytes: &[u8]) -> Result<Self>

Decode a message from bytes

Trait Implementations

impl Clone for DcpMessage

fn clone(&self) -> DcpMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DcpMessage

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

Formats the value using the given formatter.