Struct interledger_ccp::CcpRouteManager

pub struct CcpRouteManager<I, O, S, A: Account> { /* fields omitted */ }

The Routing Manager Service.

This implements the Connector-to-Connector Protocol (CCP) for exchanging route updates with peers. This service handles incoming CCP messages and sends updates to peers. It manages the routing table in the Store and updates it with the best routes determined by per-account configuration and the broadcasts we have received from peers.

Methods

impl<I, O, S, A> CcpRouteManager<I, O, S, A> where
    I: IncomingService<A> + Clone + Send + Sync + 'static,
    O: OutgoingService<A> + Clone + Send + Sync + 'static,
    S: RouteManagerStore<Account = A> + Clone + Send + Sync + 'static,
    A: CcpRoutingAccount + Send + Sync + 'static, 

pub fn start_broadcast_interval(
    &self,
    interval: u64
) -> impl Future<Item = (), Error = ()>

Returns a future that will trigger this service to update its routes and broadcast updates to peers on the given interval.

pub fn broadcast_routes(&self) -> impl Future<Item = (), Error = ()>

Trait Implementations

impl<I: Clone, O: Clone, S: Clone, A: Clone + Account> Clone for CcpRouteManager<I, O, S, A> where
    A::AccountId: Clone, 

fn clone(&self) -> CcpRouteManager<I, O, S, A>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<I, O, S, A> IncomingService<A> for CcpRouteManager<I, O, S, A> where
    I: IncomingService<A> + Clone + Send + Sync + 'static,
    O: OutgoingService<A> + Clone + Send + Sync + 'static,
    S: RouteManagerStore<Account = A> + Clone + Send + Sync + 'static,
    A: CcpRoutingAccount + Send + Sync + 'static, 

type Future = BoxedIlpFuture

fn handle_request(&mut self, request: IncomingRequest<A>) -> Self::Future

Handle the IncomingRequest if it is a CCP protocol message or pass it on to the next handler if not