Struct WorkerPool 

pub struct WorkerPool {
    pub batch_size: usize,
    pub timeout_ms: u64,
    /* private fields */
}

Worker pool for parallel HTTP packet processing.

Fields

batch_size: usize

timeout_ms: u64

Implementations

impl WorkerPool

pub fn new( num_workers: usize, queue_size: usize, batch_size: usize, timeout_ms: u64, result_sender: Sender<HttpAnalysisResult>, database: Option<Arc<Database>>, max_connections: usize, filter_config: Option<FilterConfig>, ) -> Result<Arc<Self>, HuginnNetHttpError>

Creates a new worker pool for HTTP analysis.

Parameters

• num_workers: Number of worker threads
• queue_size: Size of each worker’s packet queue
• batch_size: Maximum packets to process in one batch
• timeout_ms: Worker receive timeout in milliseconds
• result_sender: Channel to send analysis results
• database: Optional signature database for matching
• max_connections: Maximum HTTP flows to track per worker
• filter_config: Optional filter configuration for packet filtering

Returns

A new WorkerPool or an error if creation fails.

pub fn dispatch(&self, packet: Vec<u8>) -> DispatchResult

pub fn stats(&self) -> PoolStats

pub fn shutdown(&self)

Initiates graceful shutdown of the worker pool.