Knowledge Wiki Orchestrata Ultimate

Orchestrata Ultimate › Tests › Reference › postman › test_postman_signatures

Tests reference — tests/postman/test_postman_signatures.py

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

Prose pending.

tests/postman/test_postman_signatures.py

source · 297 tests · 2651 lines

Signature tests for orchestrata_ultimate-postman public classes.

Covers: postman.admin, postman.config, postman.delivery, postman.envelope, postman.error_handler, postman.event_emitting_postman, postman.exceptions, postman.filter, postman.governance, postman.guarantees, postman.health, postman.interfaces, postman.message_store, postman.metrics, postman.payload, postman.postman, postman.priority, postman.queue, postman.queue_manager, postman.receipt_store, postman.replay_engine, postman.router, postman.routing_rules, postman.subscription_manager, postman.sync_router, +1 more

Kind Name Line Description
class TestPostmanAdminSignatures 161 Signature tests for PostmanAdmin.
method TestPostmanAdminSignatures.test_init_params 164 init takes no parameters.
method TestPostmanAdminSignatures.test_list_agents 168 list_agents is async with no parameters.
method TestPostmanAdminSignatures.test_disconnect_agent 173 disconnect_agent is async with agent_id and reason.
method TestPostmanAdminSignatures.test_get_system_status 185 get_system_status is async with no parameters.
method TestPostmanAdminSignatures.test_export_config 190 export_config is async with no parameters.
method TestPostmanAdminSignatures.test_import_config 195 import_config is async with required config parameter.
class TestPostmanConfigManagerSignatures 209 Signature tests for PostmanConfigManager.
method TestPostmanConfigManagerSignatures.test_init_params 212 init has 4 optional parameters.
method TestPostmanConfigManagerSignatures.test_load 230 load is sync with no parameters.
method TestPostmanConfigManagerSignatures.test_reload 235 reload is sync with no parameters.
method TestPostmanConfigManagerSignatures.test_get 240 get has required key and optional default.
method TestPostmanConfigManagerSignatures.test_validate 250 validate has required config parameter.
method TestPostmanConfigManagerSignatures.test_on_change 258 on_change has required callback parameter.
method TestPostmanConfigManagerSignatures.test_stop_watch 268 stop_watch is sync with no parameters.
class TestDeliveryManagerSignatures 279 Signature tests for DeliveryManager.
method TestDeliveryManagerSignatures.test_init_params 282 init takes routing_engine, envelope_handler, and queue_manager,
method TestDeliveryManagerSignatures.test_deliver 298 deliver is async with envelope, payload required and mode optional.
method TestDeliveryManagerSignatures.test_get_status 312 get_status is async with required message_id.
method TestDeliveryManagerSignatures.test_cancel 322 cancel is async with required message_id.
method TestDeliveryManagerSignatures.test_retry 330 retry is async with required message_id.
class TestEnvelopeHandlerSignatures 344 Signature tests for EnvelopeHandler.
method TestEnvelopeHandlerSignatures.test_create 347 create has sender/recipient required and 5 optional params.
method TestEnvelopeHandlerSignatures.test_validate 371 validate has required envelope parameter.
method TestEnvelopeHandlerSignatures.test_serialize 379 serialize has required envelope parameter.
method TestEnvelopeHandlerSignatures.test_deserialize 384 deserialize has required data parameter.
method TestEnvelopeHandlerSignatures.test_is_expired 389 is_expired has required envelope parameter.
method TestEnvelopeHandlerSignatures.test_get_routing_key 394 get_routing_key has required envelope parameter.
method TestEnvelopeHandlerSignatures.test_extend_ttl 401 extend_ttl requires envelope and seconds.
method TestEnvelopeHandlerSignatures.test_validate_content_type 413 validate_content_type requires content_type.
class TestCircuitBreakerSignatures 426 Signature tests for CircuitBreaker.
method TestCircuitBreakerSignatures.test_init_params 429 init has 2 optional parameters.
method TestCircuitBreakerSignatures.test_is_open 441 is_open is sync with no parameters.
method TestCircuitBreakerSignatures.test_record_success 446 record_success is sync with no parameters.
method TestCircuitBreakerSignatures.test_record_failure 451 record_failure is sync with no parameters.
class TestPostmanErrorHandlerSignatures 462 Signature tests for PostmanErrorHandler.
method TestPostmanErrorHandlerSignatures.test_init_params 465 init has 2 optional parameters.
method TestPostmanErrorHandlerSignatures.test_handle 477 handle is async with required error and context.
method TestPostmanErrorHandlerSignatures.test_is_circuit_open 489 is_circuit_open is sync with required destination.
method TestPostmanErrorHandlerSignatures.test_record_success 499 record_success is sync with required destination.
method TestPostmanErrorHandlerSignatures.test_record_failure 506 record_failure is sync with required destination.
class TestEventEmittingPostmanSignatures 519 Signature tests for EventEmittingPostman.
method TestEventEmittingPostmanSignatures.test_init_params 522 init requires postman, event_bus is optional.
method TestEventEmittingPostmanSignatures.test_route 535 route is async with required packet.
method TestEventEmittingPostmanSignatures.test_acknowledge 543 acknowledge is async with required packet_id.
method TestEventEmittingPostmanSignatures.test_retry_failed 550 retry_failed is async with required packet_id.
class TestPostmanErrorSignatures 563 Signature tests for PostmanError.
method TestPostmanErrorSignatures.test_init_params 566 init requires message, error_code and context optional.
class TestMessageFilterSignatures 585 Signature tests for MessageFilter.
method TestMessageFilterSignatures.test_matches 588 matches requires envelope, payload, and criteria.
method TestMessageFilterSignatures.test_compile_filter 602 compile_filter requires criteria.
class TestPostmanGovernanceManagerSignatures 618 Signature tests for PostmanGovernanceManager.
method TestPostmanGovernanceManagerSignatures.test_init_params 621 init takes no parameters.
method TestPostmanGovernanceManagerSignatures.test_check_send_authority 628 check_send_authority is async with 3 required params.
method TestPostmanGovernanceManagerSignatures.test_check_topic_authority 642 check_topic_authority is async with 3 required params.
method TestPostmanGovernanceManagerSignatures.test_check_queue_authority 651 check_queue_authority is async with 3 required params.
method TestPostmanGovernanceManagerSignatures.test_check_admin_authority 660 check_admin_authority is async with sender and operation.
method TestPostmanGovernanceManagerSignatures.test_register_recipient 668 register_recipient is sync with sender and recipient.
method TestPostmanGovernanceManagerSignatures.test_unregister_recipient 676 unregister_recipient is sync with sender and recipient.
method TestPostmanGovernanceManagerSignatures.test_get_audit_log 684 get_audit_log is sync with required audit_id.
method TestPostmanGovernanceManagerSignatures.test_get_all_audit_logs 689 get_all_audit_logs is sync with no parameters.
class TestDeliveryGuaranteeManagerSignatures 700 Signature tests for DeliveryGuaranteeManager.
method TestDeliveryGuaranteeManagerSignatures.test_init_params 703 init has 4 optional parameters.
method TestDeliveryGuaranteeManagerSignatures.test_send 713 send is async with message_id, destinations, mode required.
method TestDeliveryGuaranteeManagerSignatures.test_acknowledge 727 acknowledge is async with message_id and destination.
method TestDeliveryGuaranteeManagerSignatures.test_negative_acknowledge 735 negative_acknowledge is async with 3 required params.
method TestDeliveryGuaranteeManagerSignatures.test_get_pending_acks 744 get_pending_acks is async with required message_id.
method TestDeliveryGuaranteeManagerSignatures.test_retry 751 retry is async with message_id and destination.
method TestDeliveryGuaranteeManagerSignatures.test_is_duplicate 759 is_duplicate is async with message_id and destination.
method TestDeliveryGuaranteeManagerSignatures.test_check_timeouts 767 check_timeouts is async with no parameters.
method TestDeliveryGuaranteeManagerSignatures.test_get_stats 772 get_stats is async with required message_id.
class TestHealthCheckerSignatures 785 Signature tests for HealthChecker.
method TestHealthCheckerSignatures.test_init_params 788 init has 6 optional parameters.
method TestHealthCheckerSignatures.test_check_redis 800 check_redis is async with no parameters.
method TestHealthCheckerSignatures.test_check_graph 805 check_graph is async with no parameters.
method TestHealthCheckerSignatures.test_get_overall_status 810 get_overall_status is async with no parameters.
class TestMessageStoreSignatures 821 Signature tests for MessageStore.
method TestMessageStoreSignatures.test_init_params 824 init has 6 optional connection parameters.
method TestMessageStoreSignatures.test_initialize 836 initialize is async with no parameters.
method TestMessageStoreSignatures.test_store 841 store is async with message_id, envelope, payload.
method TestMessageStoreSignatures.test_retrieve 855 retrieve is async with required message_id.
method TestMessageStoreSignatures.test_delete 860 delete is async with required message_id.
method TestMessageStoreSignatures.test_query 865 query is async with 6 optional filter parameters.
method TestMessageStoreSignatures.test_cleanup 878 cleanup is async with required older_than.
method TestMessageStoreSignatures.test_get_stats 886 get_stats is async with no parameters.
class TestPostmanMetricsCollectorSignatures 897 Signature tests for PostmanMetricsCollector.
method TestPostmanMetricsCollectorSignatures.test_init_params 900 init has 2 optional parameters.
method TestPostmanMetricsCollectorSignatures.test_record_message_sent 908 record_message_sent requires size_bytes and latency_ms.
method TestPostmanMetricsCollectorSignatures.test_record_message_received 920 record_message_received requires size_bytes.
method TestPostmanMetricsCollectorSignatures.test_record_message_failed 927 record_message_failed requires error_type.
method TestPostmanMetricsCollectorSignatures.test_record_queue_depth 934 record_queue_depth requires queue_name and depth.
method TestPostmanMetricsCollectorSignatures.test_get_snapshot 942 get_snapshot is sync with no parameters.
method TestPostmanMetricsCollectorSignatures.test_export_prometheus 947 export_prometheus is sync with no parameters.
method TestPostmanMetricsCollectorSignatures.test_export_json 952 export_json is sync with no parameters.
class TestPayloadHandlerSignatures 963 Signature tests for PayloadHandler.
method TestPayloadHandlerSignatures.test_validate 966 validate requires payload, content_type; max_size optional.
method TestPayloadHandlerSignatures.test_compress 982 compress requires payload.
method TestPayloadHandlerSignatures.test_decompress 987 decompress requires payload.
method TestPayloadHandlerSignatures.test_create_payload 992 create_payload requires data; content_type and compress optional.
method TestPayloadHandlerSignatures.test_encode 1008 encode requires data and content_type.
method TestPayloadHandlerSignatures.test_decode 1020 decode requires payload and content_type.
method TestPayloadHandlerSignatures.test_get_content_type 1028 get_content_type requires data.
class TestPostmanSignatures 1041 Signature tests for the main Postman class.
method TestPostmanSignatures.test_init_params 1044 init has optional config parameter.
method TestPostmanSignatures.test_initialize 1050 initialize is async with required config.
method TestPostmanSignatures.test_start 1056 start is async with no parameters.
method TestPostmanSignatures.test_stop 1061 stop is async with no parameters.
method TestPostmanSignatures.test_get_health 1066 get_health is async with no parameters.
method TestPostmanSignatures.test_get_metadata 1071 get_metadata is sync with no parameters.
method TestPostmanSignatures.test_register 1076 register requires agent_id and handler.
method TestPostmanSignatures.test_route 1088 route is async with required packet.
method TestPostmanSignatures.test_aroute 1093 aroute is async with required packet.
method TestPostmanSignatures.test_enqueue 1098 enqueue is async with required packet and optional priority.
method TestPostmanSignatures.test_dequeue 1108 dequeue is async with required volk_id.
method TestPostmanSignatures.test_get_queue_status 1113 get_queue_status is async with required volk_id.
method TestPostmanSignatures.test_acknowledge 1118 acknowledge is async with required packet_id.
method TestPostmanSignatures.test_retry_failed 1123 retry_failed is async with required packet_id.
class TestPriorityQueueImplSignatures 1134 Signature tests for PriorityQueueImpl.
method TestPriorityQueueImplSignatures.test_init_params 1137 init has optional checkpoint_path.
method TestPriorityQueueImplSignatures.test_enqueue 1144 enqueue is async with required entry.
method TestPriorityQueueImplSignatures.test_enqueue_with_priority 1149 enqueue_with_priority is async with entry and priority.
method TestPriorityQueueImplSignatures.test_dequeue 1157 dequeue is async with no parameters.
method TestPriorityQueueImplSignatures.test_peek 1162 peek is async with no parameters.
method TestPriorityQueueImplSignatures.test_size 1167 size is async with no parameters.
method TestPriorityQueueImplSignatures.test_is_empty 1172 is_empty is async with no parameters.
method TestPriorityQueueImplSignatures.test_clear 1177 clear is async with no parameters.
method TestPriorityQueueImplSignatures.test_boost_priority 1182 boost_priority is async with entry_id and new_priority.
method TestPriorityQueueImplSignatures.test_get_by_priority 1190 get_by_priority is async with required priority.
method TestPriorityQueueImplSignatures.test_checkpoint 1197 checkpoint is async with no parameters.
method TestPriorityQueueImplSignatures.test_recover 1202 recover is async with no parameters.
class TestPrioritySchedulerSignatures 1213 Signature tests for PriorityScheduler.
method TestPrioritySchedulerSignatures.test_init_params 1216 init requires queue, age_boost_threshold is optional.
method TestPrioritySchedulerSignatures.test_get_next 1229 get_next is async with no parameters.
method TestPrioritySchedulerSignatures.test_check_starvation 1234 check_starvation is async with no parameters.
method TestPrioritySchedulerSignatures.test_get_priority_stats 1239 get_priority_stats is async with no parameters.
method TestPrioritySchedulerSignatures.test_detect_priority_inversion 1244 detect_priority_inversion is async with no parameters.
class TestBaseQueueSignatures 1255 Signature tests for BaseQueue.
method TestBaseQueueSignatures.test_init_params 1258 init requires name.
method TestBaseQueueSignatures.test_enqueue 1263 enqueue is async with required entry.
method TestBaseQueueSignatures.test_dequeue 1268 dequeue is async with no parameters.
method TestBaseQueueSignatures.test_peek 1273 peek is async with no parameters.
method TestBaseQueueSignatures.test_size 1278 size is async with no parameters.
method TestBaseQueueSignatures.test_clear 1283 clear is async with no parameters.
method TestBaseQueueSignatures.test_is_empty 1288 is_empty is async with no parameters.
method TestBaseQueueSignatures.test_close 1293 close is async with no parameters.
method TestBaseQueueSignatures.test_checkpoint 1298 checkpoint is async with no parameters.
method TestBaseQueueSignatures.test_recover 1303 recover is async with no parameters.
class TestInMemoryQueueSignatures 1314 Signature tests for InMemoryQueue.
method TestInMemoryQueueSignatures.test_init_params 1317 init requires name.
method TestInMemoryQueueSignatures.test_checkpoint 1322 checkpoint is async with no parameters.
method TestInMemoryQueueSignatures.test_recover 1327 recover is async with no parameters.
class TestDiskBackedQueueSignatures 1338 Signature tests for DiskBackedQueue.
method TestDiskBackedQueueSignatures.test_init_params 1341 init requires name; storage_path is optional.
method TestDiskBackedQueueSignatures.test_checkpoint 1352 checkpoint is async with no parameters.
method TestDiskBackedQueueSignatures.test_close 1357 close is async with no parameters.
method TestDiskBackedQueueSignatures.test_recover 1362 recover is async with no parameters.
class TestBoundedQueueSignatures 1373 Signature tests for BoundedQueue.
method TestBoundedQueueSignatures.test_init_params 1376 init has all 4 optional parameters.
method TestBoundedQueueSignatures.test_enqueue 1392 enqueue is async with required entry.
method TestBoundedQueueSignatures.test_dequeue 1397 dequeue is async with no parameters.
method TestBoundedQueueSignatures.test_peek 1402 peek is async with no parameters.
method TestBoundedQueueSignatures.test_size 1407 size is async with no parameters.
method TestBoundedQueueSignatures.test_clear 1412 clear is async with no parameters.
method TestBoundedQueueSignatures.test_is_empty 1417 is_empty is async with no parameters.
method TestBoundedQueueSignatures.test_close 1422 close is async with no parameters.
method TestBoundedQueueSignatures.test_checkpoint 1427 checkpoint is async with no parameters.
method TestBoundedQueueSignatures.test_recover 1432 recover is async with no parameters.
class TestPriorityQueueSignatures 1443 Signature tests for PriorityQueue from the queue module.
method TestPriorityQueueSignatures.test_init_params 1446 init requires name.
method TestPriorityQueueSignatures.test_enqueue 1451 enqueue is async with required entry.
method TestPriorityQueueSignatures.test_checkpoint 1456 checkpoint is async with no parameters.
method TestPriorityQueueSignatures.test_recover 1461 recover is async with no parameters.
class TestRedisQueueSignatures 1472 Signature tests for RedisQueue.
method TestRedisQueueSignatures.test_init_params 1475 init requires name; redis connection params optional.
method TestRedisQueueSignatures.test_enqueue 1490 enqueue is async with required entry.
method TestRedisQueueSignatures.test_dequeue 1495 dequeue is async with no parameters.
method TestRedisQueueSignatures.test_peek 1500 peek is async with no parameters.
method TestRedisQueueSignatures.test_size 1505 size is async with no parameters.
method TestRedisQueueSignatures.test_clear 1510 clear is async with no parameters.
method TestRedisQueueSignatures.test_is_empty 1515 is_empty is async with no parameters.
method TestRedisQueueSignatures.test_close 1520 close is async with no parameters.
method TestRedisQueueSignatures.test_checkpoint 1525 checkpoint is async with no parameters.
method TestRedisQueueSignatures.test_recover 1530 recover is async with no parameters.
class TestQueueManagerSignatures 1541 Signature tests for QueueManager.
method TestQueueManagerSignatures.test_init_params 1544 init has optional storage_path.
method TestQueueManagerSignatures.test_create_queue 1551 create_queue is async with name and config.
method TestQueueManagerSignatures.test_delete_queue 1563 delete_queue is async with required name.
method TestQueueManagerSignatures.test_get_queue 1568 get_queue is async with required name.
method TestQueueManagerSignatures.test_list_queues 1573 list_queues is async with no parameters.
method TestQueueManagerSignatures.test_get_status 1578 get_status is async with required name.
method TestQueueManagerSignatures.test_purge_queue 1583 purge_queue is async with required name.
method TestQueueManagerSignatures.test_get_dead_letter_queue 1588 get_dead_letter_queue is async with no parameters.
method TestQueueManagerSignatures.test_close_all 1593 close_all is async with no parameters.
class TestReceiptStoreSignatures 1604 Signature tests for ReceiptStore.
method TestReceiptStoreSignatures.test_init_params 1607 init has 6 optional connection parameters.
method TestReceiptStoreSignatures.test_initialize 1619 initialize is async with no parameters.
method TestReceiptStoreSignatures.test_store 1624 store is async with required receipt.
method TestReceiptStoreSignatures.test_get 1630 get is async with required message_id.
method TestReceiptStoreSignatures.test_query 1635 query is async with 5 optional filter parameters.
method TestReceiptStoreSignatures.test_expire 1647 expire is async with required older_than.
class TestReplayEngineSignatures 1661 Signature tests for ReplayEngine.
method TestReplayEngineSignatures.test_init_params 1664 init has message_store, receipt_store required and 4 optional.
method TestReplayEngineSignatures.test_initialize 1681 initialize is async with no parameters.
method TestReplayEngineSignatures.test_replay 1686 replay is async with message_ids and options.
method TestReplayEngineSignatures.test_replay_by_query 1698 replay_by_query is async with 6 optional filter params.
method TestReplayEngineSignatures.test_cancel_replay 1711 cancel_replay is async with required replay_id.
class TestRoutingEngineSignatures 1724 Signature tests for RoutingEngine.
method TestRoutingEngineSignatures.test_init_params 1727 init has optional cache_ttl.
method TestRoutingEngineSignatures.test_get_routing_type 1732 get_routing_type is sync with required recipient.
method TestRoutingEngineSignatures.test_resolve 1739 resolve is async with required envelope.
method TestRoutingEngineSignatures.test_add_route 1744 add_route is async with pattern and destinations.
method TestRoutingEngineSignatures.test_remove_route 1752 remove_route is async with required pattern.
method TestRoutingEngineSignatures.test_invalidate_cache 1757 invalidate_cache is sync with optional pattern.
method TestRoutingEngineSignatures.test_subscribe_to_topic 1767 subscribe_to_topic is async with agent_id and topic_pattern.
method TestRoutingEngineSignatures.test_unsubscribe_from_topic 1775 unsubscribe_from_topic is async with agent_id and topic_pattern.
class TestRoutingRulesEngineSignatures 1789 Signature tests for RoutingRulesEngine.
method TestRoutingRulesEngineSignatures.test_init_params 1792 init has optional message_filter.
method TestRoutingRulesEngineSignatures.test_add_rule 1802 add_rule is async with required rule.
method TestRoutingRulesEngineSignatures.test_remove_rule 1807 remove_rule is async with required rule_id.
method TestRoutingRulesEngineSignatures.test_update_rule 1814 update_rule is async with rule_id and rule.
method TestRoutingRulesEngineSignatures.test_list_rules 1822 list_rules is async with no parameters.
method TestRoutingRulesEngineSignatures.test_evaluate 1827 evaluate is async with envelope and payload.
class TestSubscriptionManagerSignatures 1841 Signature tests for SubscriptionManager.
method TestSubscriptionManagerSignatures.test_init_params 1844 init takes no parameters.
method TestSubscriptionManagerSignatures.test_subscribe 1848 subscribe is async with agent_id, topic_pattern required and
method TestSubscriptionManagerSignatures.test_unsubscribe 1867 unsubscribe is async with agent_id and topic_pattern.
method TestSubscriptionManagerSignatures.test_unsubscribe_all 1875 unsubscribe_all is async with required agent_id.
method TestSubscriptionManagerSignatures.test_get_subscribers 1882 get_subscribers is async with required topic.
method TestSubscriptionManagerSignatures.test_get_subscriptions 1889 get_subscriptions is async with required agent_id.
method TestSubscriptionManagerSignatures.test_match_subscribers 1894 match_subscribers is async with required topic.
class TestSyncRouterMixinSignatures 1905 Signature tests for SyncRouterMixin.
method TestSyncRouterMixinSignatures.test_route_sync 1908 route_sync is sync with required packet.
method TestSyncRouterMixinSignatures.test_get_thread_packets 1916 get_thread_packets is sync with required thread_id.
method TestSyncRouterMixinSignatures.test_get_log 1923 get_log is sync with no parameters.
class TestTopicRegistrySignatures 1934 Signature tests for TopicRegistry.
method TestTopicRegistrySignatures.test_init_params 1937 init takes no parameters.
method TestTopicRegistrySignatures.test_create_topic 1941 create_topic is async with required definition.
method TestTopicRegistrySignatures.test_delete_topic 1948 delete_topic is async with required topic_id.
method TestTopicRegistrySignatures.test_get_topic 1955 get_topic is async with required topic_id.
method TestTopicRegistrySignatures.test_list_topics 1960 list_topics is async with optional pattern.
method TestTopicRegistrySignatures.test_match_topics 1968 match_topics is async with required pattern.
class TestIMessageEnvelopeSignatures 1982 Signature tests for IMessageEnvelope ABC.
method TestIMessageEnvelopeSignatures.test_create 1985 create has sender/recipient required, 5 optional.
method TestIMessageEnvelopeSignatures.test_validate 2001 validate requires envelope.
method TestIMessageEnvelopeSignatures.test_serialize 2005 serialize requires envelope.
method TestIMessageEnvelopeSignatures.test_deserialize 2011 deserialize requires data.
class TestIPayloadHandlerSignatures 2016 Signature tests for IPayloadHandler ABC.
method TestIPayloadHandlerSignatures.test_validate 2019 validate requires payload, content_type; max_size optional.
method TestIPayloadHandlerSignatures.test_compress 2031 compress requires payload.
method TestIPayloadHandlerSignatures.test_decompress 2035 decompress requires payload.
method TestIPayloadHandlerSignatures.test_create_payload 2039 create_payload requires data; content_type, compress optional.
class TestIRoutingEngineSignatures 2051 Signature tests for IRoutingEngine ABC.
method TestIRoutingEngineSignatures.test_resolve 2054 resolve is async with required envelope.
method TestIRoutingEngineSignatures.test_add_route 2059 add_route is async with pattern and destinations.
method TestIRoutingEngineSignatures.test_remove_route 2067 remove_route is async with required pattern.
method TestIRoutingEngineSignatures.test_invalidate_cache 2074 invalidate_cache is sync with optional pattern.
class TestIDeliveryManagerSignatures 2082 Signature tests for IDeliveryManager ABC.
method TestIDeliveryManagerSignatures.test_deliver 2085 deliver is async with envelope, payload required, mode optional.
method TestIDeliveryManagerSignatures.test_get_status 2098 get_status is async with required message_id.
method TestIDeliveryManagerSignatures.test_cancel 2105 cancel is async with required message_id.
class TestIQueueSignatures 2113 Signature tests for IQueue ABC.
method TestIQueueSignatures.test_enqueue 2116 enqueue is async with required entry.
method TestIQueueSignatures.test_dequeue 2121 dequeue is async with no parameters.
method TestIQueueSignatures.test_peek 2126 peek is async with no parameters.
method TestIQueueSignatures.test_size 2131 size is async with no parameters.
method TestIQueueSignatures.test_clear 2136 clear is async with no parameters.
method TestIQueueSignatures.test_checkpoint 2141 checkpoint is async with no parameters.
method TestIQueueSignatures.test_recover 2146 recover is async with no parameters.
class TestIPriorityQueueSignatures 2152 Signature tests for IPriorityQueue ABC.
method TestIPriorityQueueSignatures.test_enqueue_with_priority 2155 enqueue_with_priority is async with entry and priority.
method TestIPriorityQueueSignatures.test_boost_priority 2163 boost_priority is async with entry_id and new_priority.
method TestIPriorityQueueSignatures.test_get_by_priority 2171 get_by_priority is async with required priority.
class TestIQueueManagerSignatures 2179 Signature tests for IQueueManager ABC.
method TestIQueueManagerSignatures.test_create_queue 2182 create_queue is async with name and config.
method TestIQueueManagerSignatures.test_delete_queue 2190 delete_queue is async with required name.
method TestIQueueManagerSignatures.test_get_queue 2195 get_queue is async with required name.
method TestIQueueManagerSignatures.test_list_queues 2200 list_queues is async with no parameters.
method TestIQueueManagerSignatures.test_get_status 2205 get_status is async with required name.
method TestIQueueManagerSignatures.test_purge_queue 2210 purge_queue is async with required name.
method TestIQueueManagerSignatures.test_get_dead_letter_queue 2215 get_dead_letter_queue is async with no parameters.
class TestIDeliveryGuaranteeSignatures 2221 Signature tests for IDeliveryGuarantee ABC.
method TestIDeliveryGuaranteeSignatures.test_send 2224 send is async with message_id, destinations, mode.
method TestIDeliveryGuaranteeSignatures.test_acknowledge 2233 acknowledge is async with message_id and destination.
method TestIDeliveryGuaranteeSignatures.test_negative_acknowledge 2241 negative_acknowledge is async with 3 required params.
method TestIDeliveryGuaranteeSignatures.test_get_pending_acks 2250 get_pending_acks is async with required message_id.
class TestITopicRegistrySignatures 2256 Signature tests for ITopicRegistry ABC.
method TestITopicRegistrySignatures.test_create_topic 2259 create_topic is async with required definition.
method TestITopicRegistrySignatures.test_delete_topic 2266 delete_topic is async with required topic_id.
method TestITopicRegistrySignatures.test_get_topic 2273 get_topic is async with required topic_id.
method TestITopicRegistrySignatures.test_list_topics 2278 list_topics is async with optional pattern.
method TestITopicRegistrySignatures.test_match_topics 2286 match_topics is async with required pattern.
class TestISubscriptionManagerSignatures 2294 Signature tests for ISubscriptionManager ABC.
method TestISubscriptionManagerSignatures.test_subscribe 2297 subscribe is async with agent_id, topic_pattern required,
method TestISubscriptionManagerSignatures.test_unsubscribe 2312 unsubscribe is async with agent_id and topic_pattern.
method TestISubscriptionManagerSignatures.test_unsubscribe_all 2320 unsubscribe_all is async with required agent_id.
method TestISubscriptionManagerSignatures.test_get_subscribers 2327 get_subscribers is async with required topic.
method TestISubscriptionManagerSignatures.test_get_subscriptions 2332 get_subscriptions is async with required agent_id.
method TestISubscriptionManagerSignatures.test_match_subscribers 2337 match_subscribers is async with required topic.
class TestIMessageStoreSignatures 2343 Signature tests for IMessageStore ABC.
method TestIMessageStoreSignatures.test_store 2346 store is async with message_id, envelope, payload.
method TestIMessageStoreSignatures.test_retrieve 2355 retrieve is async with required message_id.
method TestIMessageStoreSignatures.test_delete 2360 delete is async with required message_id.
method TestIMessageStoreSignatures.test_query 2365 query is async with 6 optional filter params.
method TestIMessageStoreSignatures.test_cleanup 2378 cleanup is async with required older_than.
method TestIMessageStoreSignatures.test_get_stats 2383 get_stats is async with no parameters.
class TestIReceiptStoreSignatures 2389 Signature tests for IReceiptStore ABC.
method TestIReceiptStoreSignatures.test_store 2392 store is async with required receipt.
method TestIReceiptStoreSignatures.test_get 2397 get is async with required message_id.
method TestIReceiptStoreSignatures.test_query 2402 query is async with 5 optional filter params.
method TestIReceiptStoreSignatures.test_expire 2414 expire is async with required older_than.
class TestIReplayEngineSignatures 2420 Signature tests for IReplayEngine ABC.
method TestIReplayEngineSignatures.test_replay 2423 replay is async with message_ids and options.
method TestIReplayEngineSignatures.test_replay_by_query 2431 replay_by_query is async with 6 optional filter params.
method TestIReplayEngineSignatures.test_cancel_replay 2444 cancel_replay is async with required replay_id.
class TestIMetricsCollectorSignatures 2452 Signature tests for IMetricsCollector ABC.
method TestIMetricsCollectorSignatures.test_record_message_sent 2455 record_message_sent requires size_bytes and latency_ms.
method TestIMetricsCollectorSignatures.test_record_message_received 2463 record_message_received requires size_bytes.
method TestIMetricsCollectorSignatures.test_record_message_failed 2470 record_message_failed requires error_type.
method TestIMetricsCollectorSignatures.test_record_queue_depth 2477 record_queue_depth requires queue_name and depth.
method TestIMetricsCollectorSignatures.test_get_snapshot 2485 get_snapshot takes no parameters.
method TestIMetricsCollectorSignatures.test_export_prometheus 2490 export_prometheus takes no parameters.
method TestIMetricsCollectorSignatures.test_export_json 2495 export_json takes no parameters.
class TestIErrorHandlerSignatures 2501 Signature tests for IErrorHandler ABC.
method TestIErrorHandlerSignatures.test_handle 2504 handle is async with error and context.
method TestIErrorHandlerSignatures.test_is_circuit_open 2512 is_circuit_open is sync with required destination.
method TestIErrorHandlerSignatures.test_record_success 2519 record_success is sync with required destination.
method TestIErrorHandlerSignatures.test_record_failure 2526 record_failure is sync with required destination.
class TestIAdminInterfaceSignatures 2534 Signature tests for IAdminInterface ABC.
method TestIAdminInterfaceSignatures.test_list_agents 2537 list_agents is async with no parameters.
method TestIAdminInterfaceSignatures.test_disconnect_agent 2542 disconnect_agent is async with agent_id and reason.
method TestIAdminInterfaceSignatures.test_get_system_status 2550 get_system_status is async with no parameters.
method TestIAdminInterfaceSignatures.test_export_config 2555 export_config is async with no parameters.
method TestIAdminInterfaceSignatures.test_import_config 2560 import_config is async with required config.
class TestIMessageFilterSignatures 2568 Signature tests for IMessageFilter ABC.
method TestIMessageFilterSignatures.test_matches 2571 matches requires envelope, payload, criteria.
method TestIMessageFilterSignatures.test_compile_filter 2580 compile_filter requires criteria.
class TestIRoutingRulesSignatures 2588 Signature tests for IRoutingRules ABC.
method TestIRoutingRulesSignatures.test_add_rule 2591 add_rule is async with required rule.
method TestIRoutingRulesSignatures.test_remove_rule 2596 remove_rule is async with required rule_id.
method TestIRoutingRulesSignatures.test_update_rule 2601 update_rule is async with rule_id and rule.
method TestIRoutingRulesSignatures.test_list_rules 2609 list_rules is async with no parameters.
method TestIRoutingRulesSignatures.test_evaluate 2614 evaluate is async with envelope and payload.
class TestIPostmanConfigSignatures 2623 Signature tests for IPostmanConfig ABC.
method TestIPostmanConfigSignatures.test_load 2626 load takes no parameters.
method TestIPostmanConfigSignatures.test_reload 2631 reload takes no parameters.
method TestIPostmanConfigSignatures.test_get 2636 get has required key and optional default.
method TestIPostmanConfigSignatures.test_validate 2643 validate requires config.
method TestIPostmanConfigSignatures.test_on_change 2648 on_change requires callback.