Type Alias DataSource 

pub type DataSource = SqlDataSource<SeqTypes, Provider>;

Aliased Type

pub struct DataSource { /* private fields */ }

Trait Implementations

impl CatchupStorage for DataSource

async fn get_accounts( &self, instance: &NodeState, height: u64, view: ViewNumber, accounts: &[FeeAccount], ) -> Result<(FeeMerkleTree, Leaf2)>

Get the state of the requested accounts.

async fn get_reward_accounts_v2( &self, instance: &NodeState, height: u64, view: ViewNumber, accounts: &[RewardAccountV2], ) -> Result<(RewardMerkleTreeV2, Leaf2)>

async fn get_reward_accounts_v1( &self, instance: &NodeState, height: u64, view: ViewNumber, accounts: &[RewardAccountV1], ) -> Result<(RewardMerkleTreeV1, Leaf2)>

async fn get_frontier( &self, instance: &NodeState, height: u64, view: ViewNumber, ) -> Result<BlocksFrontier>

Get the blocks Merkle tree frontier.

async fn get_chain_config( &self, commitment: Commitment<ChainConfig>, ) -> Result<ChainConfig>

async fn get_leaf_chain(&self, height: u64) -> Result<Vec<Leaf2>>

async fn load_earliest_cert2( &self, height: u64, ) -> Result<Option<Certificate2<SeqTypes>>>

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

async fn get_leaf(&self, height: u64) -> Result<Leaf2>

Load a decided leaf at the given height.

impl DatabaseMetadataSource for DataSource

async fn get_table_sizes(&self) -> Result<Vec<TableSize>>

Get the sizes of all tables in the database.

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 RewardMerkleTreeDataSource for DataSource

async fn load_v1_reward_account_proof( &self, height: u64, account: RewardAccountV1, ) -> Result<RewardAccountQueryDataV1>

fn persist_tree( &self, height: u64, merkle_tree: Vec<u8>, ) -> impl Send + Future<Output = Result<()>>

fn load_tree(&self, height: u64) -> impl Send + Future<Output = Result<Vec<u8>>>

fn load_latest_tree( &self, height: u64, ) -> impl Send + Future<Output = Result<Vec<u8>>>

Load the latest serialized reward merkle tree v2 at height <= height.

fn garbage_collect( &self, height: u64, ) -> impl Send + Future<Output = Result<()>>

garbage collects merkle tree data for blocks strictly older than height

fn persist_proofs( &self, height: u64, proofs: impl Iterator<Item = (Vec<u8>, Vec<u8>)> + Send, ) -> impl Send + Future<Output = Result<()>>

fn load_proof( &self, height: u64, account: Vec<u8>, epoch_height: u64, ) -> impl Send + Future<Output = Result<Vec<u8>>>

fn load_latest_proof( &self, account: Vec<u8>, ) -> impl Send + Future<Output = Result<Vec<u8>>>

fn proof_exists(&self, height: u64) -> impl Send + Future<Output = bool>

fn persist_reward_proofs( &self, node_state: &NodeState, height: u64, version: Version, ) -> impl Send + Future<Output = Result<()>>

fn save_and_gc_reward_tree_v2( &self, node_state: &NodeState, height: u64, version: Version, merkle_tree: &RewardMerkleTreeV2, ) -> impl Send + Future<Output = Result<()>>

fn load_reward_merkle_tree_v2( &self, height: u64, ) -> impl Send + Future<Output = Result<PermittedRewardMerkleTreeV2>>

fn load_latest_reward_merkle_tree_v2( &self, height: u64, ) -> impl Send + Future<Output = Result<PermittedRewardMerkleTreeV2>>

Returns the RewardMerkleTreeV2 for height <= requested height

fn load_reward_account_proof_v2( &self, _height: u64, _account: RewardAccountV2, ) -> impl Send + Future<Output = Result<RewardAccountQueryDataV2>>

fn load_latest_reward_account_proof_v2( &self, account: RewardAccountV2, ) -> impl Send + Future<Output = Result<RewardAccountQueryDataV2>>

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.

impl TestableSequencerDataSource for DataSource

type Storage = TmpDb

fn create_storage<'async_trait>() -> Pin<Box<dyn Future<Output = Self::Storage> + Send + 'async_trait>>

where Self: 'async_trait,

fn persistence_options(storage: &Self::Storage) -> Self::Options

fn leaf_only_ds_options( storage: &Self::Storage, opt: Options, ) -> Result<Options>

fn options(storage: &Self::Storage, opt: Options) -> Options