Knowledge Wiki Orchestrata Ultimate

Orchestrata Ultimate › Tests › Reference › postman › test_queue

Tests reference — tests/postman/test_queue.py

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

Prose pending.

tests/postman/test_queue.py

source · 39 tests · 999 lines

Tests for Postman Queue Module

Covers: postman.exceptions, postman.queue, postman.types

Kind Name Line Description
class TestInMemoryQueue 114 Test InMemoryQueue implementation.
method TestInMemoryQueue.test_enqueue_dequeue 117 Test basic enqueue and dequeue operations.
method TestInMemoryQueue.test_peek 137 Test peek operation (view without removing).
method TestInMemoryQueue.test_size_and_is_empty 154 Test size and is_empty operations.
method TestInMemoryQueue.test_clear 182 Test clearing all entries from queue.
method TestInMemoryQueue.test_dequeue_from_empty_queue 201 Test dequeuing from empty queue returns None.
method TestInMemoryQueue.test_peek_empty_queue 206 Test peeking at empty queue returns None.
method TestInMemoryQueue.test_fifo_ordering 211 Test FIFO ordering of messages.
method TestInMemoryQueue.test_concurrent_enqueue 228 Test concurrent enqueue operations.
method TestInMemoryQueue.test_concurrent_dequeue 247 Test concurrent dequeue operations.
method TestInMemoryQueue.test_checkpoint_recover 273 Test checkpoint and recover (no-op for in-memory queue).
class TestDiskBackedQueue 293 Test DiskBackedQueue implementation.
method TestDiskBackedQueue.test_enqueue_with_checkpoint 296 Test enqueue with automatic checkpoint.
method TestDiskBackedQueue.test_recover 313 Test recovering queue state from disk.
method TestDiskBackedQueue.test_checkpoint_on_dequeue 344 Test automatic checkpoint after dequeue.
method TestDiskBackedQueue.test_checkpoint_on_clear 366 Test automatic checkpoint after clear.
method TestDiskBackedQueue.test_recover_nonexistent_file 388 Test recover when checkpoint file doesn't exist.
method TestDiskBackedQueue.test_checkpoint_atomicity 394 Test checkpoint uses atomic write (temp file + rename).
method TestDiskBackedQueue.test_serialization_deserialization 413 Test queue entry serialization and deserialization.
method TestDiskBackedQueue.test_close_with_final_checkpoint 448 Test close ensures final checkpoint.
class TestPriorityQueue 472 Test PriorityQueue implementation.
method TestPriorityQueue.test_priority_ordering 475 Test messages are dequeued in priority order.
method TestPriorityQueue.test_fifo_within_same_priority 507 Test FIFO ordering within same priority level.
method TestPriorityQueue.test_mixed_priority_fifo 523 Test FIFO within priority with mixed priorities.
method TestPriorityQueue.test_insert_between_priorities 553 Test inserting entries between existing priority levels.
method TestPriorityQueue.test_peek_respects_priority 583 Test peek returns highest priority entry.
class TestBoundedQueue 610 Test BoundedQueue implementation.
method TestBoundedQueue.test_reject_policy 613 Test reject overflow policy.
method TestBoundedQueue.test_drop_oldest_policy 641 Test drop_oldest overflow policy.
method TestBoundedQueue.test_max_size_property 674 Test max_size property.
method TestBoundedQueue.test_wraps_in_memory_queue 678 Test BoundedQueue wraps InMemoryQueue by default.
method TestBoundedQueue.test_wraps_custom_queue 698 Test BoundedQueue can wrap custom queue.
method TestBoundedQueue.test_delegates_operations 719 Test BoundedQueue delegates to underlying queue.
method TestBoundedQueue.test_invalid_overflow_policy 740 Test invalid overflow policy raises ValueError.
method TestBoundedQueue.test_requires_name_or_base_queue 747 Test BoundedQueue requires name or base_queue.
class TestTTLExpiration 760 Test TTL expiration handling.
method TestTTLExpiration.test_entry_is_expired 763 Test QueueEntry.is_expired method.
method TestTTLExpiration.test_expired_entry_in_queue 793 Test handling expired entries in queue.
class TestRetryHandling 816 Test retry handling.
method TestRetryHandling.test_can_retry 819 Test QueueEntry.can_retry method.
class TestConcurrentAccess 857 Test concurrent queue access.
method TestConcurrentAccess.test_concurrent_mixed_operations 860 Test mixed concurrent enqueue and dequeue operations.
method TestConcurrentAccess.test_concurrent_peek 901 Test concurrent peek operations.
class TestEdgeCases 935 Test edge cases and error conditions.
method TestEdgeCases.test_large_queue 938 Test queue with large number of entries.
method TestEdgeCases.test_checkpoint_error_handling 955 Test checkpoint error handling.
method TestEdgeCases.test_recover_invalid_json 982 Test recover with invalid JSON file.