Struct CacheInvalidateService 

pub struct CacheInvalidateService { /* private fields */ }

Outcome-aware segment that invalidates a single cache entry.

Evaluates key_expr:

• None → Completed(exchange) (nothing to invalidate).
• Some(key) → repository.invalidate(&key).await.
  • Err(e) → Failed(e).
  • Ok(()) → Completed(exchange).

Implementations

impl CacheInvalidateService

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

Trait Implementations

impl Clone for CacheInvalidateService

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 CacheInvalidateService

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.