Type Alias zebrad::components::inbound::GossipedBlockDownloads
source · type GossipedBlockDownloads = Downloads<Timeout<Buffer<BoxService<Request, Response, BoxError>, Request>>, Timeout<Buffer<BoxService<Request, Hash, RouterError>, Request>>, Buffer<BoxService<Request, Response, BoxError>, Request>>;
Aliased Type§
struct GossipedBlockDownloads {
full_verify_concurrency_limit: usize,
network: Timeout<Buffer<BoxService<Request, Response, Box<dyn Error + Sync + Send>>, Request>>,
verifier: Timeout<Buffer<BoxService<Request, Hash, RouterError>, Request>>,
state: Buffer<BoxService<Request, Response, Box<dyn Error + Sync + Send>>, Request>,
latest_chain_tip: LatestChainTip,
pending: FuturesUnordered<JoinHandle<Result<Hash, (Box<dyn Error + Sync + Send>, Hash)>>>,
cancel_handles: HashMap<Hash, Sender<()>>,
}
Fields§
§full_verify_concurrency_limit: usize
The configured full verification concurrency limit, after applying the minimum limit.
network: Timeout<Buffer<BoxService<Request, Response, Box<dyn Error + Sync + Send>>, Request>>
A service that forwards requests to connected peers, and returns their responses.
verifier: Timeout<Buffer<BoxService<Request, Hash, RouterError>, Request>>
A service that verifies downloaded blocks.
state: Buffer<BoxService<Request, Response, Box<dyn Error + Sync + Send>>, Request>
A service that manages cached blockchain state.
latest_chain_tip: LatestChainTip
Allows efficient access to the best tip of the blockchain.
pending: FuturesUnordered<JoinHandle<Result<Hash, (Box<dyn Error + Sync + Send>, Hash)>>>
A list of pending block download and verify tasks.
cancel_handles: HashMap<Hash, Sender<()>>
A list of channels that can be used to cancel pending block download and verify tasks.