Struct RequestTracker 

pub struct RequestTracker<V> { /* private fields */ }

Tracks pending request-response exchanges by (PeerId, RequestId).

This enables correct response correlation even when peers change their embedding (drift), since we match by who responded, not where they claim to be.

The value type V can be an enum to support multiple request types:

enum RequestData {
    Knn { search_embedding: Embedding, k: usize },
    Kfn { search_embedding: Embedding, k: usize },
    Ping,
}
let tracker: RequestTracker<RequestData> = RequestTracker::new(timeout);

Implementations

impl<V> RequestTracker<V>

where V: Clone,

pub fn new(default_timeout: Duration) -> Self

pub fn insert(&mut self, peer_id: PeerId, data: V) -> RequestId

Insert a new pending request, returning the assigned RequestId.

pub fn remove(&mut self, peer_id: &PeerId, request_id: &RequestId) -> Option<V>

Remove a pending request by peer_id and request_id.

pub fn is_pending(&self, peer_id: &PeerId, request_id: &RequestId) -> bool

Check if a request is pending for this peer.

pub fn process_timeouts(&mut self) -> Vec<(RequestKey, V)>

Process timeouts, returning timed-out (RequestKey, V) pairs.

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn iter(&self) -> impl Iterator<Item = (&RequestKey, &V)>

Iterate over all pending requests.

pub fn remove_all_for_peer(&mut self, peer_id: &PeerId) -> Vec<(RequestKey, V)>

Remove all pending requests for a specific peer. Returns all removed (RequestKey, V) pairs.

Trait Implementations

impl<V: Clone> Clone for RequestTracker<V>

fn clone(&self) -> RequestTracker<V>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<V: Debug> Debug for RequestTracker<V>

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

Formats the value using the given formatter.