Struct VerifyTimer 

pub struct VerifyTimer<R, B, W, X = FailClosedExtraction> {
    pub remote: R,
    pub blobs: B,
    pub windows: W,
    pub shards: Arc<dyn ShardMap>,
    pub cfg: IndexedConfig,
    pub limits: SliceLimits,
    pub lease: LeaseParams,
    pub clock: Arc<dyn Clock>,
    pub metrics: Arc<dyn Metrics>,
    pub extension: X,
}

The kind-7 handler. remote reaches other partitions (the Worker’s namespace client, budgeted per fire); the fire’s own store serves the ref shard’s rows, timers and outbox.

Fields

remote: R

Cross-partition store: index shards, membership shards, coordinator.

blobs: B

Member packs, read for external bases.

windows: W

The ticketed pack’s own windows.

shards: Arc<dyn ShardMap>

Shard placement.

cfg: IndexedConfig

Indexed limits.

limits: SliceLimits

Work units per slice.

lease: LeaseParams

Epoch lease timing for the relay seam.

clock: Arc<dyn Clock>

Backend clock.

metrics: Arc<dyn Metrics>

Metrics sink.

extension: X

The extraction seam.

Trait Implementations

impl<R, B, W, X> Debug for VerifyTimer<R, B, W, X>

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

Formats the value using the given formatter.

impl<S, R, B, W, X> TimerHandler<S> for VerifyTimer<R, B, W, X>

where S: NamespaceStore, R: NamespaceStore, B: BlobStore, W: PackWindows, X: SliceExtension,

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

One slice per alarm: a slice spends most of an alarm’s budget.

fn kind(&self) -> TimerKind

The kind this handler decodes.

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.