Struct QueueConfig 

pub struct QueueConfig {

    pub max_parallel_scans: usize,
    pub max_parallel_series_resolve: usize,
    pub max_parallel_analyses: usize,
    pub max_parallel_metadata: usize,
    pub max_parallel_index: usize,
    pub max_parallel_image_fetch: usize,
    pub max_parallel_scans_per_device: usize,
    pub high_watermark: usize,
    pub critical_watermark: usize,
    pub coalesce_window_ms: u64,
    pub default_library_cap: usize,
    pub default_library_weight: u32,
    pub library_overrides: HashMap<LibraryId, LibraryQueuePolicy>,
}

Fields

max_parallel_scans: usize

Maximum worker concurrency per queue. These values drive worker pool sizes.

max_parallel_series_resolve: usize

max_parallel_analyses: usize

max_parallel_metadata: usize

max_parallel_index: usize

max_parallel_image_fetch: usize

max_parallel_scans_per_device: usize

Per-device cap for scan workers touching the same mount.

high_watermark: usize

High watermark for queued jobs. Beyond this we start coalescing low priority work.

critical_watermark: usize

Critical watermark for queued jobs. Beyond this P2/P3 work is merged instead of enqueued.

coalesce_window_ms: u64

Sliding window (milliseconds) for aggregating duplicate work items.

default_library_cap: usize

Default maximum in-flight leases allowed per library.

default_library_weight: u32

Default scheduling weight assigned to libraries without overrides.

library_overrides: HashMap<LibraryId, LibraryQueuePolicy>

Optional per-library overrides.

Trait Implementations

impl Clone for QueueConfig

fn clone(&self) -> QueueConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueueConfig

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

Formats the value using the given formatter.

impl Default for QueueConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for QueueConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for QueueConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.