Struct zebra_rpc::queue::Runner

pub struct Runner {
    queue: Queue,
    receiver: Receiver<UnminedTx>,
    tip_height: Height,
}

The runner will make the processing of the transactions in the queue.

Fields

queue: Queue

receiver: Receiver<UnminedTx>

tip_height: Height

Implementations

impl Runner

fn transactions_as_hash_set(&self) -> HashSet<UnminedTxId>

Get the queue transactions as a HashSet of unmined ids.

fn transactions_as_vec(&self) -> Vec<Arc<Transaction>>

Get the queue transactions as a Vec of transactions.

pub fn update_tip_height(&mut self, height: Height)

Update the tip_height field with a new height.

pub async fn run<Mempool, State, Tip>( self, mempool: Mempool, state: State, tip: Tip, network: Network, )

where Mempool: Service<Request, Response = Response, Error = BoxError> + Clone + 'static, State: Service<ReadRequest, Response = ReadResponse, Error = BoxError> + Clone + Send + Sync + 'static, Tip: ChainTip + Clone + Send + Sync + 'static,

Retry sending to mempool if needed.

Creates a loop that will run each time a new block is mined. In this loop, get the transactions that are in the queue and:

• Check if they are now in the mempool and if so, delete the transaction from the queue.
• Check if the transaction is now part of a block in the state and if so, delete the transaction from the queue.
• With the transactions left in the queue, retry sending them to the mempool ignoring the result of this operation.

Additionally, each iteration of the above loop, will receive and insert to the queue transactions that are pending in the channel.

fn remove_expired(&mut self, spacing: Duration)

Remove transactions that are expired according to number of blocks and current spacing between blocks.

fn remove_committed(&mut self, to_remove: HashSet<UnminedTxId>)

Remove transactions from the queue that had been inserted to the state or the mempool.

async fn check_mempool<Mempool>( mempool: Mempool, transactions: HashSet<UnminedTxId>, ) -> HashSet<UnminedTxId>

where Mempool: Service<Request, Response = Response, Error = BoxError> + Clone + 'static,

Check the mempool for given transactions.

Returns transactions that are in the mempool.

async fn check_state<State>( state: State, transactions: HashSet<UnminedTxId>, ) -> HashSet<UnminedTxId>

where State: Service<ReadRequest, Response = ReadResponse, Error = BoxError> + Clone + Send + Sync + 'static,

Check the state for given transactions.

Returns transactions that are in the state.

async fn retry<Mempool>( mempool: Mempool, transactions: Vec<Arc<Transaction>>, ) -> HashSet<UnminedTxId>

where Mempool: Service<Request, Response = Response, Error = BoxError> + Clone + 'static,

Retry sending given transactions to mempool.

Returns the transaction ids that were retried.

Trait Implementations

impl Debug for Runner

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

Formats the value using the given formatter.