Macros§
- backend_
contract_ tests - Unified contract test macro for all backend implementations.
Structs§
Functions§
- test_
basic_ read_ write - test_
batch_ limiting - Contract test: Batch limiting returns exactly the specified number of events
- test_
checkpoint_ independent_ subscriptions - Contract test: Different subscription names have independent checkpoints
- test_
checkpoint_ load_ missing_ returns_ none - Contract test: Loading a non-existent checkpoint returns None
- test_
checkpoint_ save_ and_ load - Contract test: Save a checkpoint and load it back
- test_
checkpoint_ update_ overwrites - Contract test: Saving a checkpoint overwrites the previous value
- test_
concurrent_ version_ conflicts - test_
conflict_ preserves_ atomicity - test_
event_ ordering_ across_ streams - Contract test: Events from multiple streams are read in global append order
- test_
missing_ stream_ reads - test_
position_ based_ resumption - Contract test: Position-based resumption works correctly
- test_
stream_ isolation - test_
stream_ prefix_ filtering - Contract test: Stream prefix filtering returns only matching streams
- test_
stream_ prefix_ requires_ prefix_ match - Contract test: Stream prefix filtering requires true prefix match (not substring match)