Struct CaptureStore 

pub struct CaptureStore(/* private fields */);

Available on crate features http and inspect and std only.

Implementations

impl CaptureStore

pub fn begin_connection_if_enabled( &self, socket: Option<SocketInfo>, ingress: Protocol, label: Option<String>, ) -> Option<u64>

pub fn connection_guard(&self, id: u64) -> CaptureConnectionGuard

pub fn upgrade_guard(&self, id: u64) -> HttpUpgradeCaptureGuard

pub fn upgrade_guard_for_response( &self, id: u64, status: u16, ) -> Option<HttpUpgradeCaptureGuard>

pub async fn clear(&self)

pub fn confirm_connection(&self, id: u64)

Publish a provisionally accepted socket once it is known to carry proxy traffic rather than the inspector’s own shared-port HTTP traffic.

pub fn confirm_connection_if_enabled(&self, id: u64)

pub fn set_connection_protocol(&self, id: u64, protocol: Protocol)

pub fn set_connection_protocol_if_enabled(&self, id: u64, protocol: Protocol)

pub fn finish_connection(&self, id: u64)

pub fn finish_upgrade(&self, id: u64)

pub fn discard_connection_if_empty(&self, id: u64) -> bool

Forget a connection that has only served the inspector itself.

A shared proxy/UI listener cannot distinguish the two at accept time. The first parsed origin-form dashboard request can, and is allowed to remove the provisional entry as long as no proxied exchange has been associated with it.

impl CaptureStore

pub fn exchange_capture( &self, id: u64, ) -> Result<ExchangeCapture, Box<dyn Error + Send + Sync>>

impl CaptureStore

pub async fn snapshot(&self, filter: &CaptureFilter) -> CaptureSnapshot

pub async fn snapshot_limited( &self, filter: &CaptureFilter, connection_limit: usize, exchange_limit: usize, ) -> CaptureSnapshot

pub async fn snapshot_limited_for_connections( &self, filter: &CaptureFilter, selected_connections: &BTreeSet<u64>, connection_offset: usize, connection_limit: usize, exchange_limit: usize, ) -> CaptureSnapshot

pub async fn snapshot_limited_before_connection( &self, filter: &CaptureFilter, selected_connections: &BTreeSet<u64>, before_connection_id: Option<u64>, connection_limit: usize, exchange_limit: usize, ) -> CaptureSnapshot

impl CaptureStore

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

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

pub async fn body_stream( &self, id: u64, body: CapturedBody, limit: Option<u64>, ) -> Result<impl Stream<Item = Result<Bytes, Box<dyn Error + Send + Sync>>> + Send + 'static, Box<dyn Error + Send + Sync>>

Stream logical body bytes directly from storage. A range-limited backend can avoid reading bytes beyond a preview; no JSON or base64 decoding occurs.

pub async fn replay_request( &self, id: u64, ) -> Result<ReplayRequest, Box<dyn Error + Send + Sync>>

impl CaptureStore

pub async fn record_decision( &self, id: u64, original: &Message, outcome: &str, headers: Option<&HeaderMap>, )

pub async fn record_replay_result( &self, id: u64, result: Result<StatusCode, String>, )

impl CaptureStore

pub fn with_storage( storage: BoxService<CreateCollection, Collection, Box<dyn Error + Send + Sync>>, config: CaptureConfig, inspection: InspectionState, ) -> CaptureStore

Assemble an inspector with caller-selected storage and a shared pause boundary.

pub fn control(&self) -> Control

pub fn new_control_connection(&self) -> ControlConnection

pub fn begin_observed_connection( &self, id: u64, socket: Option<SocketInfo>, ingress: Protocol, ) -> Option<u64>

pub fn inspection_state(&self) -> InspectionState

pub fn subscribe( &self, query: CaptureQuery, ) -> impl Stream<Item = CaptureSnapshot> + Send + 'static

Subscribe directly to initial and updated capture content. Body bytes remain independently streamable through body_stream, so lists stay lightweight.

pub fn subscribe_changes(&self) -> Receiver<u64>

pub fn connection_display_id(&self, id: u64) -> Option<u64>

pub fn connection_summary(&self, id: u64) -> Option<HttpConnectionSummary>

pub fn selected_exchange_ids( &self, request_ids: &BTreeSet<u64>, connection_ids: &BTreeSet<u64>, ) -> BTreeSet<u64>

pub fn selected_exchanges( &self, request_ids: &BTreeSet<u64>, connection_ids: &BTreeSet<u64>, ) -> CaptureSelection

Trait Implementations

impl CaptureWebSocketExt for CaptureStore

async fn record_websocket_message( &self, id: u64, message: CapturedWebSocketMessage, )

fn register_websocket_injector(&self, id: u64, injector: WebSocketRelayInjector)

async fn websocket_details( &self, id: u64, page: usize, page_size: usize, ) -> Result<WebSocketDetails, Box<dyn Error + Send + Sync>>

async fn replay_websocket_message( &self, id: u64, index: usize, ) -> Result<(), WebSocketReplayError>

async fn send_websocket_message( &self, id: u64, direction: WebSocketRelayDirection, message: WebSocketRelayMessage, ) -> Result<(), WebSocketReplayError>

fn websocket_message_stream( &self, id: u64, index: usize, ) -> Result<impl Stream<Item = Result<Bytes, Box<dyn Error + Send + Sync>>> + Send + 'static, Box<dyn Error + Send + Sync>>

impl Clone for CaptureStore

fn clone(&self) -> CaptureStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CaptureStore

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

Formats the value using the given formatter.

impl Service<CaptureQuery> for CaptureStore

type Output = CaptureSnapshot

The type of the output returned by the service.

type Error = !

The type of error returned by the service.

async fn serve( &self, query: CaptureQuery, ) -> Result<<CaptureStore as Service<CaptureQuery>>::Output, <CaptureStore as Service<CaptureQuery>>::Error>

Serve an output or an error for the given input

fn boxed(self) -> BoxService<Input, Self::Output, Self::Error>

Box this service to allow for dynamic dispatch.