Struct ParallelScan

pub struct ParallelScan<BaseJob, MergeJob> {
    pub trees: Vec<Tree<Base<BaseJob>, Merge<MergeJob>>>,
    pub(super) acc: Option<(MergeJob, Vec<BaseJob>)>,
    pub curr_job_seq_no: SequenceNumber,
    pub(super) max_base_jobs: u64,
    pub(super) delay: u64,
}

Fields

trees: Vec<Tree<Base<BaseJob>, Merge<MergeJob>>>

acc: Option<(MergeJob, Vec<BaseJob>)>

last emitted proof and the corresponding transactions

curr_job_seq_no: SequenceNumber

Sequence number for the jobs added every block

max_base_jobs: u64

transaction_capacity_log_2

delay: u64

Implementations

impl<BaseJob, MergeJob> ParallelScan<BaseJob, MergeJob>

where BaseJob: Debug + Clone + 'static, MergeJob: Debug + Clone + 'static,

fn with_leaner_trees(&self) -> Self

pub fn empty(max_base_jobs: u64, delay: u64) -> Self

fn map<F1, F2>(&self, f1: F1, f2: F2) -> Self

where F1: Fn(&MergeJob) -> MergeJob, F2: Fn(&BaseJob) -> BaseJob,

pub fn hash<FunMerge, FunBase>( &self, fun_merge: FunMerge, fun_base: FunBase, ) -> GenericArray<u8, U32>

where FunMerge: Fn(&mut Vec<u8>, &MergeJob), FunBase: Fn(&mut Vec<u8>, &BaseJob),

pub fn fold_chronological_until<Accum, Final, FunMerge, FunBase, FunFinish>( &self, init: Accum, fun_merge: FunMerge, fun_base: FunBase, fun_finish: FunFinish, ) -> Final

where FunMerge: Fn(Accum, &Merge<MergeJob>) -> ControlFlow<Final, Accum>, FunBase: Fn(Accum, &Base<BaseJob>) -> ControlFlow<Final, Accum>, FunFinish: Fn(Accum) -> Final,

pub fn fold_chronological_until_err<Accum, FunMerge, FunBase, FunFinish>( &self, init: Accum, fun_merge: FunMerge, fun_base: FunBase, fun_finish: FunFinish, ) -> Result<Accum, String>

where FunMerge: Fn(Accum, &Merge<MergeJob>) -> Result<Accum, String>, FunBase: Fn(Accum, &Base<BaseJob>) -> Result<Accum, String>, FunFinish: Fn(Accum) -> Accum,

fn fold_chronological<Accum, FunMerge, FunBase>( &self, init: Accum, fun_merge: FunMerge, fun_base: FunBase, ) -> Accum

where FunMerge: Fn(Accum, &Merge<MergeJob>) -> Accum, FunBase: Fn(Accum, &Base<BaseJob>) -> Accum,

fn max_trees(&self) -> u64

fn work_for_tree( &self, data_tree: WorkForTree, ) -> Vec<AvailableJob<BaseJob, MergeJob>>

fn all_work(&self) -> Vec<Vec<AvailableJob<BaseJob, MergeJob>>>

work on all the level and all the trees

fn work_for_next_update( &self, data_count: u64, ) -> Vec<Vec<AvailableJob<BaseJob, MergeJob>>>

fn free_space_on_current_tree(&self) -> u64

fn add_merge_jobs( &mut self, completed_jobs: &[MergeJob], ) -> Result<Option<(MergeJob, Vec<BaseJob>)>, ()>

fn add_data( &mut self, data: Vec<BaseJob>, base_kind: impl Fn(&BaseJob) -> usize, ) -> Result<(), ()>

fn reset_seq_no(&mut self)

fn incr_sequence_no(&mut self)

fn update_helper( &mut self, data: Vec<BaseJob>, completed_jobs: Vec<MergeJob>, base_kind: impl Fn(&BaseJob) -> usize, ) -> Result<Option<(MergeJob, Vec<BaseJob>)>, ()>

pub fn update( &mut self, data: Vec<BaseJob>, completed_jobs: Vec<MergeJob>, base_kind: impl Fn(&BaseJob) -> usize, ) -> Result<Option<(MergeJob, Vec<BaseJob>)>, ()>

pub fn all_jobs(&self) -> Vec<Vec<AvailableJob<BaseJob, MergeJob>>>

pub fn jobs_for_next_update(&self) -> Vec<Vec<AvailableJob<BaseJob, MergeJob>>>

pub fn jobs_for_slots( &self, slots: u64, ) -> Vec<Vec<AvailableJob<BaseJob, MergeJob>>>

pub fn free_space(&self) -> u64

pub fn last_emitted_value(&self) -> Option<&(MergeJob, Vec<BaseJob>)>

fn current_job_sequence_number(&self) -> SequenceNumber

pub fn base_jobs_on_latest_tree(&self) -> impl Iterator<Item = BaseJob>

pub fn base_jobs_on_earlier_tree( &self, index: usize, ) -> impl Iterator<Item = BaseJob>

pub fn partition_if_overflowing(&self) -> SpacePartition

pub fn next_on_new_tree(&self) -> bool

pub fn pending_data(&self) -> Vec<Vec<BaseJob>>

fn job_count(&self) -> (f64, f64)

Trait Implementations

impl<BaseJob: Clone, MergeJob: Clone> Clone for ParallelScan<BaseJob, MergeJob>

fn clone(&self) -> ParallelScan<BaseJob, MergeJob>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<BaseJob: Debug, MergeJob: Debug> Debug for ParallelScan<BaseJob, MergeJob>

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

Formats the value using the given formatter.