Struct lightning_block_sync::poll::ChainPoller

pub struct ChainPoller<B: Deref<Target = T> + Sized + Send + Sync, T: BlockSource + ?Sized> { /* private fields */ }

The canonical Poll implementation used for a single BlockSource.

Other Poll implementations should be built using ChainPoller as it provides the simplest way of validating chain data and checking consistency.

Implementations

impl<B: Deref<Target = T> + Sized + Send + Sync, T: BlockSource + ?Sized> ChainPoller<B, T>

pub fn new(block_source: B, network: Network) -> Self

Creates a new poller for the given block source.

If the network parameter is mainnet, then the difficulty between blocks is checked for validity.

Trait Implementations

impl<B: Deref<Target = T> + Sized + Send + Sync, T: BlockSource + ?Sized> Poll for ChainPoller<B, T>

fn poll_chain_tip<'a>( &'a self, best_known_chain_tip: ValidatedBlockHeader ) -> AsyncBlockSourceResult<'a, ChainTip>

Returns a chain tip in terms of its relationship to the provided chain tip.

fn look_up_previous_header<'a>( &'a self, header: &'a ValidatedBlockHeader ) -> AsyncBlockSourceResult<'a, ValidatedBlockHeader>

Returns the header that preceded the given header in the chain.

fn fetch_block<'a>( &'a self, header: &'a ValidatedBlockHeader ) -> AsyncBlockSourceResult<'a, ValidatedBlock>

Returns the block associated with the given header.