Struct interledger_service_util::ExpiryShortenerService

pub struct ExpiryShortenerService<O> { /* fields omitted */ }

Expiry Shortener Service

Each node shortens the Prepare packet's expiry duration before passing it on. Nodes shorten the expiry duration so that even if the packet is fulfilled just before the expiry, they will still have enough time to pass the fulfillment to the previous node before it expires.

This service reduces the expiry time of each packet before forwarding it out. Requires a RoundtripTimeAccount and no store

Methods

impl<O> ExpiryShortenerService<O>

pub fn new(next: O) -> Self

pub fn max_expiry_duration(&mut self, milliseconds: u32) -> &mut Self

Trait Implementations

impl<O: Clone> Clone for ExpiryShortenerService<O>

fn clone(&self) -> ExpiryShortenerService<O>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<O, A> OutgoingService<A> for ExpiryShortenerService<O> where
    O: OutgoingService<A>,
    A: RoundTripTimeAccount, 

type Future = O::Future

fn send_request(&mut self, request: OutgoingRequest<A>) -> Self::Future

On send request:

1. Get the sender and receiver's roundtrip time (default 1000ms)
2. Reduce the packet's expiry by that amount
3. Ensure that the packet expiry does not exceed the maximum expiry duration
4. Forward the request