Struct SideEffectGuard 

pub struct SideEffectGuard { /* private fields */ }

Guard that tracks whether side effects should be executed.

During normal indexing, side effects (webhooks, external API calls) are executed. During replay after a reorg, side effects are skipped because they were already executed during the original processing.

Example

use chainindex_core::idempotency::{ReplayContext, SideEffectGuard};

let ctx = ReplayContext::normal();
let guard = SideEffectGuard::new(&ctx);
assert!(guard.should_execute()); // normal mode: execute side effects

let replay_ctx = ReplayContext::replay(100, None);
let replay_guard = SideEffectGuard::new(&replay_ctx);
assert!(!replay_guard.should_execute()); // replay mode: skip side effects

Implementations

impl SideEffectGuard

pub fn new(replay_ctx: &ReplayContext) -> Self

Create a new guard based on the replay context.

Side effects are skipped when replay_ctx.is_replay is true.

pub fn should_execute(&self) -> bool

Returns true if side effects should be executed (not in replay mode).

pub async fn execute<F, Fut, T>(&self, f: F) -> Option<T>

where F: FnOnce() -> Fut, Fut: Future<Output = T>,

Execute a side effect only if not in replay mode.

Returns Some(result) if the side effect was executed, or None if it was skipped (replay mode).