Struct InterceptStore 

pub struct InterceptStore { /* private fields */ }

Shared per-process intercept store.

Implementations

impl InterceptStore

pub fn new() -> Self

pub fn register( &self, host: impl Into<String>, method: impl Into<String>, path: impl Into<String>, ) -> (u64, Receiver<InterceptDecision>)

Register a fresh intercept and return the receiver the request handler should await on, plus the assigned ID.

Each call also opportunistically GCs any senders whose receiver has been dropped — this catches the client-disconnect path where neither resolve nor the timeout’s cancel fires (the request future is cancelled before either arm of tokio::select! runs). Without the GC the entries leak forever in senders + pending.

pub fn gc_dead_senders(&self) -> usize

Drop entries whose oneshot rx has been dropped. Exposed for tests + the TUI render loop, which can call this periodically even when no new intercepts are arriving.

pub fn resolve(&self, id: u64, decision: InterceptDecision) -> bool

Resolve a pending intercept with a decision. Idempotent — a second resolve for the same id is a no-op.

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

Cancel a pending intercept WITHOUT sending a decision. The proxy calls this when the receiver is dropped (client disconnected, request timed out before the operator decided) so the sender + pending entry don’t leak forever in the maps. Idempotent.

Returns true if an entry was removed, false if no such id.

pub fn drain_release(&self) -> usize

Release every pending intercept with Release. Used when the operator toggles intercept-mode OFF — don’t strand existing requests.

pub fn snapshot(&self) -> Vec<PendingIntercept>

Snapshot of the pending list for the TUI.

pub fn pending_count(&self) -> usize

How many requests are currently parked in the rendezvous.

Trait Implementations

impl Clone for InterceptStore

fn clone(&self) -> InterceptStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InterceptStore

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

Formats the value using the given formatter.

impl Default for InterceptStore

fn default() -> InterceptStore

Returns the “default value” for a type.