Struct phron_finality::data_io::legacy::data_provider::ChainTracker

pub struct ChainTracker<B, SC, C>
where
    B: BlockT<Hash = BlockHash>,
    B::Header: HeaderT<Number = BlockNumber>,
    C: HeaderBackend<B> + 'static,
    SC: SelectChain<B> + 'static,
{
    select_chain: SC,
    client: Arc<C>,
    data_to_propose: Arc<Mutex<Option<PhronData>>>,
    session_boundaries: SessionBoundaries,
    prev_chain_info: Option<ChainInfo>,
    config: ChainTrackerConfig,
    _phantom: PhantomData<B>,
}

ChainTracker keeps track of the best_block in a given session and allows to generate PhronData. Internally it frequently updates a data_to_propose field that is shared with a DataProvider, which in turn is a tiny wrapper around this single shared resource that takes out data_to_propose whenever get_data is called.

Fields

select_chain: SC

client: Arc<C>

data_to_propose: Arc<Mutex<Option<PhronData>>>

session_boundaries: SessionBoundaries

prev_chain_info: Option<ChainInfo>

config: ChainTrackerConfig

_phantom: PhantomData<B>

Implementations

impl<B, SC, C> ChainTracker<B, SC, C>

where B: BlockT<Hash = BlockHash>, B::Header: HeaderT<Number = BlockNumber>, C: HeaderBackend<B> + 'static, SC: SelectChain<B> + 'static,

pub fn new( select_chain: SC, client: Arc<C>, session_boundaries: SessionBoundaries, config: ChainTrackerConfig, metrics: TimingBlockMetrics ) -> (Self, DataProvider)

fn update_data(&mut self, best_block_in_session: &BlockId)

async fn get_best_header(&self) -> B::Header

async fn get_best_block_in_session( &self, prev_best_block: Option<BlockId> ) -> Option<BlockId>

pub async fn run(self, exit: Receiver<()>)

Trait Implementations

impl<B, SC, C> Runnable for ChainTracker<B, SC, C>

where B: BlockT<Hash = BlockHash>, B::Header: HeaderT<Number = BlockNumber>, C: HeaderBackend<B> + 'static, SC: SelectChain<B> + 'static,

fn run<'async_trait>( self, exit: Receiver<()> ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait,