Struct StreamAttempt 

pub struct StreamAttempt { /* private fields */ }

Per-attempt trace state for one OpenAI-compatible request: the optional tracer plus this attempt’s monotonic clock. Every method is a no-op when tracing is disabled; nothing here can fail the request.

Implementations

impl StreamAttempt

pub fn new(tracer: Option<RequestTracer>) -> Self

Start the first attempt’s clock. Call immediately before the send.

pub fn restart_clock(&mut self)

Restart the per-attempt clock (retry loops call this right before each re-send — retry clocks reset per attempt).

pub fn request_id(&self) -> Option<&TraceId>

The trace request ID, when a tracer began (for content-capture correlation). None when tracing is disabled for this request.

pub fn mark_headers(&mut self)

pub fn mark_first_byte(&mut self)

pub fn mark_first_model_event(&mut self)

pub fn attempt_failed( &mut self, class: RetryClass, delay: Duration, http_status: Option<u16>, provider_request_id: Option<TraceId>, code: &str, )

Record a failed attempt that WILL be retried (one record per actual send). code must be a static literal or http_<status>.

pub fn finish_success( &mut self, http_status: Option<u16>, provider_request_id: Option<TraceId>, stop_reason: Option<StopReason>, usage: Option<UsageMeta>, )

Final record: request completed. Subsequent finish calls are no-ops (the tracer is taken), so error paths can never double-emit.

pub fn finish_canceled( &mut self, http_status: Option<u16>, usage: Option<UsageMeta>, )

Final record: request canceled mid-attempt.

pub fn finish_failed( &mut self, code: &str, http_status: Option<u16>, provider_request_id: Option<TraceId>, )

Final record: terminal provider/transport failure. code must be a static literal or http_<status> — never raw provider text.