Struct InvalidationCollector 

pub struct InvalidationCollector { /* private fields */ }

Mutable invalidation collector passed to transaction companion closures.

The collector is intentionally small and database-neutral. Repository code records the cache targets made stale by a write while keeping ownership of SQL/ORM execution inside the transaction closure.

Implementations

impl InvalidationCollector

pub fn new( namespace: impl Into<String>, reason: impl Into<String>, ) -> InvalidationCollector

Create an empty collector for one cache namespace and operator-facing reason.

pub fn namespace(&self) -> &str

Return the namespace that should receive the collected invalidations.

pub fn reason(&self) -> &str

Return the reason attached to durable outbox rows.

pub fn intents(&self) -> &[InvalidationIntent]

Return collected intents in insertion order.

pub fn is_empty(&self) -> bool

Return true when no invalidations have been collected.

pub fn len(&self) -> usize

Return the number of collected intents.

pub fn intent( &mut self, intent: InvalidationIntent, ) -> &mut InvalidationCollector

Add one already-normalized invalidation intent.

pub fn invalidate_key( &mut self, key: impl Into<String>, ) -> &mut InvalidationCollector

Add one physical cache-key invalidation.

pub fn invalidate_tag( &mut self, tag: impl Into<String>, ) -> &mut InvalidationCollector

Add one tag invalidation.

pub fn invalidate_entity( &mut self, entity: impl Into<String>, key: impl Into<String>, ) -> &mut InvalidationCollector

Add one entity-tag invalidation.

pub fn invalidate_collection( &mut self, collection: impl Into<String>, ) -> &mut InvalidationCollector

Add one collection-tag invalidation.

pub fn flush(&mut self) -> &mut InvalidationCollector

Add a cache-wide flush invalidation.

pub fn cache_entity<E>( &mut self, id: <E as CacheEntity>::Id, ) -> &mut InvalidationCollector

where E: CacheEntity,

Add both entity and collection invalidations for a cache entity id.

pub fn into_collected(self) -> CollectedInvalidations

Finish collection and return an immutable invalidation payload.

Trait Implementations

impl Clone for InvalidationCollector

fn clone(&self) -> InvalidationCollector

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InvalidationCollector

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

Formats the value using the given formatter.

impl Default for InvalidationCollector

fn default() -> InvalidationCollector

Returns the “default value” for a type.

impl Eq for InvalidationCollector

impl PartialEq for InvalidationCollector

fn eq(&self, other: &InvalidationCollector) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for InvalidationCollector