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>, matcher: Option<SharedHttpMatcher>, 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
• matcher: Optional shared signature matcher
• 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 worker_index_for_packet(&self, packet: &[u8]) -> usize

Deterministically computes which worker would process packet based on its flow hash. Useful for tests that want to assert routing decisions without going through the actual queue.

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

pub fn stats(&self) -> PoolStats

pub fn shutdown(&self)

Initiates graceful shutdown of the worker pool.