Enum Message 

pub enum Message<'a> {
    Delivered(Delivery<'a>),
    Request {
        destination: DestinationHash,
        link_id: LinkId,
        request_id: RequestId,
        requester: Option<IdentityHash>,
        path_hash: RequestPathHash,
        requested_at: InstantMillis,
        rtt: RttMillis,
        data: &'a [u8],
    },
    Response {
        link_id: LinkId,
        request_id: RequestId,
        data: &'a [u8],
    },
    ResponseSegment {
        link_id: LinkId,
        request_id: RequestId,
        segment_index: u64,
        total_segments: u64,
        data: &'a [u8],
    },
    Resource {
        link_id: LinkId,
        hash: ResourceHash,
        metadata: Option<&'a [u8]>,
        data: &'a [u8],
    },
    ResourceNeedsDecompression {
        link_id: LinkId,
        hash: ResourceHash,
        stream: &'a [u8],
        uncompressed_data_bytes: u64,
    },
    ResourceSegment {
        link_id: LinkId,
        original_hash: ResourceHash,
        segment_index: u64,
        total_segments: u64,
        metadata: Option<&'a [u8]>,
        data: &'a [u8],
    },
    ChannelMessage {
        link_id: LinkId,
        message_type: MessageType,
        data: &'a [u8],
    },
}

The data plane: bytes the app owns.

Variants

Delivered(Delivery<'a>)

Request

Fields

destination: DestinationHash

link_id: LinkId

request_id: RequestId

requester: Option<IdentityHash>

path_hash: RequestPathHash

requested_at: InstantMillis

rtt: RttMillis

data: &'a [u8]

Response

Fields

link_id: LinkId

request_id: RequestId

data: &'a [u8]

ResponseSegment

One in-order segment of a split response; the request’s settlement arrives as a Diagnostic::CommandSettled when the final segment assembles.

Fields

link_id: LinkId

request_id: RequestId

segment_index: u64

total_segments: u64

data: &'a [u8]

Resource

Fields

link_id: LinkId

hash: ResourceHash

metadata: Option<&'a [u8]>

The transfer’s packed metadata, stripped from the stream head, opaque to the engine; None when none traveled.

data: &'a [u8]

ResourceNeedsDecompression

Fields

link_id: LinkId

hash: ResourceHash

stream: &'a [u8]

uncompressed_data_bytes: u64

ResourceSegment

Fields

link_id: LinkId

original_hash: ResourceHash

segment_index: u64

total_segments: u64

metadata: Option<&'a [u8]>

Rides segment one only, stripped from the stream head like the single-segment delivery.

data: &'a [u8]

ChannelMessage

Fields

link_id: LinkId

message_type: MessageType

data: &'a [u8]

Trait Implementations

impl<'a> Debug for Message<'a>

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

Formats the value using the given formatter.