Module pipeline

adaptive_pipeline::application::services

Module pipeline 

Source
Expand description

§Pipeline Service Implementation

Application layer orchestration of file processing workflows. Coordinates multi-stage pipelines (compression, encryption, I/O) with async processing, progress monitoring, and parallel chunk processing. Integrates domain services via dependency injection. Provides real-time metrics, error recovery, and resource management. See mdBook for workflow details and integration patterns.

  • Encryption Integration: Seamless encryption of sensitive data
  • Key Management: Secure key generation, storage, and rotation
  • Memory Protection: Secure handling of sensitive data in memory

§Integration

The pipeline service integrates with:

  • Domain Layer: Implements PipelineService trait
  • Repository Layer: Persists pipeline state and metadata
  • Monitoring Systems: Reports metrics and traces
  • Configuration System: Dynamic configuration updates

Structs§

ConcurrentPipeline
PipelineChunkProcessor
ChunkProcessor implementation that processes chunks through a pipeline