Enum DeduplicationResult 

pub enum DeduplicationResult {
    New(DeduplicationToken),
    InProgress,
    Cached(String),
}

Outcome of a Deduplicator::check_and_register call.

Three-way classification allows callers to decide whether to do the work themselves, wait for a concurrent worker, or immediately reuse a cached result.

Examples

use std::time::Duration;
use tokio_prompt_orchestrator::enhanced::{Deduplicator, DeduplicationResult};

let dedup = Deduplicator::new(Duration::from_secs(60));
match dedup.check_and_register("my-key").await {
    DeduplicationResult::New(token) => {
        let result = "computed".to_string();
        dedup.complete(token, result).await;
    }
    DeduplicationResult::InProgress => {
        // another task is already working; wait for it
        let _ = dedup.wait_for_result("my-key").await;
    }
    DeduplicationResult::Cached(result) => {
        println!("reused: {result}");
    }
}

Variants

New(DeduplicationToken)

New request — should be processed by the caller.

The caller must eventually call Deduplicator::complete or Deduplicator::fail with the returned DeduplicationToken so that any tasks blocked in Deduplicator::wait_for_result are unblocked.

InProgress

An identical request is already being processed by another task.

The caller should call Deduplicator::wait_for_result to block until that task completes and then reuse its result.

Cached(String)

The request was recently completed and the result is still within the cache window. The cached response string is returned directly.

Trait Implementations

impl Clone for DeduplicationResult

fn clone(&self) -> DeduplicationResult

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DeduplicationResult

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.