Struct PurgeDelivery 

pub struct PurgeDelivery { /* private fields */ }

Kind-11 retries immutable work until local and global acknowledgement.

Implementations

impl PurgeDelivery

pub fn new( local: Arc<dyn LocalInvalidation>, sink: Option<Arc<dyn PurgeSink>>, budget: SliceBudget, ) -> Self

Use the same shared budget for every purge timer in an alarm.

impl PurgeDelivery

pub fn fire_with_local<'a, S: NamespaceStore>( &'a self, local: &'a dyn LocalInvalidation, ctx: &'a TimerCtx<'a, S>, timer: &'a DueTimer, ) -> BoxFuture<'a, Result<Fired, StoreError>>

Use a context-local catalog reader without issuing a Durable Object self-call.

Trait Implementations

impl Debug for PurgeDelivery

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

Formats the value using the given formatter.

impl<S: NamespaceStore> TimerHandler<S> for PurgeDelivery

fn kind(&self) -> TimerKind

The kind this handler decodes.

fn max_per_tick(&self) -> Option<u32>

Lowers the shared TickBudget::max_per_kind allowance for this kind.

fn fire<'a>( &'a self, ctx: &'a TimerCtx<'a, S>, timer: &'a DueTimer, ) -> BoxFuture<'a, Result<Fired, StoreError>>

Prepare effects; the core atomically guards and removes the timer.