Orchestrata Ultimate › Tests › Reference › test_postman
Tests reference — tests/test_postman.py
Module of tests, split out because the directory page would be too large.
Prose pending.
tests/test_postman.py
source · 91 tests · 867 lines
Tests for orchestrata_ultimate.postman module.
Covers: postman.constants, postman.envelope, postman.exceptions, postman.filter, postman.guarantees, postman.queue_manager, postman.router, postman.subscription_manager, postman.topic_registry, postman.types
| Kind | Name | Line | Description |
|---|---|---|---|
| function | test_envelope_create_returns_envelope |
81 | |
| function | test_envelope_create_sets_priority |
93 | |
| function | test_envelope_create_sets_ttl |
104 | |
| function | test_envelope_create_invalid_sender_raises |
115 | |
| function | test_envelope_create_invalid_content_type_raises |
125 | |
| function | test_envelope_create_negative_ttl_raises |
135 | |
| function | test_envelope_create_ttl_exceeds_max_raises |
146 | |
| function | test_envelope_validate_valid_envelope |
157 | |
| function | test_envelope_serialize_deserialize_roundtrip |
167 | |
| function | test_envelope_deserialize_invalid_data_raises |
180 | |
| function | test_envelope_is_expired_not_expired |
186 | |
| function | test_envelope_get_routing_key |
197 | |
| function | test_envelope_extend_ttl_returns_new_envelope |
206 | |
| function | test_envelope_is_frozen |
219 | |
| function | test_envelope_message_id_is_unique |
228 | |
| function | test_envelope_correlation_id_not_in_envelope |
235 | |
| function | test_priority_ordering |
254 | |
| function | test_message_type_values_are_strings |
261 | |
| function | test_delivery_mode_three_modes_exist |
268 | |
| function | test_filter_matches_no_criteria |
290 | |
| function | test_filter_matches_sender_pattern_exact |
296 | |
| function | test_filter_matches_recipient_pattern_wildcard |
307 | |
| function | test_filter_matches_content_substring |
317 | |
| function | test_filter_matches_content_wildcard |
324 | |
| function | test_filter_matches_and_logic_all_must_match |
331 | |
| function | test_filter_matches_or_logic_one_is_enough |
340 | |
| function | test_filter_headers_always_false |
351 | |
| function | test_filter_compile_returns_callable |
357 | |
| function | test_filter_compile_callable_matches_correctly |
364 | |
| function | test_filter_topic_pattern_matches_recipient |
372 | |
| function | test_topic_registry_create_returns_id |
386 | |
| function | test_topic_registry_get_existing_topic |
394 | |
| function | test_topic_registry_get_nonexistent_returns_none |
403 | |
| function | test_topic_registry_delete_existing_topic |
409 | |
| function | test_topic_registry_delete_nonexistent_raises |
418 | |
| function | test_topic_registry_list_all_topics |
424 | |
| function | test_topic_registry_list_with_pattern_filters |
435 | |
| function | test_topic_registry_match_topics |
446 | |
| function | test_topic_registry_list_empty_registry |
454 | |
| function | test_subscription_manager_subscribe_returns_subscription |
465 | |
| function | test_subscription_manager_get_subscriptions |
472 | |
| function | test_subscription_manager_get_subscriptions_empty_agent |
482 | |
| function | test_subscription_manager_unsubscribe |
488 | |
| function | test_subscription_manager_unsubscribe_nonexistent_agent_raises |
497 | |
| function | test_subscription_manager_unsubscribe_wrong_pattern_raises |
503 | |
| function | test_subscription_manager_unsubscribe_all |
510 | |
| function | test_subscription_manager_unsubscribe_all_no_subs_returns_zero |
520 | |
| function | test_subscription_manager_get_subscribers_exact_match |
526 | |
| function | test_subscription_manager_get_subscribers_no_wildcard_expansion |
533 | |
| function | test_subscription_manager_match_subscribers_with_wildcard |
541 | |
| function | test_subscription_manager_match_subscribers_no_match |
548 | |
| function | test_subscription_manager_subscribe_with_ttl |
555 | |
| function | test_subscription_manager_multiple_agents_same_topic |
561 | |
| function | test_routing_engine_get_routing_type_broadcast_star |
575 | |
| function | test_routing_engine_get_routing_type_broadcast_keyword |
580 | |
| function | test_routing_engine_get_routing_type_multicast |
586 | |
| function | test_routing_engine_get_routing_type_direct |
591 | |
| function | test_routing_engine_get_routing_type_topic_dot |
597 | |
| function | test_routing_engine_get_routing_type_topic_wildcard |
602 | |
| function | test_routing_engine_get_routing_type_empty_raises |
607 | |
| function | test_routing_engine_resolve_broadcast |
613 | |
| function | test_routing_engine_resolve_direct_registered |
620 | |
| function | test_routing_engine_resolve_direct_unregistered_raises |
627 | |
| function | test_routing_engine_resolve_topic_with_subscriber |
634 | |
| function | test_routing_engine_resolve_topic_no_subscribers_raises |
645 | |
| function | test_routing_engine_add_route_and_resolve |
655 | |
| function | test_routing_engine_remove_route |
667 | |
| function | test_routing_engine_subscribe_and_unsubscribe |
676 | |
| function | test_routing_engine_non_orchestrator_cannot_broadcast |
683 | |
| function | test_routing_engine_cache_invalidation |
690 | |
| function | test_queue_manager_create_queue |
702 | |
| function | test_queue_manager_create_duplicate_raises |
710 | |
| function | test_queue_manager_delete_queue |
718 | |
| function | test_queue_manager_delete_nonexistent_returns_false |
728 | |
| function | test_queue_manager_list_queues_includes_created |
734 | |
| function | test_queue_manager_purge_queue |
745 | |
| function | test_queue_manager_purge_nonexistent_raises |
754 | |
| function | test_queue_manager_get_dead_letter_queue |
760 | |
| function | test_queue_manager_get_queue_returns_queue |
766 | |
| function | test_queue_manager_get_nonexistent_queue_returns_none |
774 | |
| function | test_delivery_guarantee_send_at_most_once_succeeds |
785 | |
| function | test_delivery_guarantee_send_at_least_once |
793 | |
| function | test_delivery_guarantee_send_exactly_once |
800 | |
| function | test_delivery_guarantee_exactly_once_deduplication |
806 | |
| function | test_delivery_guarantee_is_duplicate_after_exactly_once |
814 | |
| function | test_delivery_guarantee_is_not_duplicate_for_new_message |
821 | |
| function | test_delivery_guarantee_at_most_once_not_duplicate |
827 | |
| function | test_delivery_guarantee_acknowledge_removes_from_pending |
835 | |
| function | test_delivery_guarantee_check_timeouts_returns_list |
845 | |
| function | test_delivery_guarantee_negative_acknowledge_exhausts_retries |
852 | |
| function | test_delivery_guarantee_receipts_included_in_result |
859 |