Struct Executor 

pub struct Executor { /* private fields */ }

Executor for duplicate processing operations.

Handles rate-limited, concurrent execution of the duplicate processing pipeline:

1. Download backup copies of loser assets
2. Delete successfully downloaded assets

Example

use immich_lib::{ImmichClient, Executor};
use immich_lib::models::ExecutionConfig;

let client = ImmichClient::new("https://immich.example.com", "api-key")?;
let config = ExecutionConfig::default();
let executor = Executor::new(client, config);

// Execute analysis results
// let report = executor.execute_all(&analyses).await;

Implementations

impl Executor

pub fn new(client: ImmichClient, config: ExecutionConfig) -> Self

Create a new executor with the given client and configuration.

Arguments

• client - The Immich API client to use for operations
• config - Execution configuration (rate limits, concurrency, backup dir)

pub async fn execute_all(&self, groups: &[DuplicateAnalysis]) -> ExecutionReport

Execute processing for all duplicate groups.

Iterates through all groups, downloading backups and deleting duplicates for each. Shows progress via console progress bars.

Arguments

• groups - Slice of duplicate analysis results to process

Returns

An execution report summarizing all operations and their outcomes.

pub async fn execute_group( &self, analysis: &DuplicateAnalysis, pb: &ProgressBar, ) -> GroupResult

Execute processing for a single duplicate group.

1. Consolidates metadata from losers to winner (GPS, datetime, description)
2. Downloads backup copies of all loser assets
3. Deletes only those that were successfully downloaded

Arguments

• analysis - The duplicate analysis for this group
• pb - Progress bar to update with status messages

Returns

A group result detailing the outcome of each operation.