Trait BlockProvider 

pub trait BlockProvider:
    Send
    + Sync
    + 'static {
    type GetNextBlockFut<'a>: Future<Output = OptionalBlockStuff> + Send + 'a;
    type GetBlockFut<'a>: Future<Output = OptionalBlockStuff> + Send + 'a;
    type CleanupFut<'a>: Future<Output = Result<()>> + Send + 'a;

    // Required methods
    fn get_next_block<'a>(
        &'a self,
        prev_block_id: &'a BlockId,
    ) -> Self::GetNextBlockFut<'a>;
    fn get_block<'a>(
        &'a self,
        block_id_relation: &'a BlockIdRelation,
    ) -> Self::GetBlockFut<'a>;
    fn cleanup_until(&self, mc_seqno: u32) -> Self::CleanupFut<'_>;
}

Block provider MUST validate the block before returning it.

Required Associated Types

type GetNextBlockFut<'a>: Future<Output = OptionalBlockStuff> + Send + 'a

type GetBlockFut<'a>: Future<Output = OptionalBlockStuff> + Send + 'a

type CleanupFut<'a>: Future<Output = Result<()>> + Send + 'a

Required Methods

fn get_next_block<'a>( &'a self, prev_block_id: &'a BlockId, ) -> Self::GetNextBlockFut<'a>

Wait for the next block. Mostly used for masterchain blocks.

fn get_block<'a>( &'a self, block_id_relation: &'a BlockIdRelation, ) -> Self::GetBlockFut<'a>

Get the exact block. Provider must return the requested block.

fn cleanup_until(&self, mc_seqno: u32) -> Self::CleanupFut<'_>

Clear resources until (and including) the specified masterchain block seqno.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types

impl<T0, T1> BlockProvider for (T0, T1)

where T0: BlockProvider, T1: BlockProvider,

type GetNextBlockFut<'a> = Pin<Box<dyn Future<Output = Option<Result<WithArchiveData<BlockStuff>, Error>>> + Send + 'a>>

type GetBlockFut<'a> = Pin<Box<dyn Future<Output = Option<Result<WithArchiveData<BlockStuff>, Error>>> + Send + 'a>>

type CleanupFut<'a> = Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'a>>

fn get_next_block<'a>( &'a self, prev_block_id: &'a BlockId, ) -> Self::GetNextBlockFut<'a>

fn get_block<'a>( &'a self, block_id_relation: &'a BlockIdRelation, ) -> Self::GetBlockFut<'a>

fn cleanup_until(&self, mc_seqno: u32) -> Self::CleanupFut<'_>

impl<T0, T1, T2> BlockProvider for (T0, T1, T2)

where T0: BlockProvider, T1: BlockProvider, T2: BlockProvider,

type GetNextBlockFut<'a> = Pin<Box<dyn Future<Output = Option<Result<WithArchiveData<BlockStuff>, Error>>> + Send + 'a>>

type GetBlockFut<'a> = Pin<Box<dyn Future<Output = Option<Result<WithArchiveData<BlockStuff>, Error>>> + Send + 'a>>

type CleanupFut<'a> = Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'a>>

fn get_next_block<'a>( &'a self, prev_block_id: &'a BlockId, ) -> Self::GetNextBlockFut<'a>

fn get_block<'a>( &'a self, block_id_relation: &'a BlockIdRelation, ) -> Self::GetBlockFut<'a>

fn cleanup_until(&self, mc_seqno: u32) -> Self::CleanupFut<'_>

impl<T0, T1, T2, T3> BlockProvider for (T0, T1, T2, T3)

where T0: BlockProvider, T1: BlockProvider, T2: BlockProvider, T3: BlockProvider,

type GetNextBlockFut<'a> = Pin<Box<dyn Future<Output = Option<Result<WithArchiveData<BlockStuff>, Error>>> + Send + 'a>>

type GetBlockFut<'a> = Pin<Box<dyn Future<Output = Option<Result<WithArchiveData<BlockStuff>, Error>>> + Send + 'a>>

type CleanupFut<'a> = Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'a>>

fn get_next_block<'a>( &'a self, prev_block_id: &'a BlockId, ) -> Self::GetNextBlockFut<'a>

fn get_block<'a>( &'a self, block_id_relation: &'a BlockIdRelation, ) -> Self::GetBlockFut<'a>

fn cleanup_until(&self, mc_seqno: u32) -> Self::CleanupFut<'_>

impl<T0, T1, T2, T3, T4> BlockProvider for (T0, T1, T2, T3, T4)

where T0: BlockProvider, T1: BlockProvider, T2: BlockProvider, T3: BlockProvider, T4: BlockProvider,

type GetNextBlockFut<'a> = Pin<Box<dyn Future<Output = Option<Result<WithArchiveData<BlockStuff>, Error>>> + Send + 'a>>

type GetBlockFut<'a> = Pin<Box<dyn Future<Output = Option<Result<WithArchiveData<BlockStuff>, Error>>> + Send + 'a>>

type CleanupFut<'a> = Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'a>>

fn get_next_block<'a>( &'a self, prev_block_id: &'a BlockId, ) -> Self::GetNextBlockFut<'a>

