Struct PiiMaskingService 

pub struct PiiMaskingService;

Production PII masking service.

This service demonstrates the complete pattern for implementing pipeline stages:

• Stateless processing (no internal state)
• Thread-safe (Send + Sync)
• Non-reversible operation (masking cannot be undone)
• Type-safe configuration via FromParameters
• Proper error handling with PipelineError

Implementation Notes

• Position: PreBinary - Must execute before compression/encryption
• Reversibility: false - Masking is one-way (Reverse returns error)
• Stage Type: Transform - Data transformation operation
• Performance: Regex-based matching with compiled patterns

Implementations

impl PiiMaskingService

pub fn new() -> Self

Creates a new PII masking service.

Trait Implementations

impl Default for PiiMaskingService

fn default() -> Self

Returns the “default value” for a type.

impl StageService for PiiMaskingService

Implementation of StageService for PII masking.

This demonstrates the complete pattern that all stages follow:

1. Extract typed config via FromParameters
2. Dispatch based on Operation (Forward/Reverse)
3. Process the chunk
4. Update metrics in context
5. Return processed chunk

fn process_chunk( &self, chunk: FileChunk, config: &StageConfiguration, context: &mut ProcessingContext, ) -> Result<FileChunk, PipelineError>

Process a file chunk according to the operation (Forward or Reverse).

fn position(&self) -> StagePosition

Returns the position where this stage can execute in the pipeline.

fn is_reversible(&self) -> bool

Indicates whether this stage supports reverse operations.

fn stage_type(&self) -> StageType

Returns the type classification of this stage.