Struct MiningManagerProxy 

pub struct MiningManagerProxy { /* private fields */ }

Async proxy for the mining manager

Implementations

impl MiningManagerProxy

pub fn new(inner: Arc<MiningManager>) -> Self

pub async fn get_block_template( self, consensus: &ConsensusProxy, miner_data: MinerData, ) -> MiningManagerResult<BlockTemplate>

pub async fn get_realtime_feerate_estimations(self) -> FeerateEstimations

Returns realtime feerate estimations based on internal mempool state

pub async fn get_realtime_feerate_estimations_verbose( self, consensus: &ConsensusProxy, prefix: Prefix, ) -> MiningManagerResult<FeeEstimateVerbose>

Returns realtime feerate estimations based on internal mempool state with additional verbose data

pub async fn validate_and_insert_transaction( self, consensus: &ConsensusProxy, transaction: Transaction, priority: Priority, orphan: Orphan, rbf_policy: RbfPolicy, ) -> MiningManagerResult<TransactionInsertion>

Validates a transaction and adds it to the set of known transactions that have not yet been added to any block.

The validation is constrained by a Replace by fee policy applied to double spends in the mempool. For more information, see RbfPolicy.

The returned transactions are references of objects owned by the mempool.

pub async fn validate_and_insert_transaction_batch( self, consensus: &ConsensusProxy, transactions: Vec<Transaction>, priority: Priority, orphan: Orphan, rbf_policy: RbfPolicy, ) -> Vec<MiningManagerResult<Arc<Transaction>>>

Validates a batch of transactions, handling iteratively only the independent ones, and adds those to the set of known transactions that have not yet been added to any block.

The validation is constrained by a Replace by fee policy applied to double spends in the mempool. For more information, see RbfPolicy.

Returns transactions that where unorphaned following the insertion of the provided transactions. The returned transactions are references of objects owned by the mempool.

pub async fn handle_new_block_transactions( self, consensus: &ConsensusProxy, block_daa_score: u64, block_transactions: Arc<Vec<Transaction>>, ) -> MiningManagerResult<Vec<Arc<Transaction>>>

pub async fn expire_low_priority_transactions(self, consensus: &ConsensusProxy)

pub async fn revalidate_high_priority_transactions( self, consensus: &ConsensusProxy, transaction_ids_sender: UnboundedSender<Vec<TransactionId>>, )

pub async fn get_transaction( self, transaction_id: TransactionId, query: TransactionQuery, ) -> Option<MutableTransaction>

Try to return a mempool transaction by its id.

Note: the transaction is an orphan if tx.is_fully_populated() returns false.

pub async fn has_transaction( self, transaction_id: TransactionId, query: TransactionQuery, ) -> bool

Returns whether the mempool holds this transaction in any form.

pub async fn transaction_count(self, query: TransactionQuery) -> usize

pub async fn get_all_transactions( self, query: TransactionQuery, ) -> (Vec<MutableTransaction>, Vec<MutableTransaction>)

pub async fn get_transactions_by_addresses( self, script_public_keys: ScriptPublicKeySet, query: TransactionQuery, ) -> GroupedOwnerTransactions

get_transactions_by_addresses returns the sending and receiving transactions for a set of addresses.

Note: a transaction is an orphan if tx.is_fully_populated() returns false.

pub async fn has_accepted_transaction( self, transaction_id: TransactionId, ) -> bool

Returns whether a transaction id was registered as accepted in the mempool, meaning that the consensus accepted a block containing it and said block was handled by the mempool.

Registered transaction ids expire after a delay and are unregistered from the mempool. So a returned value of true means with certitude that the transaction was accepted and a false means either the transaction was never accepted or it was but beyond the expiration delay.

pub async fn unaccepted_transactions( self, transactions: Vec<TransactionId>, ) -> Vec<TransactionId>

Returns a vector of unaccepted transactions. For more details, see Self::has_accepted_transaction().

pub async fn unknown_transactions( self, transactions: Vec<TransactionId>, ) -> Vec<TransactionId>

Returns a vector with all transaction ids that are neither in the mempool, nor in the orphan pool nor accepted.

pub fn snapshot(&self) -> MempoolCountersSnapshot

pub fn p2p_tx_count_sample(&self) -> P2pTxCountSample

pub fn transaction_count_sample(&self, query: TransactionQuery) -> u64

Returns a recent sample of transaction count which is not necessarily accurate but is updated enough for being used as a stats/metric

Trait Implementations

impl Clone for MiningManagerProxy

fn clone(&self) -> MiningManagerProxy

Returns a duplicate of the value.

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

Performs copy-assignment from source.