Struct DefaultCellCollector 

pub struct DefaultCellCollector {
    pub indexer_client: IndexerRpcAsyncClient,
    pub ckb_client: CkbRpcAsyncClient,
    pub offchain: OffchainCellCollector,
    pub acceptable_indexer_leftbehind: u64,
}

A cell collector use ckb-indexer as backend

Fields

indexer_client: IndexerRpcAsyncClient

ckb_client: CkbRpcAsyncClient

offchain: OffchainCellCollector

acceptable_indexer_leftbehind: u64

Implementations

impl DefaultCellCollector

pub fn new(ckb_client: &str) -> DefaultCellCollector

pub fn new_with_timeout( ckb_client: &str, timeout: Duration, ) -> Result<Self, Error>

pub fn acceptable_indexer_leftbehind(&self) -> u64

THe acceptable ckb-indexer leftbehind block number (default = 1)

pub fn set_acceptable_indexer_leftbehind(&mut self, value: u64)

Set the acceptable ckb-indexer leftbehind block number

pub fn check_ckb_chain(&mut self) -> Result<(), CellCollectorError>

wrapper check_ckb_chain_async future

pub async fn check_ckb_chain_async(&mut self) -> Result<(), CellCollectorError>

Check if ckb-indexer synced with ckb node. This will check every 50ms for 100 times (more than 5s in total, since ckb-indexer’s poll interval is 2.0s).

Trait Implementations

impl CellCollector for DefaultCellCollector

fn collect_live_cells_async<'life0, 'life1, 'async_trait>( &'life0 mut self, query: &'life1 CellQueryOptions, apply_changes: bool, ) -> Pin<Box<dyn Future<Output = Result<(Vec<LiveCell>, u64), CellCollectorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Collect live cells by query options, if apply_changes is true will mark all collected cells as dead cells.

fn lock_cell( &mut self, out_point: OutPoint, tip_block_number: u64, ) -> Result<(), CellCollectorError>

Mark this cell as dead cell

fn apply_tx( &mut self, tx: Transaction, tip_block_number: u64, ) -> Result<(), CellCollectorError>

Mark all inputs as dead cells and outputs as live cells in the transaction.

fn reset(&mut self)

Clear cache and locked cells

fn collect_live_cells( &mut self, query: &CellQueryOptions, apply_changes: bool, ) -> Result<(Vec<LiveCell>, u64), CellCollectorError>

Collect live cells by query options, if apply_changes is true will mark all collected cells as dead cells.

impl Clone for DefaultCellCollector

fn clone(&self) -> DefaultCellCollector

Returns a duplicate of the value.

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

Performs copy-assignment from source.