Struct ExchangeCapture 

pub struct ExchangeCapture { /* private fields */ }

Available on crate features http and inspect and std only.

Pins an exchange, its observations and storage while an adapter or reader uses it.

Implementations

impl ExchangeCapture

pub fn summary_details(&self) -> CaptureDetails

Snapshot summary and observations without reading stored metadata records.

pub async fn inspector_details( &self, ) -> Result<CaptureDetails, Box<dyn Error + Send + Sync>>

Read bounded HTTP metadata without body or interception payload bytes. Upgraded message history is paged separately with message_interceptions.

pub async fn details( &self, ) -> Result<CaptureDetails, Box<dyn Error + Send + Sync>>

pub fn id(&self) -> u64

pub fn metadata(&self) -> &CaptureMetadata

pub fn inspection_state(&self) -> InspectionState

pub fn snapshot(&self) -> HttpExchangeSummary

pub fn state<T>(&self) -> Arc<T>

where T: Extension + Default,

pub fn changed(&self)

pub fn set_active(&self)

pub fn mark_truncated(&self)

pub fn record_bytes(&self, direction: CapturedBody, length: u64)

pub fn reserve_body(&self, direction: CapturedBody, length: u64) -> bool

pub fn count<T>(&self) -> usize

where T: CapturedRecord,

pub async fn append<T>( &self, record: &T, ) -> Result<bool, Box<dyn Error + Send + Sync>>

where T: CapturedRecord,

pub async fn record_stream<T>( &self, index: usize, ) -> Result<Option<CapturedRecordStream<<T as CapturedRecord>::Metadata>>, Box<dyn Error + Send + Sync>>

where T: CapturedRecord,

Read typed metadata and stream the payload without materializing it.

pub async fn record<T>( &self, index: usize, ) -> Result<Option<T>, Box<dyn Error + Send + Sync>>

where T: CapturedRecord,

Explicitly read one owned record. Prefer record_stream for large payloads.

pub async fn records<T>( &self, range: Range<usize>, ) -> Result<Vec<T>, Box<dyn Error + Send + Sync>>

where T: CapturedRecord,

impl ExchangeCapture

pub async fn message_interceptions( &self, page: usize, ) -> Result<Vec<StoredRecord>, Box<dyn Error + Send + Sync>>

Read a page of upgraded-message decisions, newest page first. Each payload preview is bounded to 1 KiB and each page to 16 records. Full records remain available through explicit capture downloads or details.

impl ExchangeCapture

pub fn body_source(&self, body: CapturedBody) -> CapturedBodySource

impl ExchangeCapture

pub async fn request_head( &self, ) -> Result<Option<StoredRecord>, Box<dyn Error + Send + Sync>>

Read only the original request head; body and subsequent decision records are untouched.

pub fn records_stream( &self, ) -> impl Stream<Item = Result<StoredRecord, Box<dyn Error + Send + Sync>>> + Send + 'static + use<>

Stream a pinned record prefix. Body records may be split into smaller chunks; metadata ordering and the concatenated body bytes are preserved.

Trait Implementations

impl Clone for ExchangeCapture

fn clone(&self) -> ExchangeCapture

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ExchangeCapture

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

Formats the value using the given formatter.