Struct DefaultParallelRebalancer 

pub struct DefaultParallelRebalancer;

Default implementation of ParallelRebalancer using rayon.

This implementation uses rayon’s parallel iterators for concurrent processing and provides threshold-based fallback to sequential processing for small workloads.

Implementations

impl DefaultParallelRebalancer

pub fn new() -> Self

Create a new DefaultParallelRebalancer.

Trait Implementations

impl Clone for DefaultParallelRebalancer

fn clone(&self) -> DefaultParallelRebalancer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DefaultParallelRebalancer

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

Formats the value using the given formatter.

impl Default for DefaultParallelRebalancer

fn default() -> DefaultParallelRebalancer

Returns the “default value” for a type.

impl<S: Store> ParallelRebalancer<S> for DefaultParallelRebalancer

fn parallel_rebalance( &self, _store: &S, prolly: &Prolly<S>, nodes: Vec<(Node, Vec<(Node, usize)>)>, config: &ParallelConfig, ) -> Result<Vec<Cid>, Error>

Rebalance multiple nodes in parallel.

fn parallel_batch( &self, _store: &S, prolly: &Prolly<S>, tree: &Tree, mutations: Vec<Mutation>, config: &ParallelConfig, ) -> Result<Tree, Error>

Apply batch mutations with parallel leaf processing.