Struct RetryClient

pub struct RetryClient<C> {
    pub(crate) inner: C,
    pub(crate) task_handle: TaskHandle,
}

Wrapper around IBitcoindRpc that will retry failed calls

Fields

inner: C

task_handle: TaskHandle

Implementations

impl<C> RetryClient<C>

pub fn new(inner: C, task_handle: TaskHandle) -> Self

pub(crate) async fn retry_call<T, F, R>(&self, call_fn: F) -> Result<T>

where F: Fn() -> R, R: Future<Output = Result<T>>,

Retries with an exponential backoff from RETRY_SLEEP_MIN_MS to RETRY_SLEEP_MAX_MS

Trait Implementations

impl<C: Debug> Debug for RetryClient<C>

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

Formats the value using the given formatter.

impl<C> IBitcoindRpc for RetryClient<C>

where C: IBitcoindRpc + Sync + Send,

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

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

Returns the Bitcoin network the node is connected to

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

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

Returns the current block count

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

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

Returns the block hash at a given height

fn get_fee_rate<'life0, 'async_trait>( &'life0 self, confirmation_target: u16, ) -> Pin<Box<dyn Future<Output = Result<Option<Feerate>>> + Send + 'async_trait>>

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

Estimates the fee rate for a given confirmation target. Make sure that all federation members use the same algorithm to avoid widely diverging results. If the node is not ready yet to return a fee rate estimation this function returns None.

fn submit_transaction<'life0, 'async_trait>( &'life0 self, transaction: Transaction, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Submits a transaction to the Bitcoin network

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

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

If a transaction is included in a block, returns the block height. Note: calling this method with bitcoind as a backend must first call watch_script_history or run bitcoind with txindex enabled.

fn is_tx_in_block<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, txid: &'life1 Txid, block_hash: &'life2 BlockHash, block_height: u64, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Check if a transaction is included in a block

fn watch_script_history<'life0, 'life1, 'async_trait>( &'life0 self, script: &'life1 ScriptBuf, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Watches for a script and returns any transactions associated with it

fn get_script_history<'life0, 'life1, 'async_trait>( &'life0 self, script: &'life1 ScriptBuf, ) -> Pin<Box<dyn Future<Output = Result<Vec<Transaction>>> + Send + 'async_trait>>

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

Get script transaction history

fn get_txout_proof<'life0, 'async_trait>( &'life0 self, txid: Txid, ) -> Pin<Box<dyn Future<Output = Result<TxOutProof>> + Send + 'async_trait>>

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

Returns a proof that a tx is included in the bitcoin blockchain

fn get_bitcoin_rpc_config(&self) -> BitcoinRpcConfig

Returns the Bitcoin RPC config