fn get_block<'a>( &'a self, block_id_relation: &'a BlockIdRelation, ) -> Self::GetBlockFut<'a>

fn cleanup_until(&self, mc_seqno: u32) -> Self::CleanupFut<'_>

impl<T: BlockProvider> BlockProvider for Box<T>

type GetNextBlockFut<'a> = <T as BlockProvider>::GetNextBlockFut<'a>

type GetBlockFut<'a> = <T as BlockProvider>::GetBlockFut<'a>

type CleanupFut<'a> = <T as BlockProvider>::CleanupFut<'a>

fn get_next_block<'a>( &'a self, prev_block_id: &'a BlockId, ) -> Self::GetNextBlockFut<'a>

fn get_block<'a>( &'a self, block_id_relation: &'a BlockIdRelation, ) -> Self::GetBlockFut<'a>

fn cleanup_until(&self, mc_seqno: u32) -> Self::CleanupFut<'_>

impl<T: BlockProvider> BlockProvider for Arc<T>

type GetNextBlockFut<'a> = <T as BlockProvider>::GetNextBlockFut<'a>

type GetBlockFut<'a> = <T as BlockProvider>::GetBlockFut<'a>

type CleanupFut<'a> = <T as BlockProvider>::CleanupFut<'a>

fn get_next_block<'a>( &'a self, prev_block_id: &'a BlockId, ) -> Self::GetNextBlockFut<'a>

fn get_block<'a>( &'a self, block_id_relation: &'a BlockIdRelation, ) -> Self::GetBlockFut<'a>

fn cleanup_until(&self, mc_seqno: u32) -> Self::CleanupFut<'_>

Implementors

impl BlockProvider for ArchiveBlockProvider

type GetNextBlockFut<'a> = Pin<Box<dyn Future<Output = Option<Result<WithArchiveData<BlockStuff>, Error>>> + Send + 'a>>

type GetBlockFut<'a> = Pin<Box<dyn Future<Output = Option<Result<WithArchiveData<BlockStuff>, Error>>> + Send + 'a>>

type CleanupFut<'a> = Ready<Result<(), Error>>

impl BlockProvider for BlockchainBlockProvider

type GetNextBlockFut<'a> = Pin<Box<dyn Future<Output = Option<Result<WithArchiveData<BlockStuff>, Error>>> + Send + 'a>>

type GetBlockFut<'a> = Pin<Box<dyn Future<Output = Option<Result<WithArchiveData<BlockStuff>, Error>>> + Send + 'a>>

type CleanupFut<'a> = BlockchainBlockProviderCleanupFut<'a>

impl BlockProvider for BoxBlockProvider

type GetNextBlockFut<'a> = Pin<Box<dyn Future<Output = Option<Result<WithArchiveData<BlockStuff>, Error>>> + Send + 'a>>

type GetBlockFut<'a> = Pin<Box<dyn Future<Output = Option<Result<WithArchiveData<BlockStuff>, Error>>> + Send + 'a>>

type CleanupFut<'a> = Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'a>>

impl BlockProvider for EmptyBlockProvider

type GetNextBlockFut<'a> = Ready<Option<Result<WithArchiveData<BlockStuff>, Error>>>

type GetBlockFut<'a> = Ready<Option<Result<WithArchiveData<BlockStuff>, Error>>>

type CleanupFut<'a> = Ready<Result<(), Error>>

impl BlockProvider for StorageBlockProvider

type GetNextBlockFut<'a> = Pin<Box<dyn Future<Output = Option<Result<WithArchiveData<BlockStuff>, Error>>> + Send + 'a>>

type GetBlockFut<'a> = Pin<Box<dyn Future<Output = Option<Result<WithArchiveData<BlockStuff>, Error>>> + Send + 'a>>

type CleanupFut<'a> = Ready<Result<(), Error>>

impl<T1: BlockProvider, T2: BlockProvider> BlockProvider for ChainBlockProvider<T1, T2>

type GetNextBlockFut<'a> = Pin<Box<dyn Future<Output = Option<Result<WithArchiveData<BlockStuff>, Error>>> + Send + 'a>>

type GetBlockFut<'a> = Pin<Box<dyn Future<Output = Option<Result<WithArchiveData<BlockStuff>, Error>>> + Send + 'a>>

type CleanupFut<'a> = Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'a>>

impl<T1: BlockProvider, T2: BlockProvider> BlockProvider for CycleBlockProvider<T1, T2>

type GetNextBlockFut<'a> = Pin<Box<dyn Future<Output = Option<Result<WithArchiveData<BlockStuff>, Error>>> + Send + 'a>>

type GetBlockFut<'a> = Pin<Box<dyn Future<Output = Option<Result<WithArchiveData<BlockStuff>, Error>>> + Send + 'a>>

type CleanupFut<'a> = Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'a>>

impl<T: BlockProvider> BlockProvider for RetryBlockProvider<T>

type GetNextBlockFut<'a> = Pin<Box<dyn Future<Output = Option<Result<WithArchiveData<BlockStuff>, Error>>> + Send + 'a>>

type GetBlockFut<'a> = <T as BlockProvider>::GetBlockFut<'a>

type CleanupFut<'a> = <T as BlockProvider>::CleanupFut<'a>