Struct Inbound

pub struct Inbound { /* private fields */ }

Uses the node state to respond to inbound peer requests.

This service, wrapped in appropriate middleware, is passed to zebra_network::init to respond to inbound peer requests.

The Inbound service is responsible for:

• supplying network data like peer addresses to other nodes;
• supplying chain data like blocks to other nodes;
• supplying mempool transactions to other nodes;
• receiving gossiped transactions; and
• receiving gossiped blocks.

Because the Inbound service is responsible for participating in the gossip protocols used for transaction and block diffusion, there is a potential overlap with the ChainSync and Mempool components.

The division of responsibility is that:

The ChainSync and Mempool components are internally driven, periodically polling the network to check for new blocks or transactions.

The Inbound service is externally driven, responding to block gossip by attempting to download and validate advertised blocks.

Gossiped transactions are forwarded to the mempool downloader, which unifies polled and gossiped transactions into a single download list.

Implementations

impl Inbound

pub fn new( full_verify_concurrency_limit: usize, setup: Receiver<InboundSetupData>, ) -> Inbound

Create a new inbound service.

Dependent services are sent via the setup channel after initialization.

Trait Implementations

impl Service<Request> for Inbound

fn call(&mut self, req: Request) -> Self::Future

Call the inbound service.

Errors indicate that the peer has done something wrong or unexpected, and will cause callers to disconnect from the remote peer.

type Response = Response

Responses given by the service.

type Error = Box<dyn Error + Sync + Send>

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<Inbound as Service<Request>>::Response, <Inbound as Service<Request>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.