Struct RecordedExchange 

pub struct RecordedExchange {
    pub recv_ts_ns: u128,
    pub latency_ns: Option<u64>,
    pub protocol: String,
    pub request: Value,
    pub response: Option<Value>,
}

One captured request/response pair plus metadata.

Fields

recv_ts_ns: u128

Wall-clock nanoseconds since UNIX epoch when the request was received. Replay tools use this to compute relative timing if they want to reproduce arrival rates.

latency_ns: Option<u64>

Latency of the response in nanoseconds (from request receive to response send). None if the request didn’t complete (timeout / cancel / crash).

protocol: String

Free-form protocol tag (e.g. "openai.chat", "kserve.embedding"). Replay readers can filter on this.

request: Value

Wire-format request as JSON.

response: Option<Value>

Wire-format response as JSON, or None for errored / open exchanges captured mid-flight.

Implementations

impl RecordedExchange

pub fn now( protocol: impl Into<String>, request: Value, response: Option<Value>, latency_ns: Option<u64>, ) -> Self

Convenience constructor with the current wall clock.

Trait Implementations

impl Clone for RecordedExchange

fn clone(&self) -> RecordedExchange

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RecordedExchange

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RecordedExchange

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for RecordedExchange

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

where __S: Serializer,

Serialize this value into the given Serde serializer.