Struct CachePeekStaleService 

pub struct CachePeekStaleService { /* private fields */ }

Outcome-aware segment that serves a stale (post-expiry) cache entry.

Evaluates key_expr:

• None → Stopped(exchange) with a debug log (an anomalous key resolution is fail-closed, not a miss).
• Some(key) → repository.peek_stale(&key).await.
  • Err(e) → Failed(e).
  • Ok(Some(entry)) → reconstruct body from entry, set CamelCachePeekHit=true and CamelCachePeekStale (true when the entry’s expires_at has elapsed at evaluation time; false when absent or not elapsed), return Completed(exchange).
  • Ok(None) → MISS (absence), governed by PeekStaleMissPolicy:
    • Stop (default): set CamelCachePeekHit=false and CamelCachePeekStale=false, log at debug, return Stopped(exchange) (absence in CircuitBreaker.fallback means “no stale available”).
    • Continue: set CamelCachePeekHit=false and CamelCachePeekStale=false, leave the body unchanged, return Completed(exchange) so choice can branch on CamelCachePeekHit.

Implementations

impl CachePeekStaleService

pub fn new( repository: Arc<dyn CacheRepository>, key_expr: MessageIdExpression, miss_policy: PeekStaleMissPolicy, ) -> Self

Trait Implementations

impl Clone for CachePeekStaleService

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl OutcomePipeline for CachePeekStaleService

fn clone_box(&self) -> Box<dyn OutcomePipeline>

Clone the segment into a new boxed instance. Required because Box<dyn OutcomePipeline> cannot directly derive Clone.

fn run<'a>( &'a mut self, exchange: Exchange, ) -> Pin<Box<dyn Future<Output = PipelineOutcome> + Send + 'a>>

Execute the segment against exchange, returning a PipelineOutcome.