Struct mithril_common::cardano_block_scanner::DumbBlockScanner

pub struct DumbBlockScanner { /* private fields */ }

Dumb block scanner

Implementations

impl DumbBlockScanner

pub fn new() -> Self

Factory

pub fn forwards(self, blocks: Vec<Vec<ScannedBlock>>) -> Self

Add to the inner streamer several ChainScannedBlocks::RollForwards responses at the end of its queue.

pub fn backward(self, chain_point: ChainPoint) -> Self

Add to the inner streamer a ChainScannedBlocks::RollBackward response at the end of its queue.

pub fn last_polled_point(self, raw_point: Option<RawCardanoPoint>) -> Self

Set the last polled point to return when Self::last_polled_point is called.

pub fn add_forwards(&self, blocks: Vec<Vec<ScannedBlock>>)

Add to the inner streamer several ChainScannedBlocks::RollForwards responses at the end of its queue.

pub fn add_backward(&self, chain_point: ChainPoint)

Add to the inner streamer a ChainScannedBlocks::RollBackward response at the end of its queue.

pub fn set_last_polled_point(&self, raw_point: Option<RawCardanoPoint>)

Set the last polled point to return when Self::last_polled_point is called.

Trait Implementations

impl BlockScanner for DumbBlockScanner

fn scan<'life0, 'async_trait>( &'life0 self, _from: Option<RawCardanoPoint>, _until: BlockNumber, ) -> Pin<Box<dyn Future<Output = StdResult<Box<dyn BlockStreamer>>> + Send + 'async_trait>>

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

Scan the transactions

impl Default for DumbBlockScanner

fn default() -> Self

Returns the “default value” for a type.