Struct BlockchainClient

pub struct BlockchainClient {
    pub http_url: String,
    /* private fields */
}

Fields

http_url: String

Implementations

impl BlockchainClient

pub async fn new_http( http_url: &str, timeout: Duration, max_response_size_bytes: u32, ) -> Result<Self>

Creates a new RPC client connected only to HTTP.

pub async fn new_http_ws( http_url: &str, ws_url: Option<&str>, timeout: Duration, max_response_size_bytes: u32, ) -> Result<Self>

Creates a new RPC client connected to HTTP and optionally to WS.

pub fn supports_ws(&self) -> bool

Checks if the supports websocket connection.

pub async fn fetch_listening(&self) -> Result<()>

Checks if the blockchain is listening.

pub async fn fetch_block_number(&self) -> Result<BlockNumber>

Fetches the current block number.

pub async fn fetch_block_and_receipts( &self, block_number: BlockNumber, ) -> Result<Option<ExternalBlockWithReceipts>>

Fetches a block by number with receipts.

pub async fn fetch_block( &self, block_number: BlockNumber, ) -> Result<Option<ExternalBlock>>

Fetches a block by number.

pub async fn fetch_transaction( &self, tx_hash: Hash, ) -> Result<Option<AlloyTransaction>>

Fetches a transaction by hash.

pub async fn fetch_receipt( &self, tx_hash: Hash, ) -> Result<Option<ExternalReceipt>>

Fetches a receipt by hash.

pub async fn fetch_balance( &self, address: Address, block_number: Option<BlockNumber>, ) -> Result<Wei>

Fetches account balance by address and block number.

pub async fn fetch_replication_log( &self, block_number: BlockNumber, ) -> Result<Option<ReplicationLogRocksdb>>

Returns the external replication log if found.

pub async fn send_raw_transaction_to_leader( &self, tx: AlloyBytes, rpc_client: &RpcClientApp, ) -> Result<Hash, StratusError>

Forwards a transaction to leader.

pub async fn subscribe_new_heads(&self) -> Result<Subscription<ExternalBlock>>

Trait Implementations

impl Debug for BlockchainClient

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

Formats the value using the given formatter.