Struct RpcOperations

pub struct RpcOperations<P: JsonRpcClient + 'static> { /* private fields */ }

Implementation of HoprRpcOperations and HoprIndexerRpcOperations trait via ethers

Implementations

impl<P: JsonRpcClient + 'static> RpcOperations<P>

pub fn new( json_rpc: P, chain_key: &ChainKeypair, cfg: RpcOperationsConfig, ) -> Result<Self>

Trait Implementations

impl<P: JsonRpcClient> Clone for RpcOperations<P>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<P: Debug + JsonRpcClient + 'static> Debug for RpcOperations<P>

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

Formats the value using the given formatter.

impl<P: JsonRpcClient + 'static> HoprIndexerRpcOperations for RpcOperations<P>

fn block_number<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

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

Retrieves the latest block number.

fn try_stream_logs<'a>( &'a self, start_block_number: u64, filter: LogFilter, ) -> Result<Pin<Box<dyn Stream<Item = BlockWithLogs> + Send + 'a>>>

Starts streaming logs from the given start_block_number. If no start_block_number is given, the stream starts from the latest block. The given filter are applied to retrieve the logs, the function fails if the filter is empty. The streaming stops only when the corresponding channel is closed by the returned receiver.

impl<P: JsonRpcClient + 'static> HoprRpcOperations for RpcOperations<P>

fn get_timestamp<'life0, 'async_trait>( &'life0 self, block_number: u64, ) -> Pin<Box<dyn Future<Output = Result<Option<u64>>> + Send + 'async_trait>>

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

Retrieves the timestamp from the given block number.

fn get_balance<'life0, 'async_trait>( &'life0 self, address: Address, balance_type: BalanceType, ) -> Pin<Box<dyn Future<Output = Result<Balance>> + Send + 'async_trait>>

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

Retrieves the node’s account balance of the given type.

fn get_eligibility_status<'life0, 'async_trait>( &'life0 self, address: Address, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Retrieves the node’s eligibility status

fn get_node_management_module_target_info<'life0, 'async_trait>( &'life0 self, target: Address, ) -> Pin<Box<dyn Future<Output = Result<Option<U256>>> + Send + 'async_trait>>

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

Retrieves info of the given node module’s target.

fn get_safe_from_node_safe_registry<'life0, 'async_trait>( &'life0 self, node_address: Address, ) -> Pin<Box<dyn Future<Output = Result<Address>> + Send + 'async_trait>>

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

Retrieves safe address of the given node address from the registry.

fn get_module_target_address<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Address>> + Send + 'async_trait>>

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

Retrieves target address of the node module.

fn get_channel_closure_notice_period<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Duration>> + Send + 'async_trait>>

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

Retrieves the notice period of channel closure from the Channels contract.

fn check_node_safe_module_status<'life0, 'async_trait>( &'life0 self, node_address: Address, ) -> Pin<Box<dyn Future<Output = Result<NodeSafeModuleStatus>> + Send + 'async_trait>>

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

Retrieves the on-chain status of node, safe, and module.

fn send_transaction<'life0, 'async_trait>( &'life0 self, tx: TypedTransaction, ) -> Pin<Box<dyn Future<Output = Result<PendingTransaction<'_>>> + Send + 'async_trait>>

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

Sends transaction to the RPC provider.