Struct fc_db::sql::Backend

pub struct Backend<Block> { /* private fields */ }

Implementations

impl<Block> Backend<Block>

where Block: BlockT<Hash = H256>,

pub async fn new( config: BackendConfig<'_>, pool_size: u32, num_ops_timeout: Option<NonZeroU32>, storage_override: Arc<dyn StorageOverride<Block>>, ) -> Result<Self, Error>

Creates a new instance of the SQL backend.

pub fn pool(&self) -> &SqlitePool

Get the underlying Sqlite pool.

pub async fn canonicalize( &self, retracted: &[H256], enacted: &[H256], ) -> Result<(), Error>

Canonicalize the indexed blocks, marking/demarking them as canon based on the provided retracted and enacted values.

pub async fn insert_genesis_block_metadata<Client, BE>( &self, client: Arc<Client>, ) -> Result<Option<H256>, Error>

where Client: StorageProvider<Block, BE> + HeaderBackend<Block> + 'static + ProvideRuntimeApi<Block>, Client::Api: EthereumRuntimeRPCApi<Block>, BE: BackendT<Block> + 'static,

Index the block metadata for the genesis block.

pub async fn insert_block_metadata<Client, BE>( &self, client: Arc<Client>, hash: H256, ) -> Result<(), Error>

where Client: StorageProvider<Block, BE> + HeaderBackend<Block> + 'static, BE: BackendT<Block> + 'static,

Insert the block metadata for the provided block hashes.

pub async fn index_block_logs(&self, block_hash: Block::Hash)

Index the logs for the newly indexed blocks upto a max_pending_blocks value.

pub async fn is_block_indexed(&self, block_hash: Block::Hash) -> bool

Retrieves the status if a block has been already indexed.

pub async fn block_indexed_and_canon_status( &self, block_hash: Block::Hash, ) -> BlockIndexedStatus

Retrieves the status if a block is indexed and if also marked as canon.

pub async fn set_block_as_canon( &self, block_hash: H256, ) -> Result<SqliteQueryResult, Error>

Sets the provided block as canon.

pub async fn get_first_missing_canon_block(&self) -> Option<u32>

Retrieves the first missing canonical block number in decreasing order that hasn’t been indexed yet. If no unindexed block exists or the table or the rows do not exist, then the function returns None.

pub async fn get_first_pending_canon_block(&self) -> Option<H256>

Retrieves the first pending canonical block hash in decreasing order that hasn’t had then the function returns None.

pub async fn last_indexed_canon_block(&self) -> Result<H256, Error>

Retrieve the block hash for the last indexed canon block.

Trait Implementations

impl<Block: BlockT<Hash = H256>> Backend<Block> for Backend<Block>

fn block_hash<'life0, 'life1, 'async_trait>( &'life0 self, ethereum_block_hash: &'life1 H256, ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<Block::Hash>>, String>> + Send + 'async_trait>>

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

Get the substrate hash with the given ethereum block hash.

fn transaction_metadata<'life0, 'life1, 'async_trait>( &'life0 self, ethereum_transaction_hash: &'life1 H256, ) -> Pin<Box<dyn Future<Output = Result<Vec<TransactionMetadata<Block>>, String>> + Send + 'async_trait>>

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

Get the transaction metadata with the given ethereum block hash.

fn log_indexer(&self) -> &dyn LogIndexerBackend<Block>

Returns reference to log indexer backend.

fn first_block_hash<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Block::Hash, String>> + Send + 'async_trait>>

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

Get the hash of the oldest substrate block fully indexed by the backend.

fn latest_block_hash<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Block::Hash, String>> + Send + 'async_trait>>

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

Get the hash of the latest substrate block fully indexed by the backend.

fn is_indexed(&self) -> bool

Indicate whether the log indexing feature is supported.

impl<Block: Clone> Clone for Backend<Block>

fn clone(&self) -> Backend<Block>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<Block: BlockT<Hash = H256>> LogIndexerBackend<Block> for Backend<Block>

fn is_indexed(&self) -> bool

Indicate whether the log indexing feature is supported.

fn filter_logs<'life0, 'async_trait>( &'life0 self, from_block: u64, to_block: u64, addresses: Vec<H160>, topics: Vec<Vec<Option<H256>>>, ) -> Pin<Box<dyn Future<Output = Result<Vec<FilteredLog<Block>>, String>> + Send + 'async_trait>>

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

Filter the logs by the parameters.