Struct AttemptClock 

pub struct AttemptClock { /* private fields */ }

Monotonic (Instant-based) timing capture for one transport attempt. Every mark is set-once; unobserved stages stay None (never zero).

Implementations

impl AttemptClock

pub fn start() -> Self

Start the clock immediately before handing bytes to the transport.

pub fn mark_headers(&mut self)

Response headers observed (set-once).

pub fn mark_first_byte(&mut self)

First response body byte / SSE frame observed (set-once).

pub fn set_first_model_event_after_headers(&mut self, offset_ms: u64)

First parsed model event, expressed as a monotonic offset from the headers mark (the stream parser measures from post-headers).

pub fn mark_first_model_event(&mut self)

First parsed model event, measured directly on this attempt’s own monotonic clock (set-once). Used by transports that observe the event on the same task that owns the clock (OpenAI-compatible paths); the Anthropic stream parser instead reports a post-headers offset via Self::set_first_model_event_after_headers.

pub fn set_first_model_event_offset(&mut self, offset_ms: u64)

First parsed model event at a caller-measured monotonic offset from this attempt’s send start (set-once). Used by transports whose stream events are observed on a task that does not own the clock (the extension-provider forwarder records the offset through an atomic and the owning task applies it here before finishing).

pub fn mark_stream_end(&mut self)

Stream fully consumed / request finished (set-once).

Trait Implementations

impl Clone for AttemptClock

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for AttemptClock

impl Debug for AttemptClock

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

Formats the value using the given formatter.