Struct PeerBackend 

pub struct PeerBackend { /* private fields */ }

Implementations

impl PeerBackend

pub async fn new( network: NetworkType, tls: Connector, max_peers: usize, requirement: PeerRequirement, connect_timeout: Duration, request_timeout: Duration, ) -> Result<Self, ChiaQueryError>

pub fn constants(&self) -> &ConsensusConstants

Get the consensus constants for the configured network.

pub async fn has_peers(&self) -> bool

pub async fn peer_count(&self) -> usize

How many peers this backend HOLDS right now — see PeerPool::peer_count.

pub async fn independent_peer_count(&self) -> usize

How many held peers are INDEPENDENT opinions — see PeerPool::independent_peer_count.

pub async fn corroboration_readiness( &self, asked: SocketAddr, ) -> CorroborationReadiness

Whether a corroborated read of an answer given by asked may be attempted at all — see PeerPool::corroboration_readiness. It REFUSES rather than degrading.

pub async fn subscribe_frames(&self, capacity: usize) -> FrameSubscription

Subscribe to the frames arriving on this backend’s pooled sessions.

Falling further behind than capacity ENDS the subscription rather than skipping a frame — see frames::FrameSubscription.

pub async fn try_get_coin_record_by_name( &self, name: &str, ) -> Result<CoinRecord, ChiaQueryError>

pub async fn try_get_coin_record_by_name_opt( &self, name: &str, ) -> Result<OptAnswer<CoinRecord>, ChiaQueryError>

Absence-aware sibling of try_get_coin_record_by_name.

A rejected/timed-out request is a failure -> Err. An EMPTY coin-state list from a successful RespondCoinState is one peer’s WORD that the coin does not exist, which is not the same thing as it not existing, so the answer is graded by OptAnswer rather than flattened into Ok(None) – see read_opt_corroborated (SPEC §3).

pub async fn try_get_coin_spend_opt( &self, coin_id: &str, ) -> Result<OptAnswer<CoinSpend>, ChiaQueryError>

Absence-aware read of the spend that spent coin_id.

A coin that is unknown (no coin-state) and one that is unspent (no spent height) are both “there is no such spend”, and both rest on a peer’s word alone, so both are graded by OptAnswer through read_opt_corroborated. Err only when the peer read itself fails.

pub async fn try_get_coin_records_by_puzzle_hash( &self, puzzle_hash: &str, start_height: Option<u32>, end_height: Option<u32>, include_spent: bool, ) -> Result<Vec<CoinRecord>, ChiaQueryError>

pub async fn try_get_coin_records_by_puzzle_hashes( &self, puzzle_hashes: &[String], start_height: Option<u32>, end_height: Option<u32>, include_spent: bool, ) -> Result<Vec<CoinRecord>, ChiaQueryError>

pub async fn try_get_coin_records_by_hint( &self, hint: &str, start_height: Option<u32>, end_height: Option<u32>, include_spent: bool, ) -> Result<Vec<CoinRecord>, ChiaQueryError>

pub async fn try_get_coin_records_by_hints( &self, hints: &[String], start_height: Option<u32>, end_height: Option<u32>, include_spent: bool, ) -> Result<Vec<CoinRecord>, ChiaQueryError>

pub async fn try_get_coin_records_by_names( &self, names: &[String], ) -> Result<Vec<CoinRecord>, ChiaQueryError>

pub async fn try_get_puzzle_and_solution( &self, coin_id: &str, height: u32, ) -> Result<CoinSpend, ChiaQueryError>

pub async fn try_get_fee_estimate( &self, target_times: &[u64], ) -> Result<FeeEstimate, ChiaQueryError>

pub async fn try_push_tx( &self, bundle: &SpendBundle, ) -> Result<TxStatus, ChiaQueryError>

pub async fn try_get_block_record_by_height( &self, height: u32, ) -> Result<BlockRecord, ChiaQueryError>

pub async fn try_get_additions_and_removals( &self, height: u32, header_hash: &str, ) -> Result<AdditionsAndRemovals, ChiaQueryError>

pub async fn try_get_children( &self, parent_id: &str, ) -> Result<Vec<CoinRecord>, ChiaQueryError>

pub async fn try_get_block_by_height( &self, height: u32, ) -> Result<Value, ChiaQueryError>

pub async fn try_get_additions_and_removals_from_block( &self, height: u32, ) -> Result<AdditionsAndRemovals, ChiaQueryError>

pub async fn try_get_block_spends_by_height( &self, height: u32, ) -> Result<Vec<CoinSpend>, ChiaQueryError>

pub async fn try_get_block_spends_with_conditions( &self, height: u32, ) -> Result<Vec<CoinSpendWithConditions>, ChiaQueryError>

pub async fn try_get_puzzle_and_solution_auto( &self, coin_id: &str, ) -> Result<CoinSpend, ChiaQueryError>

pub async fn try_get_block_records( &self, start: u32, end: u32, ) -> Result<Vec<BlockRecord>, ChiaQueryError>

pub async fn try_get_blocks_range( &self, start: u32, end: u32, ) -> Result<Vec<Value>, ChiaQueryError>

pub fn network_info(&self) -> NetworkInfo

pub fn aggsig_additional_data(&self) -> String

pub fn peak_height(&self) -> u32