Struct ExactlyOnceRegistry 

pub struct ExactlyOnceRegistry { /* private fields */ }

Exactly-once processing registry

Implementations

impl ExactlyOnceRegistry

pub fn new(config: ExactlyOnceConfig) -> Self

pub fn check_idempotency(&self, key: &str, event_id: Uuid) -> IdempotencyResult

Check and register an idempotency key

Returns New if the key hasn’t been seen (and registers it), or Duplicate with the original event_id if already processed.

pub fn commit_offset( &self, pipeline_id: &str, stream_id: &str, offset: usize, event_id: Uuid, )

Commit a consumer offset for a pipeline

pub fn get_offset( &self, pipeline_id: &str, stream_id: &str, ) -> Option<ConsumerOffset>

Get the last committed offset for a pipeline

pub fn record_processing(&self, pipeline_id: &str, event_id: Uuid)

Record that a pipeline has processed an event

pub fn was_processed(&self, pipeline_id: &str, event_id: Uuid) -> bool

Check if a pipeline has already processed an event

pub fn stats(&self) -> ExactlyOnceStats

Statistics about the exactly-once registry