Struct NetworkTraceV2 

pub struct NetworkTraceV2 {
    pub epoch: DateTime<Utc>,
    pub channels: Vec<NetworkChannelV2>,
    pub inputs: Vec<NetworkInputEventV1>,
    pub outputs: Vec<NetworkOutputV4>,
}

Version-two schedule-independent network trace: v1’s release model over several channels.

Fields

epoch: DateTime<Utc>

channels: Vec<NetworkChannelV2>

inputs: Vec<NetworkInputEventV1>

Inputs of every channel, in the global order they were observed.

outputs: Vec<NetworkOutputV4>

Outbound fragments of every channel, in the order they were sent.

Implementations

impl NetworkTraceV2

pub fn validate(&self) -> Result<(), NetworkTraceValidationError>

Enforce the v2 envelope before either writing or consuming a trace.

pub fn records_refused_sends(&self) -> bool

Whether the trace records a nonblocking send refused with EAGAIN, which only v3 and v4 can hold.

pub fn records_send_waits(&self) -> bool

Whether any outbound fragment records a wait, which only v4 can hold.

pub fn write_framed<W: Write>( &self, writer: W, ) -> Result<(), NetworkTraceCodecError>

Write one complete, length-delimited trace: v4 when it records a send wait, otherwise v3 when it records a refused send, otherwise v2.

pub fn encode_framed(&self) -> Result<Vec<u8>, NetworkTraceCodecError>

The bytes Self::write_framed writes, encoded without touching any output, so a caller can refuse an invalid trace before it truncates a file.

pub fn read_framed<R: Read>(reader: R) -> Result<Self, NetworkTraceCodecError>

Read exactly one complete v1, v2, v3 or v4 trace. A v1 trace is upgraded to the equivalent v2 trace after passing v1 validation; a v2 trace may not hold the refused sends that v3 added, and only a v4 trace can hold a send wait.

Trait Implementations

impl Clone for NetworkTraceV2

fn clone(&self) -> NetworkTraceV2

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NetworkTraceV2

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for NetworkTraceV2

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for NetworkTraceV2

impl From<NetworkTraceV1> for NetworkTraceV2

fn from(trace: NetworkTraceV1) -> Self

Converts to this type from the input type.

impl PartialEq for NetworkTraceV2

fn eq(&self, other: &NetworkTraceV2) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for NetworkTraceV2

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for NetworkTraceV2