Struct phron_finality::import::PhronBlockImport

pub struct PhronBlockImport<I>
where
    I: BlockImport<Block> + Clone + Send,
{
    inner: I,
    justification_tx: UnboundedSender<Justification>,
    translator: JustificationTranslator,
}

A wrapper around a block import that also extracts any present justifications and sends them to our components which will process them further and possibly finalize the block.

Fields

inner: I

justification_tx: UnboundedSender<Justification>

translator: JustificationTranslator

Implementations

impl<I> PhronBlockImport<I>

where I: BlockImport<Block> + Clone + Send,

pub fn new( inner: I, justification_tx: UnboundedSender<Justification>, translator: JustificationTranslator ) -> PhronBlockImport<I>

fn send_justification( &mut self, block_id: BlockId, justification: SubstrateJustification ) -> Result<(), SendJustificationError<TranslateError>>

Trait Implementations

impl<I> BlockImport<Block<Header<u32, BlakeTwo256>, OpaqueExtrinsic>> for PhronBlockImport<I>

where I: BlockImport<Block> + Clone + Send,

type Error = <I as BlockImport<Block<Header<u32, BlakeTwo256>, OpaqueExtrinsic>>>::Error

The error type.

fn check_block<'life0, 'async_trait>( &'life0 mut self, block: BlockCheckParams<Block> ) -> Pin<Box<dyn Future<Output = Result<ImportResult, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Check block preconditions.

fn import_block<'life0, 'async_trait>( &'life0 mut self, block: BlockImportParams<Block> ) -> Pin<Box<dyn Future<Output = Result<ImportResult, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Import a block.

impl<I> Clone for PhronBlockImport<I>

where I: BlockImport<Block> + Clone + Send + Clone,

fn clone(&self) -> PhronBlockImport<I>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<I> JustificationImport<Block<Header<u32, BlakeTwo256>, OpaqueExtrinsic>> for PhronBlockImport<I>

where I: BlockImport<Block> + Clone + Send,

type Error = Error

fn on_start<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Vec<(BlockHash, BlockNumber)>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Called by the import queue when it is started. Returns a list of justifications to request from the network.

fn import_justification<'life0, 'async_trait>( &'life0 mut self, hash: BlockHash, number: BlockNumber, justification: SubstrateJustification ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Import a Block justification and finalize the given block.