List of all items
Structs
Macros
Functions
- atomic::check_atomic_conflict_aborts_all
- atomic::check_atomic_empty_batch_is_noop
- atomic::check_atomic_multi_stream_commits_all
- boundary::check_conflict_leaves_store_unchanged
- boundary::check_large_payload_round_trips
- boundary::check_max_length_event_type_round_trips
- boundary::check_metadata_absent_vs_present_distinct
- boundary::check_prefix_stream_ids_isolated
- boundary::check_version_gap_batch_rejected
- boundary::check_wrong_first_version_rejected
- lifecycle::check_reopen_conflict_state_intact
- lifecycle::check_reopen_preserves_events
- lifecycle::check_reopen_preserves_position_watermark
- lifecycle::check_reopen_subscription_catches_up
- linearizability::check_caught_up_boundary_race
- linearizability::check_concurrent_distinct_streams_all_land
- linearizability::check_concurrent_same_stream_single_winner
- linearizability::check_wake_after_idle
- row::append_event
- row::append_event_at
- row::append_rows
- row::assert_strictly_increasing
- row::drain_all
- row::drain_all_attributed
- row::drain_all_with_metadata
- row::drain_stream
- row::envelope_for
- row::row_of
- sequence::check_all_boundary_then_new_append
- sequence::check_all_empty_store_yields_none
- sequence::check_all_from_is_exclusive
- sequence::check_all_global_order_across_streams
- sequence::check_all_items_carry_their_stream_key
- sequence::check_all_metadata_round_trips
- sequence::check_all_multi_resume_cycles
- sequence::check_append_conflict_is_surfaced
- sequence::check_append_retry_after_conflict_succeeds
- sequence::check_append_returns_assigned_all_position
- sequence::check_append_then_read_round_trips
- sequence::check_empty_read_yields_none
- sequence::check_large_stream_completes
- sequence::check_multi_event_append_returns_last_position
- sequence::check_read_stream_from_is_inclusive
- sequence::check_read_stream_inclusive_read_all_exclusive_coexist
- sequence::check_subscription_absent_stream_waits_then_delivers
- sequence::check_subscription_all_backlog_then_caught_up_then_live
- sequence::check_subscription_backlog_then_caught_up_then_live
- sequence::check_subscription_beyond_head_filters_below_bound
- sequence::check_subscription_large_backlog_crosses_chunk_seam
- sequence::check_subscription_resume_strict_after
- sequence::check_two_subscribers_same_stream_both_receive
- sequence::check_versions_strictly_monotonic_and_fused
- snapshot::check_snapshot_absent_then_commit_then_found
- snapshot::check_snapshot_empty_state_round_trips
- snapshot::check_snapshot_extreme_positions_round_trip
- snapshot::check_snapshot_overwrite_latest_wins
- snapshot::check_snapshot_stale_on_schema_change