Struct ScannerPipeline 

pub struct ScannerPipeline { /* private fields */ }

Scanner pipeline for composing multiple scanners

Enterprise Pattern

Provides:

• Sequential execution
• Parallel execution option
• Short-circuit on high risk
• Result aggregation

Implementations

impl ScannerPipeline

pub fn new() -> Self

Create a new scanner pipeline

pub fn add(self, scanner: Arc<dyn Scanner>) -> Self

Add a scanner to the pipeline

pub fn with_short_circuit(self, threshold: f32) -> Self

Enable short-circuit evaluation

If any scanner returns risk >= threshold, stop execution

pub async fn execute( &self, input: &str, vault: &Vault, ) -> Result<Vec<ScanResult>>

Execute pipeline sequentially

pub async fn execute_parallel( &self, input: &str, vault: &Vault, ) -> Result<Vec<ScanResult>>

Execute pipeline in parallel

All scanners run concurrently. Useful for I/O-bound scanners.

pub async fn execute_aggregated( &self, input: &str, vault: &Vault, ) -> Result<ScanResult>

Get aggregated result from pipeline

Trait Implementations

impl Default for ScannerPipeline

fn default() -> Self

Returns the “default value” for a type.