Struct IdempotencyEngine 

pub struct IdempotencyEngine { /* private fields */ }

Idempotency engine — deduplication for step executions.

Implementations

impl IdempotencyEngine

pub fn new() -> Self

pub fn configure( &mut self, step_id: &str, key_strategy: KeyStrategy, window: IdempotencyWindow, conflict_resolution: ConflictResolution, ) -> WorkflowResult<()>

Configure idempotency for a step.

pub fn compute_key( &self, step_id: &str, workflow_id: &str, input: &Value, ) -> WorkflowResult<String>

Compute idempotency key for a step execution.

pub fn check(&self, key: &str) -> Option<&IdempotencyEntry>

Check if a key was already processed.

pub fn store( &mut self, key: String, step_id: &str, execution_id: &str, input_hash: &str, output: Value, ) -> WorkflowResult<()>

Store execution result for deduplication.

pub fn record_hit(&mut self, step_id: &str)

Record a cache hit.

pub fn purge_expired(&mut self) -> usize

Purge expired entries.

pub fn report(&self) -> IdempotencyReport

Get deduplication report.

pub fn clear(&mut self)

Clear all cached entries.

Trait Implementations

impl Default for IdempotencyEngine

fn default() -> Self

Returns the “default value” for a type.