Struct ServerBitcoinRpcMonitor 

pub struct ServerBitcoinRpcMonitor {
    rpc: DynServerBitcoinRpc,
    status_receiver: Receiver<Option<ServerBitcoinRpcStatus>>,
    chain_id: OnceLock<ChainId>,
}

Fields

rpc: DynServerBitcoinRpc

status_receiver: Receiver<Option<ServerBitcoinRpcStatus>>

chain_id: OnceLock<ChainId>

Cached chain ID (block hash at height 1) - fetched once and never changes

Implementations

impl ServerBitcoinRpcMonitor

pub fn new( rpc: DynServerBitcoinRpc, update_interval: Duration, task_group: &TaskGroup, ) -> Self

async fn fetch_status( rpc: &DynServerBitcoinRpc, ) -> Result<ServerBitcoinRpcStatus>

pub fn get_bitcoin_rpc_config(&self) -> BitcoinRpcConfig

pub fn url(&self) -> SafeUrl

pub fn status(&self) -> Option<ServerBitcoinRpcStatus>

pub fn subscribe_status(&self) -> Receiver<Option<ServerBitcoinRpcStatus>>

Returns a receiver that can be awaited to be notified whenever the status is refreshed.

This lets a consumer react to the monitor’s own polling cadence instead of running an independent timer, which would otherwise read a status that is already up to one update interval stale before sleeping again.

Note the monitor republishes on every update interval regardless of whether the status actually changed, so the receiver fires once per interval rather than only on a real change.

pub async fn get_block(&self, hash: &BlockHash) -> Result<Block>

pub async fn get_mempool_txids(&self) -> Result<Option<Vec<Txid>>>

See IServerBitcoinRpc::get_mempool_txids; None means the backend has no mempool visibility, not that the mempool is empty.

pub async fn get_mempool_tx(&self, txid: &Txid) -> Result<Option<Transaction>>

See IServerBitcoinRpc::get_mempool_tx.

pub async fn get_block_hash(&self, height: u64) -> Result<BlockHash>

pub async fn submit_transaction(&self, tx: Transaction) -> Result<()>

pub async fn get_chain_id(&self) -> Result<ChainId>

Returns the chain ID, caching the result after the first successful fetch.

Trait Implementations

impl Clone for ServerBitcoinRpcMonitor

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ServerBitcoinRpcMonitor

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

Formats the value using the given formatter.