Struct ShowPipelineUseCase 

pub struct ShowPipelineUseCase { /* private fields */ }

Use case for displaying detailed pipeline information.

This use case retrieves a specific pipeline by name and displays its complete metadata, including stages, configuration, and processing metrics. It provides comprehensive visibility into pipeline structure and behavior.

Responsibilities

• Look up pipeline by name in repository
• Format detailed pipeline information for display
• Display all stage configurations and parameters
• Show processing metrics and statistics
• Handle missing pipelines with clear error messages

Dependencies

• Pipeline Repository: For retrieving pipeline data

Example

let use_case = ShowPipelineUseCase::new(pipeline_repository);
match use_case.execute("compress-encrypt".to_string()).await {
    Ok(()) => println!("Pipeline details displayed"),
    Err(e) => eprintln!("Failed to show pipeline: {}", e),
}

Implementations

impl ShowPipelineUseCase

pub fn new(pipeline_repository: Arc<SqlitePipelineRepository>) -> Self

Creates a new Show Pipeline use case.

Parameters

• pipeline_repository - Repository for accessing pipeline data

Returns

A new instance of ShowPipelineUseCase

pub async fn execute(&self, pipeline_name: String) -> Result<()>

Executes the show pipeline use case.

Retrieves a specific pipeline by name and displays its complete metadata, including all stages, configuration parameters, and processing metrics.

Parameters

• pipeline_name - Name of the pipeline to display

Output Format

Displays:

• Pipeline metadata (ID, name, status, timestamps)
• Detailed stage information with configurations
• Stage parameters (if present)
• Pipeline-level configuration (if present)
• Processing metrics (bytes, chunks, errors, warnings)

Returns

• Ok(()) - Pipeline details displayed successfully
• Err(anyhow::Error) - Pipeline not found or repository access failed

Errors

Returns errors for:

• Pipeline not found with given name
• Repository connection failures
• Database query errors
• Permission issues accessing pipeline data

Example Output

=== Pipeline Details ===
ID: 01H2X3Y4Z5A6B7C8D9E0F1G2H3
Name: compress-encrypt
Status: Active
Created: 2025-10-05 14:30:00 UTC
Updated: 2025-10-05 14:30:00 UTC

Stages (4):
  1. input_checksum (Checksum)
     Algorithm: sha256
     Enabled: true
     Order: 0

  2. compression (Compression)
     Algorithm: brotli
     Enabled: true
     Order: 1
     Parameters:
       level: 6

  3. encryption (Encryption)
     Algorithm: aes256gcm
     Enabled: true
     Order: 2

  4. output_checksum (Checksum)
     Algorithm: sha256
     Enabled: true
     Order: 3

Metrics:
  Bytes Processed: 1048576
  Chunks Processed: 16
  Error Count: 0
  Warning Count: 0