Struct rsure::node::HashUpdater

pub struct HashUpdater<'n, S> { /* fields omitted */ }

The HashUpdater is able to update hashes. This is the first pass.

Methods

impl<'a, S: Source> HashUpdater<'a, S>

pub fn new(source: S, store: &dyn Store) -> HashUpdater<S>

pub fn compute(self, base: &str, estimate: &Estimate) -> Result<HashMerger<S>>

First pass. Go through the source nodes, and for any that need a hash, compute the hash, and collect the results into a temporary file. Consumes the updater, returning the HashMerger which is used to merge the hash results into a datastream.

pub fn compute_parallel(
    self,
    base: &str,
    estimate: &Estimate
) -> Result<HashMerger<S>>

First pass, multi-threaded version. Go through the source nodes, and for any that need a hash, compute the hash, and collect the result into a temporary file. Consumes the updater, returning the HashMerger which is used to merge the hash results into a datastream.