Function cuprate_dandelion_tower::pool::start_dandelion_pool_manager

pub fn start_dandelion_pool_manager<P, R, Tx, TxId, PeerId>(
    buffer_size: usize,
    dandelion_router: R,
    backing_pool: P,
    config: DandelionConfig,
) -> DandelionPoolService<Tx, TxId, PeerId>
where
    Tx: Clone + Send + 'static,
    TxId: Hash + Eq + Clone + Send + 'static,
    PeerId: Hash + Eq + Clone + Send + 'static,
    P: Service<TxStoreRequest<TxId>, Response = TxStoreResponse<Tx>, Error = BoxError> + Send + 'static,
    P::Future: Send + 'static,
    R: Service<DandelionRouteReq<Tx, PeerId>, Response = State, Error = DandelionRouterError> + Send + 'static,
    R::Future: Send + 'static,

Start the DandelionPoolManager.

This function spawns the DandelionPoolManager and returns DandelionPoolService which can be used to send requests to the pool.

Args

• buffer_size is the size of the channel’s buffer between the DandelionPoolService and DandelionPoolManager.
• dandelion_router is the router service, kept generic instead of DandelionRouter to allow user to customise routing functionality.
• backing_pool is the backing transaction storage service
• config is DandelionConfig.