Struct fuel_txpool::service::TxPoolService

pub struct TxPoolService { /* private fields */ }

Implementations

impl TxPoolService

pub fn new(db: Box<dyn TxPoolDb>, config: Arc<Config>) -> Self

Trait Implementations

impl TxPool for TxPoolService

fn insert<'life0, 'async_trait>(
    &'life0 self,
    txs: Vec<ArcTx>
) -> Pin<Box<dyn Future<Output = Vec<Result<Vec<ArcTx>>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

import tx

fn find<'life0, 'life1, 'async_trait>(
    &'life0 self,
    hashes: &'life1 [TxId]
) -> Pin<Box<dyn Future<Output = Vec<Option<ArcTx>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

find all tx by its hash

fn find_dependent<'life0, 'life1, 'async_trait>(
    &'life0 self,
    hashes: &'life1 [TxId]
) -> Pin<Box<dyn Future<Output = Vec<ArcTx>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

find all dependent tx and return them with requsted dependencies in one list sorted by Price.

fn filter_by_negative<'life0, 'life1, 'async_trait>(
    &'life0 self,
    tx_ids: &'life1 [TxId]
) -> Pin<Box<dyn Future<Output = Vec<TxId>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Iterete over hashes and return all hashes that we dont have.

fn includable<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = Vec<ArcTx>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Return all sorted transactions that are includable in next block. This is going to be heavy operation, use it with only when needed.

fn block_update<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

When block is updated we need to receive all spend outputs and remove them from txpool

fn remove<'life0, 'life1, 'async_trait>(
    &'life0 self,
    tx_ids: &'life1 [TxId]
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

remove transaction from pool needed on user demand. Low priority

fn find_one<'life0, 'life1, 'async_trait>(
    &'life0 self,
    hash: &'life1 TxId
) -> Pin<Box<dyn Future<Output = Option<ArcTx>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

find one tx by its hash

fn subscribe<'life0, 'async_trait>(
    &'life0 self,
    sub: Arc<dyn Subscriber>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait,