Struct WorkerRepurposePlan 

pub struct WorkerRepurposePlan {
    pub fetch_workers: usize,
    pub persist_workers: usize,
    pub fetch_queue_capacity: usize,
    pub persist_queue_capacity: usize,
    pub dispatch_target: usize,
}

Worker allocation plan for staged daemon pipelines where fetch and persistence run concurrently.

Fields

fetch_workers: usize

Number of fetch workers actively scraping upstream sources.

persist_workers: usize

Number of dedicated persistence workers (CSV + inserts + post-fetch side effects).

fetch_queue_capacity: usize

Capacity of the fetch queue feeding fetch workers.

persist_queue_capacity: usize

Capacity of the persistence queue feeding persist workers.

dispatch_target: usize

Number of randomized fetch jobs to keep in flight.

Implementations

impl WorkerRepurposePlan

pub fn for_randomized_registry( fetch_workers: usize, fetch_queue_capacity: usize, dispatch_target: usize, ) -> Self

Build a plan for randomized registry ingestion.

dispatch_target should already include provider-specific prefetch shaping.

Trait Implementations

impl Clone for WorkerRepurposePlan

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for WorkerRepurposePlan

impl Debug for WorkerRepurposePlan

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

Formats the value using the given formatter.

impl Eq for WorkerRepurposePlan

impl PartialEq for WorkerRepurposePlan

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for WorkerRepurposePlan