Struct DeterministicConflictStore 

pub struct DeterministicConflictStore<S> { /* private fields */ }

A wrapper around an event store that injects a deterministic number of version conflicts before delegating to the inner store.

This is useful for testing retry logic where you need predictable conflict behavior rather than the probabilistic chaos testing approach.

Examples

use eventcore_testing::deterministic::DeterministicConflictStore;
use eventcore_memory::InMemoryEventStore;

// Create a store that will fail with VersionConflict twice before succeeding
let inner = InMemoryEventStore::new();
let store = DeterministicConflictStore::new(inner, 2);

// First two append_events calls will return VersionConflict
// Third call will delegate to inner store

Implementations

impl<S> DeterministicConflictStore<S>

pub fn new(store: S, conflict_count: u32) -> Self

Creates a new DeterministicConflictStore that will inject conflict_count version conflicts before delegating to the inner store.

Arguments

• store - The inner event store to delegate to after conflicts are exhausted
• conflict_count - Number of conflicts to inject before delegation

Trait Implementations

impl<S> EventStore for DeterministicConflictStore<S>

where S: EventStore + Sync,

async fn read_stream<E: Event>( &self, stream_id: StreamId, ) -> Result<EventStreamReader<E>, EventStoreError>

Read all events from a stream.

async fn append_events( &self, writes: StreamWrites, ) -> Result<EventStreamSlice, EventStoreError>

Atomically append events to multiple streams with optimistic concurrency control.