Type Alias DataSource 

pub type DataSource = FileSystemDataSource<SeqTypes, Provider>;

Aliased Type

pub struct DataSource { /* private fields */ }

Trait Implementations

impl CatchupStorage for DataSource

fn get_accounts( &self, _instance: &NodeState, _height: u64, _view: ViewNumber, _accounts: &[FeeAccount], ) -> impl Send + Future<Output = Result<(FeeMerkleTree, Leaf2)>>

Get the state of the requested accounts.

fn get_reward_accounts_v1( &self, _instance: &NodeState, _height: u64, _view: ViewNumber, _accounts: &[RewardAccountV1], ) -> impl Send + Future<Output = Result<(RewardMerkleTreeV1, Leaf2)>>

fn get_reward_accounts_v2( &self, _instance: &NodeState, _height: u64, _view: ViewNumber, _accounts: &[RewardAccountV2], ) -> impl Send + Future<Output = Result<(RewardMerkleTreeV2, Leaf2)>>

fn get_frontier( &self, _instance: &NodeState, _height: u64, _view: ViewNumber, ) -> impl Send + Future<Output = Result<BlocksFrontier>>

Get the blocks Merkle tree frontier.

fn get_chain_config( &self, _commitment: Commitment<ChainConfig>, ) -> impl Send + Future<Output = Result<ChainConfig>>

fn get_leaf_chain( &self, _height: u64, ) -> impl Send + Future<Output = Result<Vec<Leaf2>>>

fn load_earliest_cert2( &self, _height: u64, ) -> impl Send + Future<Output = Result<Option<Certificate2<SeqTypes>>>>

Load the earliest cert2 whose finalized block height is at or above height.

fn get_leaf(&self, _height: u64) -> impl Send + Future<Output = Result<Leaf2>>

Load a decided leaf at the given height.

impl PruningDataSource for DataSource

async fn get_oldest_block(&self) -> Result<Option<BlockQueryData<SeqTypes>>>

Get the oldest block in storage, or None if empty or unsupported.

async fn get_oldest_leaf(&self) -> Result<Option<LeafQueryData<SeqTypes>>>

Get the oldest leaf in storage, or None if empty or unsupported.

impl SequencerDataSource for DataSource

type Options = Options

fn create<'async_trait>( opt: Self::Options, provider: Provider, reset: bool, ) -> Pin<Box<dyn Future<Output = Result<Self>> + Send + 'async_trait>>

where Self: 'async_trait,

Instantiate a data source from command line options.