Struct Requester 

pub struct Requester<E: Clock + GClock + Rng + Metrics, P: PublicKey> { /* private fields */ }

Send rate-limited requests to peers prioritized by performance.

Requester attempts to saturate the bandwidth (inferred by rate limit) of the most performant peers (based on our latency observations). To encourage exploration, set the value of initial to less than the expected latency of performant peers and/or periodically set shuffle in request.

Implementations

impl<E: Clock + GClock + Rng + Metrics, P: PublicKey> Requester<E, P>

pub fn new(context: E, config: Config<P>) -> Self

Create a new requester.

pub fn reconcile(&mut self, participants: &[P])

Indicate which participants can be sent requests.

pub fn block(&mut self, participant: P)

Skip a participant for future requests.

Participants added to this list will never be removed (even if dropped during reconcile, in case they are re-added later).

pub fn request(&mut self, shuffle: bool) -> Option<(P, ID)>

Ask for a participant to handle a request.

If shuffle is true, the order of participants is shuffled before a request is made. This is typically used when a request to the preferred participant fails.

pub fn cancel(&mut self, id: ID) -> Option<Request<P>>

Drop an outstanding request regardless of who it was intended for.

pub fn handle(&mut self, participant: &P, id: ID) -> Option<Request<P>>

Handle a request by ID, ensuring the provided participant was associated with said ID.

If the request was outstanding, a Request is returned that can either be resolved or timed out.

pub fn resolve(&mut self, request: Request<P>)

Resolve an outstanding request.

pub fn timeout(&mut self, request: Request<P>)

Timeout an outstanding request.

pub fn fail(&mut self, request: Request<P>)

Fail an outstanding request and penalize the request participant with the timeout duration.

This is used when we fail to send a request to a participant.

pub fn next(&self) -> Option<(ID, SystemTime)>

Get the next outstanding ID and deadline.

pub fn len(&self) -> usize

Get the number of outstanding requests.

pub fn len_blocked(&self) -> usize

Get the number of blocked participants.