Struct UtxoParser

pub struct UtxoParser { /* private fields */ }

Parser that tracks unspent outputs and input amounts to produce UtxoBlock

See the module docs for example usage.

Implementations

impl UtxoParser

pub fn new(filter_file: &str) -> Result<Self>

Create a new parser from a file generated by FilterParser

Trait Implementations

impl BlockParser<UtxoBlock> for UtxoParser

fn options() -> Options

In order to track UTXO amounts we must process blocks in-order

We reduce the number of threads to reduce memory usage. If you run into memory issues try lowering num_threads further or the buffer_size

fn extract(&self, block: Block) -> Vec<UtxoBlock>

Extracts the data you need from the block.

fn batch(&self, items: Vec<UtxoBlock>) -> Vec<UtxoBlock>

Runs on batches of B to return the final results, blocks will be in-order if Options::order_output has been set.

fn parse(&self, headers: &[ParsedHeader]) -> Receiver<Result<B>>

Parse all the blocks represented by the headers.

fn parse_dir(&self, blocks: &str) -> Result<Receiver<Result<B>>>

Parse all the blocks located in the blocks directory

fn parse_ordered(&self, headers: &[ParsedHeader]) -> Receiver<Result<B>>

Parse all the blocks represented by the headers, ensuring the results B are returned in the same order the ParsedHeader were passed in.

fn parse_with_opts( &self, headers: &[ParsedHeader], opts: Options, ) -> Receiver<Result<B>>

Allows users to pass in custom Options in case they need to reduce memory usage or otherwise tune performance for their system. Users should call BlockParser::options to get the default options associated with the parser first.

fn send_batch(&self, tx_c: &Sender<Result<B>>, batch: Result<Vec<B>>)

Helper function for sending batch results in a channel

impl Clone for UtxoParser

fn clone(&self) -> UtxoParser

Returns a copy of the value.

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

Performs copy-assignment from source.