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 get_all_reward_accounts( &self, height: u64, offset: u64, limit: u64, ) -> Result<Vec<(RewardAccountV2, RewardAmount)>>

impl RewardAccountProofDataSource for DataSource

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

async fn load_v2_reward_account_proof( &self, height: u64, account: RewardAccountV2, ) -> 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