Orchestrata Ultimate › Tests › Reference › kernel › test_queue_manager_extended

Tests reference — tests/kernel/test_queue_manager_extended.py

Module of tests/kernel, split out because the directory page would be too large.

Prose pending.

tests/kernel/test_queue_manager_extended.py

source · 35 tests · 696 lines

Covers: kernel.queue_manager, core.packet/ (package)

Kind Name Line Description
class TestQueueStatsExtended 128
method TestQueueStatsExtended.test_to_dict_with_datetimes 129
method TestQueueStatsExtended.test_to_dict_with_none_datetimes 155
class TestQueueManagerConstruction 178
method TestQueueManagerConstruction.test_init_explicit_params 179
method TestQueueManagerConstruction.test_key_helpers 198
class TestQueueManagerLifecycle 212
method TestQueueManagerLifecycle.test_context_manager 213
method TestQueueManagerLifecycle.test_aclose_idempotent 225
method TestQueueManagerLifecycle.test_close_idempotent 238
method TestQueueManagerLifecycle.test_get_client_lazy 250
class TestQueueManagerEnqueueDequeue 268
method TestQueueManagerEnqueueDequeue.test_enqueue_and_dequeue 269
method TestQueueManagerEnqueueDequeue.test_dequeue_empty_queue 281
method TestQueueManagerEnqueueDequeue.test_dequeue_with_timeout 286
method TestQueueManagerEnqueueDequeue.test_enqueue_multiple_same_recipient 306
class TestQueueManagerPriority 328
method TestQueueManagerPriority.test_dequeue_highest_priority_first 329
method TestQueueManagerPriority.test_queue_depth_across_priorities 349
class TestQueueManagerBackpressure 366
method TestQueueManagerBackpressure.test_enqueue_rejects_when_full 367
class TestQueueManagerDeliveryTracking 385
method TestQueueManagerDeliveryTracking.test_record_delivery_success 386
method TestQueueManagerDeliveryTracking.test_record_delivery_failure 400
method TestQueueManagerDeliveryTracking.test_dequeue_increments_in_flight 418
class TestQueueManagerDeadLetter 433
method TestQueueManagerDeadLetter.test_move_to_dead_letter_success 434
method TestQueueManagerDeadLetter.test_move_to_dead_letter_missing_metadata 456
method TestQueueManagerDeadLetter.test_move_to_dead_letter_no_recipient_in_meta 460
class TestQueueManagerExpireStale 478
method TestQueueManagerExpireStale.test_expire_stale_messages_removes_old 479
method TestQueueManagerExpireStale.test_expire_stale_messages_none_found 532
class TestQueueManagerStats 550
method TestQueueManagerStats.test_get_stats_empty 551
method TestQueueManagerStats.test_get_stats_with_messages 562
method TestQueueManagerStats.test_get_stats_with_dlq_and_failed 577
method TestQueueManagerStats.test_stats_cache_updated 591
class TestQueueManagerInspect 604
method TestQueueManagerInspect.test_inspect_queue_returns_summaries 605
method TestQueueManagerInspect.test_inspect_queue_respects_limit 619
method TestQueueManagerInspect.test_inspect_queue_empty 629
method TestQueueManagerInspect.test_inspect_queue_priority_order 634
class TestQueueManagerMetadata 653
method TestQueueManagerMetadata.test_metadata_set_on_enqueue 654
method TestQueueManagerMetadata.test_metadata_updated_on_dequeue 666
class TestQueueManagerDepthEdgeCases 683
method TestQueueManagerDepthEdgeCases.test_get_queue_depth_zero 684
method TestQueueManagerDepthEdgeCases.test_get_queue_depth_after_dequeue 689