# Test & Code Coverage Report
Generated: 2026-06-15T16:00:38.282888
## Summary
| Total Tests | 547 |
| Line Coverage | 90.0% (5805/6452) |
| Function Coverage | 88.1% (570/647) |
| Region Coverage | 89.8% (10068/11216) |
## Test Suites
| lib (unit tests) | 91 |
| main | 103 |
| api_error_tests | 6 |
| api_tests | 62 |
| concurrency_tests | 15 |
| integration_tests | 6 |
| memory_integration_tests | 4 |
| memory_storage_tests | 41 |
| message_tests | 25 |
| startup_gate_tests | 20 |
| storage_tests | 132 |
| ws_tests | 42 |
## Per-File Coverage
| [src/ws.rs](src/ws.rs) | 496/584 | 84.9% | 62/69 | 89.9% | 808/982 | 82.3% |
| [src/main.rs](src/main.rs) | 491/578 | 84.9% | 62/66 | 93.9% | 778/913 | 85.2% |
| [src/memory_storage.rs](src/memory_storage.rs) | 273/316 | 86.4% | 66/80 | 82.5% | 458/520 | 88.1% |
| [src/payload_store.rs](src/payload_store.rs) | 293/329 | 89.1% | 19/22 | 86.4% | 587/659 | 89.1% |
| [src/storage.rs](src/storage.rs) | 2514/2785 | 90.3% | 149/170 | 87.6% | 4876/5426 | 89.9% |
| [src/api.rs](src/api.rs) | 1042/1128 | 92.4% | 127/145 | 87.6% | 1405/1504 | 93.4% |
| [src/memory_monitor.rs](src/memory_monitor.rs) | 322/344 | 93.6% | 32/40 | 80.0% | 565/597 | 94.6% |
| [src/log_buffer.rs](src/log_buffer.rs) | 134/143 | 93.7% | 24/25 | 96.0% | 203/216 | 94.0% |
| [src/operation_timing.rs](src/operation_timing.rs) | 214/219 | 97.7% | 23/24 | 95.8% | 362/373 | 97.1% |
| [src/message.rs](src/message.rs) | 26/26 | 100.0% | 6/6 | 100.0% | 26/26 | 100.0% |
## Test Inventory
### lib (unit tests)
- `api::tests::test_ack_endpoint`
- `api::tests::test_consume_endpoint`
- `api::tests::test_create_queue_endpoint`
- `api::tests::test_nack_endpoint`
- `api::tests::test_publish_endpoint`
- `api::tests::test_stats_endpoint`
- `log_buffer::tests::test_log_buffer_captures_debug_and_trace_levels`
- `log_buffer::tests::test_log_buffer_captures_entries`
- `log_buffer::tests::test_log_buffer_default`
- `log_buffer::tests::test_log_buffer_history`
- `log_buffer::tests::test_log_buffer_ring_capacity`
- `log_buffer::tests::test_log_capture_does_not_spawn_tasks_sync`
- `memory_monitor::tests::test_cgroup_v1_limit_detection`
- `memory_monitor::tests::test_cgroup_v1_unlimited_returns_zero`
- `memory_monitor::tests::test_cgroup_v1_usage_fallback`
- `memory_monitor::tests::test_cgroup_v2_limit_detection`
- `memory_monitor::tests::test_cgroup_v2_unlimited_returns_zero`
- `memory_monitor::tests::test_cgroup_v2_usage_reading`
- `memory_monitor::tests::test_default_thresholds`
- `memory_monitor::tests::test_env_override_takes_precedence`
- `memory_monitor::tests::test_hysteresis_exits_at_70_percent`
- `memory_monitor::tests::test_limit_bytes_accessor`
- `memory_monitor::tests::test_memory_monitor_new_does_not_panic`
- `memory_monitor::tests::test_no_files_returns_zero_usage`
- `memory_monitor::tests::test_no_pressure_at_79_percent`
- `memory_monitor::tests::test_no_pressure_below_threshold`
- `memory_monitor::tests::test_pressure_at_81_percent`
- `memory_monitor::tests::test_pressure_detected_at_threshold`
- `memory_monitor::tests::test_pressure_with_explicit_limit`
- `memory_monitor::tests::test_proc_statm_fallback`
- `operation_timing::tests::concurrent_recording_is_safe`
- `operation_timing::tests::different_operations_independent`
- `operation_timing::tests::min_tracked_correctly`
- `operation_timing::tests::multiple_samples_same_second_aggregate`
- `operation_timing::tests::query_clamps_to_max_history`
- `operation_timing::tests::query_empty_store_returns_no_operations`
- `operation_timing::tests::query_fills_gaps_with_empty_buckets`
- `operation_timing::tests::query_returns_empty_buckets_for_stale_data`
- `operation_timing::tests::ring_buffer_wraps_after_max_history`
- `operation_timing::tests::single_sample_creates_bucket`
- `payload_store::tests::test_append_after_reopen_is_readable`
- `payload_store::tests::test_append_after_seal_survives_compaction`
- `payload_store::tests::test_append_and_read`
- `payload_store::tests::test_compact_aborts_on_unreadable_ref_without_deleting`
- `payload_store::tests::test_compact_rewrites_live_refs`
- `payload_store::tests::test_disk_usage`
- `payload_store::tests::test_many_appends_all_readable`
- `payload_store::tests::test_multiple_appends`
- `payload_store::tests::test_reopen_reads_existing_data`
- `storage::unit_tests::nack_with_delay_becomes_visible_after_unlock_expired_sweep`
- `storage::unit_tests::nack_with_delay_dlq_on_exhausted_retries`
- `storage::unit_tests::nack_with_delay_keeps_message_invisible_until_delay_elapses`
- `storage::unit_tests::nack_with_delay_rejects_wrong_consumer`
- `storage::unit_tests::queue_counters_ack_decrements_locked`
- `storage::unit_tests::queue_counters_batch_ack`
- `storage::unit_tests::queue_counters_batch_nack_mixed`
- `storage::unit_tests::queue_counters_delete_queue_removes_entry`
- `storage::unit_tests::queue_counters_full_lifecycle`
- `storage::unit_tests::queue_counters_get_all_queue_stats_from_cache`
- `storage::unit_tests::queue_counters_list_queues_from_cache`
- `storage::unit_tests::queue_counters_nack_dlq_decrements_locked`
- `storage::unit_tests::queue_counters_nack_retry_moves_locked_to_available`
- `storage::unit_tests::queue_counters_pop_moves_available_to_locked`
- `storage::unit_tests::queue_counters_purge_queue_zeros_counts`
- `storage::unit_tests::queue_counters_push_increments_available`
- `storage::unit_tests::queue_counters_rename_queue_moves_entry`
- `storage::unit_tests::queue_counters_seeded_on_restart`
- `storage::unit_tests::test_cold_storage_starvation_with_continuous_publish`
- `storage::unit_tests::test_default_block_cache_128mb`
- `storage::unit_tests::test_default_max_open_files_128`
- `storage::unit_tests::test_delete_and_purge_queue_emit_info_logs`
- `storage::unit_tests::test_empty_queue_dedup_set_reclaimed`
- `storage::unit_tests::test_empty_queue_hot_tier_removed`
- `storage::unit_tests::test_empty_queue_locked_index_cleaned`
- `storage::unit_tests::test_failed_pop_refills_hot_tier`
- `storage::unit_tests::test_has_duplicate_payload_mismatch_and_break_on_non_prefix_key`
- `storage::unit_tests::test_has_duplicate_payload_returns_true_for_unlocked_duplicate`
- `storage::unit_tests::test_hot_tier_starvation_recovery`
- `storage::unit_tests::test_locked_index_shrunk`
- `storage::unit_tests::test_memory_breakdown_reflects_state`
- `storage::unit_tests::test_memory_breakdown_returns_expected_fields`
- `storage::unit_tests::test_nonempty_dedup_set_shrunk`
- `storage::unit_tests::test_nonempty_queue_not_reclaimed`
- `storage::unit_tests::test_pop_treats_expired_lock_as_available`
- `storage::unit_tests::test_storage_new_loads_queue_config_from_db`
- `storage::unit_tests::test_storage_new_skips_invalid_queue_config_json`
- `storage::unit_tests::test_storage_new_warns_on_forced_queue_config_load_error`
- `storage::unit_tests::test_tracing_macros_execute_under_scoped_subscriber`
- `storage::unit_tests::test_unlock_expired_messages_handles_missing_and_corrupt_entries`
- `storage::unit_tests::test_unlock_expired_messages_unlocks_no_dup_queue_message`
- `storage::unit_tests::test_unlock_message_by_key_returns_false_for_unlocked_message`
### main
- `api::tests::test_ack_endpoint`
- `api::tests::test_consume_endpoint`
- `api::tests::test_create_queue_endpoint`
- `api::tests::test_nack_endpoint`
- `api::tests::test_publish_endpoint`
- `api::tests::test_stats_endpoint`
- `log_buffer::tests::test_log_buffer_captures_debug_and_trace_levels`
- `log_buffer::tests::test_log_buffer_captures_entries`
- `log_buffer::tests::test_log_buffer_default`
- `log_buffer::tests::test_log_buffer_history`
- `log_buffer::tests::test_log_buffer_ring_capacity`
- `log_buffer::tests::test_log_capture_does_not_spawn_tasks_sync`
- `memory_monitor::tests::test_cgroup_v1_limit_detection`
- `memory_monitor::tests::test_cgroup_v1_unlimited_returns_zero`
- `memory_monitor::tests::test_cgroup_v1_usage_fallback`
- `memory_monitor::tests::test_cgroup_v2_limit_detection`
- `memory_monitor::tests::test_cgroup_v2_unlimited_returns_zero`
- `memory_monitor::tests::test_cgroup_v2_usage_reading`
- `memory_monitor::tests::test_default_thresholds`
- `memory_monitor::tests::test_env_override_takes_precedence`
- `memory_monitor::tests::test_hysteresis_exits_at_70_percent`
- `memory_monitor::tests::test_limit_bytes_accessor`
- `memory_monitor::tests::test_memory_monitor_new_does_not_panic`
- `memory_monitor::tests::test_no_files_returns_zero_usage`
- `memory_monitor::tests::test_no_pressure_at_79_percent`
- `memory_monitor::tests::test_no_pressure_below_threshold`
- `memory_monitor::tests::test_pressure_at_81_percent`
- `memory_monitor::tests::test_pressure_detected_at_threshold`
- `memory_monitor::tests::test_pressure_with_explicit_limit`
- `memory_monitor::tests::test_proc_statm_fallback`
- `operation_timing::tests::concurrent_recording_is_safe`
- `operation_timing::tests::different_operations_independent`
- `operation_timing::tests::min_tracked_correctly`
- `operation_timing::tests::multiple_samples_same_second_aggregate`
- `operation_timing::tests::query_clamps_to_max_history`
- `operation_timing::tests::query_empty_store_returns_no_operations`
- `operation_timing::tests::query_fills_gaps_with_empty_buckets`
- `operation_timing::tests::query_returns_empty_buckets_for_stale_data`
- `operation_timing::tests::ring_buffer_wraps_after_max_history`
- `operation_timing::tests::single_sample_creates_bucket`
- `payload_store::tests::test_append_after_reopen_is_readable`
- `payload_store::tests::test_append_after_seal_survives_compaction`
- `payload_store::tests::test_append_and_read`
- `payload_store::tests::test_compact_aborts_on_unreadable_ref_without_deleting`
- `payload_store::tests::test_compact_rewrites_live_refs`
- `payload_store::tests::test_disk_usage`
- `payload_store::tests::test_many_appends_all_readable`
- `payload_store::tests::test_multiple_appends`
- `payload_store::tests::test_reopen_reads_existing_data`
- `storage::unit_tests::nack_with_delay_becomes_visible_after_unlock_expired_sweep`
- `storage::unit_tests::nack_with_delay_dlq_on_exhausted_retries`
- `storage::unit_tests::nack_with_delay_keeps_message_invisible_until_delay_elapses`
- `storage::unit_tests::nack_with_delay_rejects_wrong_consumer`
- `storage::unit_tests::queue_counters_ack_decrements_locked`
- `storage::unit_tests::queue_counters_batch_ack`
- `storage::unit_tests::queue_counters_batch_nack_mixed`
- `storage::unit_tests::queue_counters_delete_queue_removes_entry`
- `storage::unit_tests::queue_counters_full_lifecycle`
- `storage::unit_tests::queue_counters_get_all_queue_stats_from_cache`
- `storage::unit_tests::queue_counters_list_queues_from_cache`
- `storage::unit_tests::queue_counters_nack_dlq_decrements_locked`
- `storage::unit_tests::queue_counters_nack_retry_moves_locked_to_available`
- `storage::unit_tests::queue_counters_pop_moves_available_to_locked`
- `storage::unit_tests::queue_counters_purge_queue_zeros_counts`
- `storage::unit_tests::queue_counters_push_increments_available`
- `storage::unit_tests::queue_counters_rename_queue_moves_entry`
- `storage::unit_tests::queue_counters_seeded_on_restart`
- `storage::unit_tests::test_cold_storage_starvation_with_continuous_publish`
- `storage::unit_tests::test_default_block_cache_128mb`
- `storage::unit_tests::test_default_max_open_files_128`
- `storage::unit_tests::test_delete_and_purge_queue_emit_info_logs`
- `storage::unit_tests::test_empty_queue_dedup_set_reclaimed`
- `storage::unit_tests::test_empty_queue_hot_tier_removed`
- `storage::unit_tests::test_empty_queue_locked_index_cleaned`
- `storage::unit_tests::test_failed_pop_refills_hot_tier`
- `storage::unit_tests::test_has_duplicate_payload_mismatch_and_break_on_non_prefix_key`
- `storage::unit_tests::test_has_duplicate_payload_returns_true_for_unlocked_duplicate`
- `storage::unit_tests::test_hot_tier_starvation_recovery`
- `storage::unit_tests::test_locked_index_shrunk`
- `storage::unit_tests::test_memory_breakdown_reflects_state`
- `storage::unit_tests::test_memory_breakdown_returns_expected_fields`
- `storage::unit_tests::test_nonempty_dedup_set_shrunk`
- `storage::unit_tests::test_nonempty_queue_not_reclaimed`
- `storage::unit_tests::test_pop_treats_expired_lock_as_available`
- `storage::unit_tests::test_storage_new_loads_queue_config_from_db`
- `storage::unit_tests::test_storage_new_skips_invalid_queue_config_json`
- `storage::unit_tests::test_storage_new_warns_on_forced_queue_config_load_error`
- `storage::unit_tests::test_tracing_macros_execute_under_scoped_subscriber`
- `storage::unit_tests::test_unlock_expired_messages_handles_missing_and_corrupt_entries`
- `storage::unit_tests::test_unlock_expired_messages_unlocks_no_dup_queue_message`
- `storage::unit_tests::test_unlock_message_by_key_returns_false_for_unlocked_message`
- `tests::test_bind_listener_ephemeral_port`
- `tests::test_config_from_env_defaults`
- `tests::test_config_from_env_storage_mode_memory`
- `tests::test_main_exits_immediately_in_tests`
- `tests::test_server_memory_mode_serves_health`
- `tests::test_server_serves_health_and_shuts_down`
- `tests::test_shutdown_signal_returns_immediately_in_tests_when_not_forced`
- `tests::test_startup_gate_blocks_api_while_initializing`
- `tests::test_startup_gate_lifts_after_init`
- `tests::test_timeout_monitor_background_task`
- `tests::test_timeout_monitor_error_resilience`
- `tests::test_timeout_monitor_result_branches`
### api_error_tests
- `test_delete_queue_error_returns_500_with_json_error`
- `test_force_unlock_queue_error_returns_500`
- `test_purge_queue_error_returns_500_with_json_error`
- `test_queue_stats_storage_error_returns_404`
- `test_queues_storage_error_returns_500`
- `test_stats_storage_error_returns_500`
### api_tests
- `test_ack_message`
- `test_ack_wrong_consumer`
- `test_batch_ack_all_found`
- `test_batch_ack_empty_list`
- `test_batch_ack_partial_not_found`
- `test_batch_nack_all_unlocked`
- `test_batch_nack_missing_fields_rejected`
- `test_concurrent_api_operations`
- `test_consume_empty_queue`
- `test_consume_with_default_timeout`
- `test_create_queue_conflict`
- `test_create_queue_max_first`
- `test_create_queue_min_first`
- `test_default_queue_behavior`
- `test_delete_all_empty_server`
- `test_delete_all_removes_all_queues`
- `test_delete_all_with_dlq_allows_recreate`
- `test_delete_nonexistent_queue`
- `test_delete_queue_endpoint`
- `test_delete_queue_with_dlq_allows_recreate`
- `test_duplicate_payload_returns_400`
- `test_force_unlock_queue_endpoint`
- `test_force_unlock_queue_endpoint_nothing_locked`
- `test_health_endpoint`
- `test_invalid_json_handling`
- `test_list_queues_endpoint`
- `test_multiple_queue_configurations`
- `test_nack_message`
- `test_nack_wrong_consumer`
- `test_operation_timings_covers_all_api_operations`
- `test_operation_timings_custom_seconds`
- `test_operation_timings_default_window`
- `test_operation_timings_responsive_without_storage`
- `test_operation_timings_returns_200_when_idle`
- `test_priority_ordering_comprehensive`
- `test_priority_ordering_through_api`
- `test_publish_and_consume`
- `test_publish_message`
- `test_publish_message_minimal`
- `test_purge_all_empties_all_queues`
- `test_purge_all_empty_server`
- `test_purge_nonexistent_queue`
- `test_purge_queue_endpoint`
- `test_queue_isolation_through_api`
- `test_queue_metrics_endpoint_returns_time_series`
- `test_queue_stats_endpoint`
- `test_queue_stats_includes_live_rate_fields`
- `test_rename_queue_via_update`
- `test_stats_endpoint`
- `test_stats_includes_memory_fields`
- `test_text_priority_empty_returns_400`
- `test_text_priority_kind_mismatch_through_api`
- `test_text_priority_ordering_through_api`
- `test_text_priority_with_slash_succeeds`
- `test_update_queue_allow_duplicates`
- `test_update_queue_empty_name_returns_bad_request`
- `test_update_queue_nonexistent`
- `test_update_queue_rename`
- `test_update_queue_rename_and_allow_duplicates`
- `test_update_queue_rename_to_empty_string_returns_bad_request`
- `test_update_queue_rename_to_existing_returns_conflict`
- `test_webui_served_from_configurable_directory`
### concurrency_tests
- `test_get_all_queue_stats_returns_all_queues_memory`
- `test_get_all_queue_stats_returns_all_queues_rocksdb`
- `test_log_buffer_sync_ring_eviction`
- `test_log_capture_does_not_spawn_tasks`
- `test_memory_concurrent_nodup_push_different_payloads`
- `test_memory_concurrent_nodup_push_same_payload`
- `test_memory_concurrent_nodup_push_stress`
- `test_memory_concurrent_pop_no_double_delivery`
- `test_memory_no_deadlock_push_vs_ack`
- `test_memory_no_deadlock_push_vs_batch_ack`
- `test_memory_no_deadlock_push_vs_nack`
- `test_rocksdb_concurrent_nodup_push_different_payloads`
- `test_rocksdb_concurrent_nodup_push_same_payload`
- `test_rocksdb_concurrent_pop_no_double_delivery`
- `test_rocksdb_pop_stress_no_double_delivery`
### integration_tests
- `test_data_persistence_across_restarts`
- `test_failed_message_processing`
- `test_mixed_queue_operations`
- `test_multi_consumer_load_balancing`
- `test_order_processing_workflow`
- `test_system_health_monitoring`
### memory_integration_tests
- `test_api_with_memory_storage_health`
- `test_api_with_memory_storage_publish_consume_ack`
- `test_api_with_memory_storage_stats`
- `test_timeout_monitor_with_memory_storage`
### memory_storage_tests
- `test_configure_queue_disable_duplicates_dedupes_messages`
- `test_configure_queue_enable_duplicates_drops_payload_set`
- `test_memory_ack_fast_path_cleans_stale_secondary_index_entry`
- `test_memory_ack_removes`
- `test_memory_ack_uses_secondary_index`
- `test_memory_batch_ack`
- `test_memory_batch_ack_fast_path_cleans_stale_index_entries`
- `test_memory_batch_nack`
- `test_memory_batch_nack_fast_path_cleans_stale_index_entries`
- `test_memory_delete_queue`
- `test_memory_delete_queue_removes_dlq_entries`
- `test_memory_duplicate_rejection`
- `test_memory_fifo_ordering`
- `test_memory_force_unlock_queue`
- `test_memory_force_unlock_queue_empty`
- `test_memory_list_queues`
- `test_memory_nack_dead_letter`
- `test_memory_nack_fast_path_cleans_stale_secondary_index_entry`
- `test_memory_nack_unlocks`
- `test_memory_priority_ordering_max_first`
- `test_memory_priority_ordering_min_first`
- `test_memory_purge_queue`
- `test_memory_push_and_pop`
- `test_memory_queue_counters_track_full_lifecycle`
- `test_memory_queue_exists`
- `test_memory_queue_stats`
- `test_memory_rename_queue`
- `test_memory_rename_queue_already_exists_returns_error`
- `test_memory_rename_queue_empty_name_returns_storage_error`
- `test_memory_rename_queue_not_found_returns_error`
- `test_memory_rename_queue_same_name_returns_ok`
- `test_memory_renew_fast_path_cleans_stale_secondary_index_entry`
- `test_memory_renew_lock`
- `test_memory_repop_of_expired_lock_does_not_double_count`
- `test_memory_text_priority_kind_mismatch`
- `test_memory_text_priority_max_first`
- `test_memory_text_priority_min_first`
- `test_memory_text_priority_slash_stats_not_corrupted`
- `test_memory_text_priority_with_slash_max_first`
- `test_memory_text_priority_with_slash_min_first`
- `test_memory_timeout_unlock`
### message_tests
- `test_message_clone`
- `test_message_creation`
- `test_message_debug`
- `test_message_priority_extremes`
- `test_message_retry_count_extremes`
- `test_message_serialization`
- `test_message_with_complex_payload`
- `test_payload_ref_and_hash_omitted_when_none`
- `test_payload_ref_and_hash_serde_roundtrip`
- `test_priority_default`
- `test_priority_display`
- `test_priority_kind`
- `test_priority_kind_default`
- `test_priority_ordering_debug_clone`
- `test_priority_ordering_default`
- `test_priority_ordering_enum`
- `test_queue_config_clone_debug`
- `test_queue_config_creation`
- `test_queue_config_default`
- `test_queue_config_serialization`
- `test_queue_config_with_different_orderings`
- `test_queue_stats_clone`
- `test_queue_stats_creation`
- `test_queue_stats_debug`
- `test_queue_stats_serialization`
### startup_gate_tests
- `test_ack_batch_blocked_during_init`
- `test_ack_blocked_during_init`
- `test_consume_blocked_during_init`
- `test_create_queue_blocked_during_init`
- `test_create_queue_works_after_init_completes`
- `test_delete_all_blocked_during_init`
- `test_delete_queue_blocked_during_init`
- `test_gate_lifts_when_flag_cleared`
- `test_health_allowed_during_init`
- `test_nack_batch_blocked_during_init`
- `test_nack_blocked_during_init`
- `test_operation_timings_allowed_during_init`
- `test_publish_blocked_during_init`
- `test_publish_works_after_init_completes`
- `test_purge_all_blocked_during_init`
- `test_purge_queue_blocked_during_init`
- `test_queue_stats_allowed_during_init`
- `test_queues_allowed_during_init`
- `test_stats_allowed_during_init`
- `test_update_queue_blocked_during_init`
### storage_tests
- `test_ack_fast_path_cleans_stale_secondary_index_entry`
- `test_ack_message`
- `test_ack_wrong_consumer`
- `test_allow_duplicates_default_true_allows_duplicate_payloads`
- `test_allow_duplicates_false_allows_same_payload_after_ack`
- `test_allow_duplicates_false_allows_same_payload_after_nack_to_dlq`
- `test_allow_duplicates_false_blocks_push_when_message_is_locked`
- `test_allow_duplicates_false_rejects_unlocked_duplicate_on_publish`
- `test_allow_duplicates_false_transition_nack_unlocks_not_drops`
- `test_batch_ack_all_found`
- `test_batch_ack_empty_list`
- `test_batch_ack_fallback_when_sticky_flag_set`
- `test_batch_ack_fast_path_after_sticky_cleared`
- `test_batch_ack_fast_path_cleans_stale_secondary_index_entries`
- `test_batch_ack_fast_path_returns_not_found_without_scan`
- `test_batch_ack_partial_not_found`
- `test_batch_ack_removes_from_locked_index`
- `test_batch_ack_wrong_consumer_not_acked`
- `test_batch_nack_all_unlocked_for_retry`
- `test_batch_nack_empty_list`
- `test_batch_nack_exceeded_retries_moves_to_dlq`
- `test_batch_nack_fallback_when_sticky_flag_set`
- `test_batch_nack_fast_path_after_sticky_cleared`
- `test_batch_nack_fast_path_cleans_stale_secondary_index_entries`
- `test_batch_nack_no_duplicates_push_rejected_while_locked`
- `test_batch_nack_wrong_consumer_not_nacked`
- `test_broken_payload_ref_cleanup_and_fresh_push`
- `test_compact_with_zero_live_refs_cleans_segments`
- `test_compaction_does_not_break_hot_tier`
- `test_concurrent_mixed_priority_queues`
- `test_concurrent_operations`
- `test_configure_queue_dedup_rebuild_updates_counters`
- `test_configure_queue_disabling_duplicates_dedupes_existing_unlocked_messages`
- `test_configure_queue_enabling_duplicates_does_not_modify_existing_messages`
- `test_create_queue_method`
- `test_delete_nonexistent_queue`
- `test_delete_queue`
- `test_delete_queue_removes_dlq_entries`
- `test_delete_queue_with_dlq_allows_recreate_via_api`
- `test_delete_queue_with_locked_messages`
- `test_diagnose_queue_detects_injected_drift`
- `test_diagnose_queue_reports_clean_state_after_normal_ops`
- `test_empty_queue_pop`
- `test_fifo_ordering_ignores_priority`
- `test_fifo_preserves_position_on_nack_retry`
- `test_force_unlock_queue_empty_returns_zero`
- `test_force_unlock_queue_isolation`
- `test_force_unlock_queue_mixed_locked_and_available`
- `test_force_unlock_queue_unlocks_all_locked_messages`
- `test_get_queue_config`
- `test_has_duplicate_payload_excludes_message_id`
- `test_integrity_scan_decrements_locked_for_locked_broken_message`
- `test_integrity_scan_deletes_broken_messages`
- `test_large_payloads_are_externalized`
- `test_message_locking`
- `test_message_persistence`
- `test_mixed_old_and_new_format_messages`
- `test_mixed_queue_configurations`
- `test_nack_fast_path_cleans_stale_secondary_index_entry`
- `test_nack_max_retries_dead_letter`
- `test_nack_message_retry`
- `test_nack_wrong_consumer`
- `test_old_format_messages_survive_full_lifecycle`
- `test_payload_store_ack_allows_repush_of_same_payload`
- `test_payload_store_duplicate_detection_with_externalized_payloads`
- `test_payload_store_nack_retry_preserves_payload`
- `test_payload_store_push_pop_ack_roundtrip`
- `test_payload_store_push_pop_many_after_restart`
- `test_payload_store_stress_push_pop_1000`
- `test_payload_store_survives_restart`
- `test_pop_returns_none_when_all_payloads_broken`
- `test_priority_ordering`
- `test_priority_ordering_edge_cases`
- `test_pset_allows_push_after_ack`
- `test_pset_batch_ack_removes_payloads`
- `test_pset_batch_nack_dlq_removes_payloads`
- `test_pset_blocks_push_while_locked`
- `test_pset_delete_clears_set`
- `test_pset_disable_constraint_drops_set`
- `test_pset_enable_constraint_builds_set`
- `test_pset_nack_dlq_allows_repush`
- `test_pset_nack_retry_keeps_payload_blocked`
- `test_pset_purge_clears_set`
- `test_pset_startup_reconstruction_blocks_push`
- `test_pset_startup_reconstruction_includes_locked`
- `test_pset_unlock_expired_retry_keeps_payload_blocked`
- `test_purge_nonexistent_queue`
- `test_purge_queue`
- `test_purge_queue_preserves_config`
- `test_push_and_pop_message`
- `test_push_message`
- `test_queue_configuration_default_behavior`
- `test_queue_configuration_max_first`
- `test_queue_configuration_min_first`
- `test_queue_isolation`
- `test_queue_isolation_delete_purge`
- `test_queue_stats_after_ack_nack`
- `test_queue_stats_empty_system`
- `test_queue_stats_multiple_queues`
- `test_queue_stats_nonexistent_queue`
- `test_queue_stats_single_queue`
- `test_queue_stats_with_locked_messages`
- `test_rename_queue_already_exists_returns_error`
- `test_rename_queue_does_not_touch_unrelated_locked_id_index_entries`
- `test_rename_queue_empty_name_returns_storage_error`
- `test_rename_queue_error_display`
- `test_rename_queue_leaves_unrelated_queue_locks_alone`
- `test_rename_queue_not_found_returns_error`
- `test_rename_queue_same_name_returns_ok`
- `test_renew_fast_path_cleans_stale_secondary_index_entry`
- `test_repop_of_expired_lock_does_not_double_count`
- `test_reseed_queue_counters_repairs_drift`
- `test_small_payloads_stay_inline`
- `test_stats_and_queue_listing_skip_invalid_and_corrupt_entries`
- `test_storage_new`
- `test_text_priority_fifo`
- `test_text_priority_kind_mismatch_rejected`
- `test_text_priority_max_first`
- `test_text_priority_max_first_prefix_ordering`
- `test_text_priority_min_first`
- `test_text_priority_slash_does_not_corrupt_queue_stats`
- `test_text_priority_validation`
- `test_text_priority_with_null_byte`
- `test_text_priority_with_slash_max_first`
- `test_text_priority_with_slash_min_first`
- `test_timeout_monitor_acked_message_cleanup`
- `test_timeout_monitor_mixed_expired_and_valid`
- `test_timeout_monitor_multiple_expired_messages`
- `test_timeout_monitor_no_expired_messages`
- `test_timeout_monitor_unlock_expired_messages`
- `test_unlock_expired_recovers_cap_overflow_lock`
- `test_unlock_expired_recovers_locks_after_restart`
### ws_tests
- `test_ws_ack_removes_message`
- `test_ws_batch_ack`
- `test_ws_batch_nack`
- `test_ws_binary_frame_rejected_with_1003`
- `test_ws_connection_close_releases_subscriptions`
- `test_ws_connection_upgrade`
- `test_ws_credit_flow_control`
- `test_ws_credit_on_unsubscribed_queue_returns_error`
- `test_ws_error_frame_echoes_req_id`
- `test_ws_frame_missing_type_field_returns_error`
- `test_ws_invalid_json_rejected_with_1007`
- `test_ws_multi_queue_subscribe`
- `test_ws_nack_unlocks_message`
- `test_ws_no_reply_suppresses_response`
- `test_ws_no_req_id_omitted_in_response`
- `test_ws_operations_update_rate_counters`
- `test_ws_ping_timeout_closes_with_1001`
- `test_ws_publish_missing_payload_field`
- `test_ws_publish_missing_queue_field`
- `test_ws_publish_nonexistent_queue_error`
- `test_ws_publish_success`
- `test_ws_renew_extends_lock`
- `test_ws_renew_not_locked_returns_error`
- `test_ws_renew_with_lock_timeout_secs`
- `test_ws_req_id_echoed_in_ok`
- `test_ws_session_ack_noreply`
- `test_ws_session_credit_flow_control`
- `test_ws_session_request_timeout`
- `test_ws_session_send_frame_public`
- `test_ws_subscribe_and_deliver`
- `test_ws_subscribe_default_lock_timeout`
- `test_ws_subscribe_logs_delivers_live_entries`
- `test_ws_subscribe_logs_with_large_history_does_not_deadlock`
- `test_ws_subscribe_logs_without_buffer_returns_error`
- `test_ws_subscribe_missing_queue_field`
- `test_ws_subscribe_nonexistent_queue_error`
- `test_ws_subscribe_same_queue_twice_is_ok`
- `test_ws_subscribe_with_lock_timeout_secs`
- `test_ws_subscribe_without_credits_is_unlimited`
- `test_ws_unknown_type_returns_error_frame_and_stays_open`
- `test_ws_unsubscribe_logs_stops_delivery`
- `test_ws_unsubscribe_stops_delivery`