pub struct BlokliClient { /* private fields */ }Expand description
Client implementation of the Blokli API.
The client implements the following Blokli API traits:
Implementations§
Source§impl BlokliClient
impl BlokliClient
Sourcepub fn new(base_url: Url, cfg: BlokliClientConfig) -> Self
pub fn new(base_url: Url, cfg: BlokliClientConfig) -> Self
Creates a new instance given Blokli base URL and configuration.
Sourcepub fn config(&self) -> &BlokliClientConfig
pub fn config(&self) -> &BlokliClientConfig
Returns the client’s configuration.
Trait Implementations§
Source§impl BlokliQueryClient for BlokliClient
impl BlokliQueryClient for BlokliClient
Source§fn query_curvy_pending_notes<'life0, 'async_trait>(
&'life0 self,
from_block: Option<u64>,
after: Option<CurvyEventCursor>,
first: u32,
) -> Pin<Box<dyn Future<Output = Result<CurvyPendingNotes, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_curvy_pending_notes<'life0, 'async_trait>(
&'life0 self,
from_block: Option<u64>,
after: Option<CurvyEventCursor>,
first: u32,
) -> Pin<Box<dyn Future<Output = Result<CurvyPendingNotes, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns a chain-ordered page of Curvy pending notes. Read more
Source§fn query_curvy_committed_notes<'life0, 'async_trait>(
&'life0 self,
from_block: Option<u64>,
after: Option<CurvyEventCursor>,
first: u32,
) -> Pin<Box<dyn Future<Output = Result<CurvyCommittedNotes, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_curvy_committed_notes<'life0, 'async_trait>(
&'life0 self,
from_block: Option<u64>,
after: Option<CurvyEventCursor>,
first: u32,
) -> Pin<Box<dyn Future<Output = Result<CurvyCommittedNotes, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns a chain-ordered page of committed Curvy notes.
Source§fn query_curvy_committed_nullifiers<'life0, 'async_trait>(
&'life0 self,
from_block: Option<u64>,
after: Option<CurvyEventCursor>,
first: u32,
) -> Pin<Box<dyn Future<Output = Result<CurvyCommittedNullifiers, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_curvy_committed_nullifiers<'life0, 'async_trait>(
&'life0 self,
from_block: Option<u64>,
after: Option<CurvyEventCursor>,
first: u32,
) -> Pin<Box<dyn Future<Output = Result<CurvyCommittedNullifiers, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns a chain-ordered page of committed Curvy nullifiers.
Source§fn query_curvy_sync_checkpoint<'life0, 'async_trait>(
&'life0 self,
block_hash: Option<String>,
) -> Pin<Box<dyn Future<Output = Result<CurvySyncCheckpoint, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_curvy_sync_checkpoint<'life0, 'async_trait>(
&'life0 self,
block_hash: Option<String>,
) -> Pin<Box<dyn Future<Output = Result<CurvySyncCheckpoint, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns the latest finalized Curvy sync checkpoint, or the checkpoint pinned by block hash.
Source§fn query_curvy_sync_notes<'life0, 'async_trait>(
&'life0 self,
checkpoint: String,
from_index: Option<u64>,
first: u32,
) -> Pin<Box<dyn Future<Output = Result<CurvySyncNotePage, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_curvy_sync_notes<'life0, 'async_trait>(
&'life0 self,
checkpoint: String,
from_index: Option<u64>,
first: u32,
) -> Pin<Box<dyn Future<Output = Result<CurvySyncNotePage, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns a checkpoint-pinned page of dense committed notes.
Source§fn query_curvy_sync_nullifiers<'life0, 'async_trait>(
&'life0 self,
checkpoint: String,
from_index: Option<u64>,
first: u32,
) -> Pin<Box<dyn Future<Output = Result<CurvySyncNullifierPage, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_curvy_sync_nullifiers<'life0, 'async_trait>(
&'life0 self,
checkpoint: String,
from_index: Option<u64>,
first: u32,
) -> Pin<Box<dyn Future<Output = Result<CurvySyncNullifierPage, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns a checkpoint-pinned page of dense committed nullifiers.
Source§fn query_curvy_shard_roots<'life0, 'async_trait>(
&'life0 self,
checkpoint: String,
from_index: Option<u64>,
first: u32,
) -> Pin<Box<dyn Future<Output = Result<CurvyShardRootPage, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_curvy_shard_roots<'life0, 'async_trait>(
&'life0 self,
checkpoint: String,
from_index: Option<u64>,
first: u32,
) -> Pin<Box<dyn Future<Output = Result<CurvyShardRootPage, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns a checkpoint-pinned page of completed notes-tree shard roots.
Source§fn query_curvy_aggregator_state<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<CurvyAggregatorState, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_curvy_aggregator_state<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<CurvyAggregatorState, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Reads current Curvy Aggregator indices and notes-tree root from chain.
Source§fn query_curvy_note_status<'life0, 'async_trait>(
&'life0 self,
note_id: String,
) -> Pin<Box<dyn Future<Output = Result<CurvyNoteStatus, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_curvy_note_status<'life0, 'async_trait>(
&'life0 self,
note_id: String,
) -> Pin<Box<dyn Future<Output = Result<CurvyNoteStatus, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Reads a Curvy note’s raw status from chain.
Source§fn query_curvy_valid_notes_root<'life0, 'async_trait>(
&'life0 self,
root: String,
) -> Pin<Box<dyn Future<Output = Result<bool, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_curvy_valid_notes_root<'life0, 'async_trait>(
&'life0 self,
root: String,
) -> Pin<Box<dyn Future<Output = Result<bool, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Checks whether a Curvy notes-tree root is valid.
Source§fn query_curvy_nullifier_spent<'life0, 'async_trait>(
&'life0 self,
nullifier: String,
) -> Pin<Box<dyn Future<Output = Result<bool, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_curvy_nullifier_spent<'life0, 'async_trait>(
&'life0 self,
nullifier: String,
) -> Pin<Box<dyn Future<Output = Result<bool, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Checks whether a Curvy nullifier has already been spent.
Source§fn query_curvy_vault_fees<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<CurvyVaultFees, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_curvy_vault_fees<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<CurvyVaultFees, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Reads Curvy Vault protocol-level fees.
Source§fn query_curvy_aggregator_fees<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<CurvyAggregatorFees, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_curvy_aggregator_fees<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<CurvyAggregatorFees, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Reads Curvy Aggregator proof fee configuration.
Source§fn query_curvy_vault_token_count<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<CurvyVaultTokenCount, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_curvy_vault_token_count<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<CurvyVaultTokenCount, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Reads the number of registered Curvy Vault tokens.
Source§fn query_curvy_vault_token<'life0, 'async_trait>(
&'life0 self,
token_id: String,
) -> Pin<Box<dyn Future<Output = Result<CurvyVaultToken, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_curvy_vault_token<'life0, 'async_trait>(
&'life0 self,
token_id: String,
) -> Pin<Box<dyn Future<Output = Result<CurvyVaultToken, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Reads one Curvy Vault token and its gas fee configuration.
Source§fn query_curvy_entry_portal_address<'life0, 'async_trait>(
&'life0 self,
owner_hash: String,
recovery: String,
) -> Pin<Box<dyn Future<Output = Result<String, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_curvy_entry_portal_address<'life0, 'async_trait>(
&'life0 self,
owner_hash: String,
recovery: String,
) -> Pin<Box<dyn Future<Output = Result<String, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Derives a Curvy entry portal address.
Source§fn query_curvy_exit_portal_address<'life0, 'async_trait>(
&'life0 self,
exit_address: String,
exit_chain_id: String,
recovery: String,
) -> Pin<Box<dyn Future<Output = Result<String, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_curvy_exit_portal_address<'life0, 'async_trait>(
&'life0 self,
exit_address: String,
exit_chain_id: String,
recovery: String,
) -> Pin<Box<dyn Future<Output = Result<String, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Derives a Curvy exit portal address.
Source§fn query_curvy_portal_registered<'life0, 'async_trait>(
&'life0 self,
portal_address: String,
) -> Pin<Box<dyn Future<Output = Result<bool, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_curvy_portal_registered<'life0, 'async_trait>(
&'life0 self,
portal_address: String,
) -> Pin<Box<dyn Future<Output = Result<bool, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Checks whether a portal is registered with Curvy PortalFactory.
Source§fn count_accounts<'life0, 'async_trait>(
&'life0 self,
selector: AccountSelector,
) -> Pin<Box<dyn Future<Output = Result<u32, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn count_accounts<'life0, 'async_trait>(
&'life0 self,
selector: AccountSelector,
) -> Pin<Box<dyn Future<Output = Result<u32, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Counts accounts matching the given
AccountSelector. Read moreSource§fn query_accounts<'life0, 'async_trait>(
&'life0 self,
selector: AccountSelector,
) -> Pin<Box<dyn Future<Output = Result<Vec<Account>, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_accounts<'life0, 'async_trait>(
&'life0 self,
selector: AccountSelector,
) -> Pin<Box<dyn Future<Output = Result<Vec<Account>, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns accounts matching the given
AccountSelector. Read moreSource§fn query_native_balance<'life0, 'life1, 'async_trait>(
&'life0 self,
address: &'life1 ChainAddress,
) -> Pin<Box<dyn Future<Output = Result<NativeBalance, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn query_native_balance<'life0, 'life1, 'async_trait>(
&'life0 self,
address: &'life1 ChainAddress,
) -> Pin<Box<dyn Future<Output = Result<NativeBalance, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Returns the native-chain balance for an account or safe address. Read more
Source§fn query_token_balance<'life0, 'life1, 'async_trait>(
&'life0 self,
address: &'life1 ChainAddress,
token: Token,
) -> Pin<Box<dyn Future<Output = Result<HoprBalance, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn query_token_balance<'life0, 'life1, 'async_trait>(
&'life0 self,
address: &'life1 ChainAddress,
token: Token,
) -> Pin<Box<dyn Future<Output = Result<HoprBalance, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Returns the HOPR token balance for an account or safe address.
Source§fn query_transaction_count<'life0, 'life1, 'async_trait>(
&'life0 self,
address: &'life1 ChainAddress,
) -> Pin<Box<dyn Future<Output = Result<u64, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn query_transaction_count<'life0, 'life1, 'async_trait>(
&'life0 self,
address: &'life1 ChainAddress,
) -> Pin<Box<dyn Future<Output = Result<u64, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Returns the number of indexed transactions sent from the given address.
Source§fn query_safe_allowance<'life0, 'life1, 'async_trait>(
&'life0 self,
address: &'life1 ChainAddress,
) -> Pin<Box<dyn Future<Output = Result<SafeHoprAllowance, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn query_safe_allowance<'life0, 'life1, 'async_trait>(
&'life0 self,
address: &'life1 ChainAddress,
) -> Pin<Box<dyn Future<Output = Result<SafeHoprAllowance, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Returns the HOPR token allowance configured for a safe address.
Source§fn query_redeemed_stats<'life0, 'async_trait>(
&'life0 self,
selector: RedeemedStatsSelector,
) -> Pin<Box<dyn Future<Output = Result<RedeemedStats, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_redeemed_stats<'life0, 'async_trait>(
&'life0 self,
selector: RedeemedStatsSelector,
) -> Pin<Box<dyn Future<Output = Result<RedeemedStats, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns redeemed and rejected ticket aggregates filtered by safe, node, or both. Read more
Source§fn query_safe<'life0, 'async_trait>(
&'life0 self,
selector: SafeSelector,
) -> Pin<Box<dyn Future<Output = Result<Vec<Safe>, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_safe<'life0, 'async_trait>(
&'life0 self,
selector: SafeSelector,
) -> Pin<Box<dyn Future<Output = Result<Vec<Safe>, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns deployed safes matching the given
SafeSelector.Source§fn query_module_address_prediction<'life0, 'async_trait>(
&'life0 self,
input: ModulePredictionInput,
) -> Pin<Box<dyn Future<Output = Result<ChainAddress, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_module_address_prediction<'life0, 'async_trait>(
&'life0 self,
input: ModulePredictionInput,
) -> Pin<Box<dyn Future<Output = Result<ChainAddress, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns the predicted module address for the given safe deployment data.
Source§fn count_channels<'life0, 'async_trait>(
&'life0 self,
selector: ChannelSelector,
) -> Pin<Box<dyn Future<Output = Result<u32, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn count_channels<'life0, 'async_trait>(
&'life0 self,
selector: ChannelSelector,
) -> Pin<Box<dyn Future<Output = Result<u32, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
👎Deprecated since 0.22.0:
Use query_channel_stats instead, which returns both count and total wxHOPR balance.
Counts channels matching the given
ChannelSelector. Read moreSource§fn query_channel_stats<'life0, 'async_trait>(
&'life0 self,
selector: ChannelSelector,
) -> Pin<Box<dyn Future<Output = Result<ChannelStats, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_channel_stats<'life0, 'async_trait>(
&'life0 self,
selector: ChannelSelector,
) -> Pin<Box<dyn Future<Output = Result<ChannelStats, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns channel count and total wxHOPR balance matching the given
ChannelSelector. Read moreSource§fn query_channels<'life0, 'async_trait>(
&'life0 self,
selector: ChannelSelector,
) -> Pin<Box<dyn Future<Output = Result<ChannelsList, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_channels<'life0, 'async_trait>(
&'life0 self,
selector: ChannelSelector,
) -> Pin<Box<dyn Future<Output = Result<ChannelsList, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns channels matching the given
ChannelSelector. Read moreSource§fn count_services<'life0, 'async_trait>(
&'life0 self,
selector: ServiceSelector,
) -> Pin<Box<dyn Future<Output = Result<u32, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn count_services<'life0, 'async_trait>(
&'life0 self,
selector: ServiceSelector,
) -> Pin<Box<dyn Future<Output = Result<u32, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Counts service registry entries matching the given
ServiceSelector. Read moreSource§fn query_services<'life0, 'async_trait>(
&'life0 self,
selector: ServiceSelector,
) -> Pin<Box<dyn Future<Output = Result<Vec<ServiceEntry>, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_services<'life0, 'async_trait>(
&'life0 self,
selector: ServiceSelector,
) -> Pin<Box<dyn Future<Output = Result<Vec<ServiceEntry>, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns service registry entries matching the given
ServiceSelector. Read moreSource§fn query_live_services<'life0, 'async_trait>(
&'life0 self,
selector: ServiceSelector,
) -> Pin<Box<dyn Future<Output = Result<Vec<ServiceEntry>, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_live_services<'life0, 'async_trait>(
&'life0 self,
selector: ServiceSelector,
) -> Pin<Box<dyn Future<Output = Result<Vec<ServiceEntry>, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns only entries whose node is currently bound in the NodeSafeRegistry selected by the
service registry itself.
Source§fn query_service_types<'life0, 'async_trait>(
&'life0 self,
service_type: Option<ServiceTypeId>,
) -> Pin<Box<dyn Future<Output = Result<Vec<ServiceTypeInfo>, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_service_types<'life0, 'async_trait>(
&'life0 self,
service_type: Option<ServiceTypeId>,
) -> Pin<Box<dyn Future<Output = Result<Vec<ServiceTypeInfo>, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns service type configuration, optionally restricted to a single type. Read more
Source§fn query_service_registry_config<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<ServiceRegistryConfig, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_service_registry_config<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<ServiceRegistryConfig, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns the current registry-wide type registration fee and node-safe registry pointer. Read more
Source§fn query_transaction_status<'life0, 'async_trait>(
&'life0 self,
tx_id: TxId,
) -> Pin<Box<dyn Future<Output = Result<Transaction, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_transaction_status<'life0, 'async_trait>(
&'life0 self,
tx_id: TxId,
) -> Pin<Box<dyn Future<Output = Result<Transaction, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns the latest known status for a tracked transaction id. Read more
Source§fn query_chain_info<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<ChainInfo, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_chain_info<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<ChainInfo, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns chain, contract, fee, ticket, and timing parameters reported by Blokli.
Source§fn query_version<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<String, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_version<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<String, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns the Blokli server version string.
Source§fn query_health<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<String, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_health<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<String, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns the current health state as reported by the legacy health query.
Source§fn query_compatibility<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<Compatibility, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_compatibility<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<Compatibility, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Queries server compatibility information. Read more
Source§fn query_safes_balance<'life0, 'async_trait>(
&'life0 self,
owner_address: Option<ChainAddress>,
) -> Pin<Box<dyn Future<Output = Result<SafesBalance, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn query_safes_balance<'life0, 'async_trait>(
&'life0 self,
owner_address: Option<ChainAddress>,
) -> Pin<Box<dyn Future<Output = Result<SafesBalance, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns the total wxHOPR balance held across indexed safe contracts. Read more
Source§impl BlokliSubscriptionClient for BlokliClient
impl BlokliSubscriptionClient for BlokliClient
Source§fn subscribe_channels(
&self,
selector: ChannelSelector,
) -> Result<impl Stream<Item = Result<Channel, BlokliClientError>> + Send, BlokliClientError>
fn subscribe_channels( &self, selector: ChannelSelector, ) -> Result<impl Stream<Item = Result<Channel, BlokliClientError>> + Send, BlokliClientError>
Streams channel updates matching the given
ChannelSelector. Read moreSource§fn subscribe_accounts(
&self,
selector: AccountSelector,
) -> Result<impl Stream<Item = Result<Account, BlokliClientError>> + Send, BlokliClientError>
fn subscribe_accounts( &self, selector: AccountSelector, ) -> Result<impl Stream<Item = Result<Account, BlokliClientError>> + Send, BlokliClientError>
Streams account updates matching the given
AccountSelector. Read moreSource§fn subscribe_graph(
&self,
) -> Result<impl Stream<Item = Result<OpenedChannelsGraphEntry, BlokliClientError>> + Send, BlokliClientError>
fn subscribe_graph( &self, ) -> Result<impl Stream<Item = Result<OpenedChannelsGraphEntry, BlokliClientError>> + Send, BlokliClientError>
Streams updates for the open-channel graph. Read more
Source§fn subscribe_ticket_params(
&self,
) -> Result<impl Stream<Item = Result<TicketParameters, BlokliClientError>> + Send, BlokliClientError>
fn subscribe_ticket_params( &self, ) -> Result<impl Stream<Item = Result<TicketParameters, BlokliClientError>> + Send, BlokliClientError>
Streams updates of ticket price and winning-probability parameters.
Source§fn subscribe_health(
&self,
) -> Result<impl Stream<Item = Result<ReadinessState, BlokliClientError>> + Send, BlokliClientError>
fn subscribe_health( &self, ) -> Result<impl Stream<Item = Result<ReadinessState, BlokliClientError>> + Send, BlokliClientError>
Streams readiness updates for the Blokli instance.
Source§fn subscribe_safe_deployments(
&self,
) -> Result<impl Stream<Item = Result<Safe, BlokliClientError>> + Send, BlokliClientError>
fn subscribe_safe_deployments( &self, ) -> Result<impl Stream<Item = Result<Safe, BlokliClientError>> + Send, BlokliClientError>
Streams on-chain safe deployments indexed by Blokli.
Source§fn subscribe_services(
&self,
selector: ServiceSelector,
) -> Result<impl Stream<Item = Result<ServiceUpdate, BlokliClientError>> + Send, BlokliClientError>
fn subscribe_services( &self, selector: ServiceSelector, ) -> Result<impl Stream<Item = Result<ServiceUpdate, BlokliClientError>> + Send, BlokliClientError>
Streams changes to service registry entries matching the given
ServiceSelector. Read moreSource§fn subscribe_service_types(
&self,
service_type: Option<ServiceTypeId>,
) -> Result<impl Stream<Item = Result<ServiceTypeUpdate, BlokliClientError>> + Send, BlokliClientError>
fn subscribe_service_types( &self, service_type: Option<ServiceTypeId>, ) -> Result<impl Stream<Item = Result<ServiceTypeUpdate, BlokliClientError>> + Send, BlokliClientError>
Streams changes to service type and registry-wide configuration. Read more
Source§fn subscribe_service_registry_config(
&self,
) -> Result<impl Stream<Item = Result<ServiceRegistryConfig, BlokliClientError>> + Send + 'static, BlokliClientError>
fn subscribe_service_registry_config( &self, ) -> Result<impl Stream<Item = Result<ServiceRegistryConfig, BlokliClientError>> + Send + 'static, BlokliClientError>
Streams the complete registry-wide configuration. Read more
Source§fn subscribe_track_transaction(
&self,
tx_id: TxId,
) -> Result<impl Stream<Item = Result<Transaction, BlokliClientError>> + Send, BlokliClientError>
fn subscribe_track_transaction( &self, tx_id: TxId, ) -> Result<impl Stream<Item = Result<Transaction, BlokliClientError>> + Send, BlokliClientError>
Streams status updates for a tracked transaction id. Read more
Source§fn subscribe_ticket_redeemed(
&self,
selector: TicketSelector,
) -> Result<impl Stream<Item = Result<RedeemTicketDetails, BlokliClientError>> + Send, BlokliClientError>
fn subscribe_ticket_redeemed( &self, selector: TicketSelector, ) -> Result<impl Stream<Item = Result<RedeemTicketDetails, BlokliClientError>> + Send, BlokliClientError>
Subscribes to on-chain ticket redemption events matching the given
TicketSelector. Read moreSource§fn subscribe_curvy_pending_notes(
&self,
from_block: Option<u64>,
) -> Result<impl Stream<Item = Result<CurvyPendingNote, BlokliClientError>> + Send, BlokliClientError>
fn subscribe_curvy_pending_notes( &self, from_block: Option<u64>, ) -> Result<impl Stream<Item = Result<CurvyPendingNote, BlokliClientError>> + Send, BlokliClientError>
Streams all pending Curvy notes from an optional inclusive block. Read more
Source§fn subscribe_curvy_committed_notes(
&self,
from_block: Option<u64>,
) -> Result<impl Stream<Item = Result<CurvyCommittedNote, BlokliClientError>> + Send, BlokliClientError>
fn subscribe_curvy_committed_notes( &self, from_block: Option<u64>, ) -> Result<impl Stream<Item = Result<CurvyCommittedNote, BlokliClientError>> + Send, BlokliClientError>
Streams all committed Curvy notes from an optional inclusive block. Read more
Source§fn subscribe_curvy_committed_nullifiers(
&self,
from_block: Option<u64>,
) -> Result<impl Stream<Item = Result<CurvyCommittedNullifier, BlokliClientError>> + Send, BlokliClientError>
fn subscribe_curvy_committed_nullifiers( &self, from_block: Option<u64>, ) -> Result<impl Stream<Item = Result<CurvyCommittedNullifier, BlokliClientError>> + Send, BlokliClientError>
Streams committed Curvy nullifiers from an optional inclusive block.
Source§impl BlokliTransactionClient for BlokliClient
impl BlokliTransactionClient for BlokliClient
Source§fn submit_transaction<'life0, 'life1, 'async_trait>(
&'life0 self,
signed_tx: &'life1 [u8],
) -> Pin<Box<dyn Future<Output = Result<TxReceipt, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn submit_transaction<'life0, 'life1, 'async_trait>(
&'life0 self,
signed_tx: &'life1 [u8],
) -> Pin<Box<dyn Future<Output = Result<TxReceipt, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Submits a signed transaction and returns the on-chain transaction hash reported by Blokli. Read more
Source§fn submit_and_track_transaction<'life0, 'life1, 'async_trait>(
&'life0 self,
signed_tx: &'life1 [u8],
) -> Pin<Box<dyn Future<Output = Result<TxId, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn submit_and_track_transaction<'life0, 'life1, 'async_trait>(
&'life0 self,
signed_tx: &'life1 [u8],
) -> Pin<Box<dyn Future<Output = Result<TxId, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Submits a signed transaction and returns a Blokli tracking id. Read more
Source§fn submit_and_confirm_transaction<'life0, 'life1, 'async_trait>(
&'life0 self,
signed_tx: &'life1 [u8],
num_confirmations: usize,
) -> Pin<Box<dyn Future<Output = Result<TxReceipt, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn submit_and_confirm_transaction<'life0, 'life1, 'async_trait>(
&'life0 self,
signed_tx: &'life1 [u8],
num_confirmations: usize,
) -> Pin<Box<dyn Future<Output = Result<TxReceipt, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Submits a signed transaction and waits for the requested number of confirmations. Read more
Source§fn track_transaction<'life0, 'async_trait>(
&'life0 self,
tx_id: TxId,
client_timeout: Duration,
) -> Pin<Box<dyn Future<Output = Result<Transaction, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn track_transaction<'life0, 'async_trait>(
&'life0 self,
tx_id: TxId,
client_timeout: Duration,
) -> Pin<Box<dyn Future<Output = Result<Transaction, BlokliClientError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Tracks the transaction given the
tx_id previously returned
by submit_and_track_transaction until it is confirmed
or fails.Source§impl Clone for BlokliClient
impl Clone for BlokliClient
Source§fn clone(&self) -> BlokliClient
fn clone(&self) -> BlokliClient
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl Freeze for BlokliClient
impl RefUnwindSafe for BlokliClient
impl Send for BlokliClient
impl Sync for BlokliClient
impl Unpin for BlokliClient
impl UnsafeUnpin for BlokliClient
impl UnwindSafe for BlokliClient
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more