Struct RelayHandler 

pub struct RelayHandler<T, H = NoHook> {
    pub target: T,
    pub hook: H,
    pub budget: RelayBudget,
}

Pushes a source’s queued rows to a separately supplied target store. Distinct producers may upsert the same key when its value is identical. A key that is ever relay-deleted MUST have exactly one producer, so its source sequence orders every update and delete. Target rh rows never expire.

Fields

target: T

Target store (may be a clone of the source store on native).

hook: H

Atomic target-batch extension.

budget: RelayBudget

Per-fire work cap.

Implementations

impl<T: NamespaceStore, H: RelayHook> RelayHandler<T, H>

pub async fn deliver_with_metrics<S: NamespaceStore>( &self, ctx: &TimerCtx<'_, S>, timer: &DueTimer, metrics: &dyn Metrics, ) -> Result<Fired, StoreError>

Deliver one relay fire while recording source backlog and lag.

Trait Implementations

impl<T: Debug, H: Debug> Debug for RelayHandler<T, H>

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

Formats the value using the given formatter.

impl<S: NamespaceStore, T: NamespaceStore, H: RelayHook> TimerHandler<S> for RelayHandler<T, H>

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.

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

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