Struct ParallelConfig 

pub struct ParallelConfig {
    pub enabled: bool,
    pub max_concurrency: Option<usize>,
    pub batch_size: Option<usize>,
}

Configuration for parallel processing operations.

This struct controls how debtmap executes batch operations like multi-file analysis. When enabled, files are processed concurrently using rayon’s thread pool.

Example

use debtmap::config::ParallelConfig;

let config = ParallelConfig {
    enabled: true,
    max_concurrency: Some(4),
    batch_size: Some(50),
};

Fields

enabled: bool

Enable parallel processing (default: true)

When disabled, files are processed sequentially. Useful for debugging or when running in constrained environments.

max_concurrency: Option<usize>

Maximum concurrent operations (default: num_cpus)

Limits the number of concurrent file analyses. If None, uses all available CPU cores.

batch_size: Option<usize>

Batch size for chunked processing (default: 100)

Large codebases are processed in batches to prevent resource exhaustion and enable progress reporting.

Implementations

impl ParallelConfig

pub fn new() -> Self

Create a new parallel config with defaults.

pub fn sequential() -> Self

Create a config with parallel processing disabled.

pub fn effective_concurrency(&self) -> usize

Get the effective concurrency level.

Returns the configured max_concurrency, or the number of available CPU cores if not specified.

pub fn effective_batch_size(&self) -> usize

Get the effective batch size.

Trait Implementations

impl Clone for ParallelConfig

fn clone(&self) -> ParallelConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ParallelConfig

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

Formats the value using the given formatter.

impl Default for ParallelConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ParallelConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for ParallelConfig

fn eq(&self, other: &ParallelConfig) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for ParallelConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for ParallelConfig