Struct ChainHeadBackend 

pub struct ChainHeadBackend<T: Config> { /* private fields */ }

The chainHead backend.

Implementations

impl<T: Config> ChainHeadBackend<T>

pub fn builder() -> ChainHeadBackendBuilder<T>

Configure and construct an ChainHeadBackend and the associated ChainHeadBackendDriver.

Trait Implementations

impl<T: Config> Backend<T> for ChainHeadBackend<T>

fn storage_fetch_values<'life0, 'async_trait>( &'life0 self, keys: Vec<Vec<u8>>, at: HashFor<T>, ) -> Pin<Box<dyn Future<Output = Result<StreamOfResults<StorageResponse>, BackendError>> + Send + 'async_trait>>

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

Fetch values from storage.

fn storage_fetch_descendant_keys<'life0, 'async_trait>( &'life0 self, key: Vec<u8>, at: HashFor<T>, ) -> Pin<Box<dyn Future<Output = Result<StreamOfResults<Vec<u8>>, BackendError>> + Send + 'async_trait>>

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

Fetch keys underneath the given key from storage.

fn storage_fetch_descendant_values<'life0, 'async_trait>( &'life0 self, key: Vec<u8>, at: HashFor<T>, ) -> Pin<Box<dyn Future<Output = Result<StreamOfResults<StorageResponse>, BackendError>> + Send + 'async_trait>>

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

Fetch values underneath the given key from storage.

fn genesis_hash<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<HashFor<T>, BackendError>> + Send + 'async_trait>>

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

Fetch the genesis hash

fn block_number_to_hash<'life0, 'async_trait>( &'life0 self, _number: u64, ) -> Pin<Box<dyn Future<Output = Result<Option<BlockRef<HashFor<T>>>, BackendError>> + Send + 'async_trait>>

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

Convert a block number to a hash. This should return None in the event that multiple block hashes correspond to the given number (ie if the number is greater than that of the latest finalized block and some forks exist). Nevertheless, it could still return the hash to a block on some fork that is pruned.

fn block_header<'life0, 'async_trait>( &'life0 self, at: HashFor<T>, ) -> Pin<Box<dyn Future<Output = Result<Option<T::Header>, BackendError>> + Send + 'async_trait>>

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

Get a block header.

fn block_body<'life0, 'async_trait>( &'life0 self, at: HashFor<T>, ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<Vec<u8>>>, BackendError>> + Send + 'async_trait>>

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

Return the extrinsics found in the block. Each extrinsic is represented by a vector of bytes which has not been SCALE decoded (in other words, the first bytes in the vector will decode to the compact encoded length of the extrinsic)

fn latest_finalized_block_ref<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<BlockRef<HashFor<T>>, BackendError>> + Send + 'async_trait>>

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

Get the most recent finalized block hash. Note: needed only in blocks client for finalized block stream; can prolly be removed.

fn stream_all_block_headers<'life0, 'async_trait>( &'life0 self, _hasher: T::Hasher, ) -> Pin<Box<dyn Future<Output = Result<StreamOfResults<(T::Header, BlockRef<HashFor<T>>)>, BackendError>> + Send + 'async_trait>>

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

A stream of all new block headers as they arrive.

fn stream_best_block_headers<'life0, 'async_trait>( &'life0 self, _hasher: T::Hasher, ) -> Pin<Box<dyn Future<Output = Result<StreamOfResults<(T::Header, BlockRef<HashFor<T>>)>, BackendError>> + Send + 'async_trait>>

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

A stream of best block headers.

fn stream_finalized_block_headers<'life0, 'async_trait>( &'life0 self, _hasher: T::Hasher, ) -> Pin<Box<dyn Future<Output = Result<StreamOfResults<(T::Header, BlockRef<HashFor<T>>)>, BackendError>> + Send + 'async_trait>>

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

A stream of finalized block headers.

fn submit_transaction<'life0, 'life1, 'async_trait>( &'life0 self, extrinsic: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = Result<StreamOfResults<TransactionStatus<HashFor<T>>>, BackendError>> + Send + 'async_trait>>

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

Submit a transaction. This will return a stream of events about it.

fn call<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, method: &'life1 str, call_parameters: Option<&'life2 [u8]>, at: HashFor<T>, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>, BackendError>> + Send + 'async_trait>>

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

Make a call to some runtime API.

impl<T: Clone + Config> Clone for ChainHeadBackend<T>

fn clone(&self) -> ChainHeadBackend<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug + Config> Debug for ChainHeadBackend<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.