pub struct ProbeEnvelope {
pub wire_version: u32,
pub request_id: u64,
pub deadline_unix_ms: u64,
pub body: Option<Body>,
}Expand description
The probe daemon’s top-level message.
Framed on the wire as [u8 framing_version=1][u32 LE len][prost ProbeEnvelope], reusing running_process::broker::protocol::framing (16 MiB cap).
This is a STANDALONE wire. It is deliberately NOT multiplexed over the frozen
broker Frame registry and has no broker payload_protocol id: the probe
daemon is not a broker backend, so borrowing the broker’s envelope would
couple this schema to a frozen wire it does not otherwise need.
Fields§
§wire_version: u32Always 1 within probe_diag.v1. A peer that sees another value must refuse rather than guess — the field exists so a future wire break is detectable at the first byte of the body instead of surfacing as a decode error.
request_id: u64Client-assigned; echoed on the reply so responses can be correlated on a multiplexed connection.
deadline_unix_ms: u64Absolute wall-clock deadline. Absolute rather than a relative timeout so a request queued behind other work cannot silently extend its own budget.
body: Option<Body>Trait Implementations§
Source§impl Clone for ProbeEnvelope
impl Clone for ProbeEnvelope
Source§fn clone(&self) -> ProbeEnvelope
fn clone(&self) -> ProbeEnvelope
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for ProbeEnvelope
impl Debug for ProbeEnvelope
Source§impl Default for ProbeEnvelope
impl Default for ProbeEnvelope
Source§impl Message for ProbeEnvelope
impl Message for ProbeEnvelope
Source§fn encoded_len(&self) -> usize
fn encoded_len(&self) -> usize
Source§fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>where
Self: Sized,
fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>where
Self: Sized,
Source§fn encode_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
fn encode_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
Source§fn encode_length_delimited(
&self,
buf: &mut impl BufMut,
) -> Result<(), EncodeError>where
Self: Sized,
fn encode_length_delimited(
&self,
buf: &mut impl BufMut,
) -> Result<(), EncodeError>where
Self: Sized,
Source§fn encode_length_delimited_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
fn encode_length_delimited_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
Source§fn decode(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
fn decode(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
Source§fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
Source§fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
self. Read moreSource§fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
self.