Struct CachePeekStaleService 

pub struct CachePeekStaleService { /* private fields */ }

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

Evaluates key_expr:

• None → Stopped(exchange) (no key = no stale available).
• Some(key) → repository.peek_stale(&key).await.
  • Err(e) → Failed(e).
  • Ok(Some(entry)) → reconstruct body from entry, set on exchange, return Completed(exchange).
  • Ok(None) → Stopped(exchange) (absence = no stale available — spec R6).

Implementations

impl CachePeekStaleService

pub fn new( repository: Arc<dyn CacheRepository>, key_expr: MessageIdExpression, ) -> 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.