Orchestrata Ultimate / RTM / 002-postman
RTM: 002-postman
Requirement to symbol to test rows for 002-postman: Postman Message Broker (U:PS).
At a glance
| Item | Value |
|---|---|
| Requirement IDs | 457 |
Traced from src/ |
227 (49.7%) |
| Untraced | 230 |
Cited from tests/ |
13 (2.8%) |
Traced in src/ but not cited from tests/ |
217 |
Reading this matrix
This matrix lists each of the 457 requirement IDs of spec 002-postman with the src/ symbols that cite it and the tests that cite it. 227 of them (49.7%) have at least one citing symbol and 230 have none.
13 requirements are also cited from tests/, and 217 are traced in code but never named by a test. A test citation is a @traces on a test function; it shows intent to cover, not that the test runs or reaches the symbol.
Rows showing none in the symbols column are the gaps to close first. The densest untraced groups are REQ-002-FR11 (37), REQ-002-US-010 (24), REQ-002-US-008 (21).
Requirement to symbols to tests
| Requirement | Symbols in src/ |
Tests citing it |
|---|---|---|
REQ-002-US-001-001 Agent can send messages through Postman service |
orchestrata_ultimate/postman/event_emitting_postman EventEmittingPostman L14orchestrata_ultimate/postman/interfaces IDeliveryManager L245orchestrata_ultimate/postman/interfaces deliver L255+1 more |
tests/postman/test_cxp_redis_delivery.py::test_e2e_volk_chain_through_redis |
REQ-002-US-001-002 Messages are routed to correct recipient agents |
orchestrata_ultimate/core/protocols/components route L137orchestrata_ultimate/postman/delivery DeliveryManager L48orchestrata_ultimate/postman/delivery _deliver_to_all L288+2 more |
tests/postman/test_cxp_redis_delivery.py::test_redis_required_not_in_memory |
REQ-002-US-001-003 Message delivery is acknowledged with receipts |
orchestrata_ultimate/postman/delivery DeliveryManager L48orchestrata_ultimate/postman/delivery deliver L107 |
tests/postman/test_cxp_redis_delivery.py::test_e2e_thread_packets_from_redis_not_memory |
REQ-002-US-001-004 Failed deliveries trigger retry mechanisms |
orchestrata_ultimate/postman/delivery DeliveryManager L48orchestrata_ultimate/postman/delivery retry L470orchestrata_ultimate/postman/error_handler PostmanErrorHandler L74+1 more |
none |
REQ-002-US-001-005 Delivery status is tracked and logged |
orchestrata_ultimate/postman/delivery DeliveryManager L48orchestrata_ultimate/postman/delivery _extract_message_id L182orchestrata_ultimate/postman/delivery _queue_message L227+7 more |
none |
REQ-002-US-001-006 Support for INFORM message type |
orchestrata_ultimate/postman/types MessageType L42 |
none |
REQ-002-US-001-007 Support for REQUEST message type |
orchestrata_ultimate/postman/types MessageType L42 |
none |
REQ-002-US-001-008 Support for QUERY message type |
orchestrata_ultimate/postman/types MessageType L42 |
none |
REQ-002-US-001-009 Support for RESPONSE message type |
orchestrata_ultimate/postman/types MessageType L42 |
none |
REQ-002-US-001-010 Support for ERROR message type |
orchestrata_ultimate/postman/types MessageType L42 |
none |
REQ-002-US-001-011 Support for NOTIFY message type |
orchestrata_ultimate/postman/types MessageType L42 |
none |
REQ-002-US-001-012 Support for SUBSCRIBE message type |
orchestrata_ultimate/postman/types MessageType L42 |
none |
REQ-002-US-001-013 Support for UNSUBSCRIBE message type |
orchestrata_ultimate/postman/types MessageType L42 |
none |
REQ-002-US-001-014 Direct agent-to-agent delivery |
none | none |
REQ-002-US-001-015 Broadcast delivery to multiple agents |
none | none |
REQ-002-US-001-016 Topic-based delivery |
orchestrata_ultimate/agents/tool_registry _publish_topic L1330orchestrata_ultimate/postman/postman publish_topic L210 |
none |
REQ-002-US-001-017 Queue-based delivery |
none | none |
REQ-002-US-001-018 Priority-based delivery |
none | none |
REQ-002-US-001-019 Handle recipient not found errors |
none | none |
REQ-002-US-001-020 Handle network timeout errors |
none | none |
REQ-002-US-001-021 Handle malformed message errors |
none | none |
REQ-002-US-001-022 Handle authentication errors |
none | none |
REQ-002-US-001-023 Handle authorization errors |
none | none |
REQ-002-US-001-024 Retry failed deliveries (up to 3 attempts) |
orchestrata_ultimate/core/protocols/components retry_failed L208orchestrata_ultimate/postman/error_handler __init__ L88orchestrata_ultimate/postman/exceptions MaxRetriesExceededError L161+2 more |
none |
REQ-002-US-001-025 Log all delivery failures |
none | none |
REQ-002-US-001-026 Notify sender of permanent failures |
orchestrata_ultimate/agents/kernel_handler _build_draining_packet L561 |
tests/agents/test_kernel_handler_ack_only.py::test_background_blocked_intent_emits_no_reply_terminaltests/agents/test_kernel_handler_ack_only.py::test_shutdown_cancels_and_sinks_failuretests/agents/test_message_volk_delivery_status.py::test_message_volk_reports_handler_error_as_failure |
REQ-002-US-001-027 Deliver messages within 100ms (p95) |
none | none |
REQ-002-US-001-028 Support 5000+ messages/second throughput |
none | none |
REQ-002-US-001-029 Handle concurrent deliveries efficiently |
none | none |
REQ-002-US-001-030 Maintain message ordering per sender-recipient pair |
none | none |
REQ-002-US-002-001 Agent can subscribe to topics |
orchestrata_ultimate/agents/tool_registry _subscribe_topic L1367orchestrata_ultimate/postman/interfaces ISubscriptionManager L661orchestrata_ultimate/postman/interfaces subscribe L671+1 more |
none |
REQ-002-US-002-002 Agent can unsubscribe from topics |
orchestrata_ultimate/agents/tool_registry _unsubscribe_topic L1401orchestrata_ultimate/postman/interfaces unsubscribe L698orchestrata_ultimate/postman/router unsubscribe_from_topic L409 |
none |
REQ-002-US-002-003 Agent can list subscribed topics |
orchestrata_ultimate/postman/topic_registry list_topics L103 |
none |
REQ-002-US-002-004 Support wildcard topic patterns (e.g., "agent.*") |
none | none |
REQ-002-US-002-005 Support hierarchical topic structures |
none | none |
REQ-002-US-002-006 Validate topic names on subscription |
orchestrata_ultimate/postman/exceptions InvalidTopicPatternError L231 |
none |
REQ-002-US-002-007 Deliver messages to all topic subscribers |
orchestrata_ultimate/agents/tool_registry _publish_topic L1330orchestrata_ultimate/postman/postman publish_topic L210 |
none |
REQ-002-US-002-008 Filter messages by topic match |
none | none |
REQ-002-US-002-009 Support multiple simultaneous subscriptions |
orchestrata_ultimate/postman/subscription_manager get_subscriptions L220 |
none |
REQ-002-US-002-010 Handle subscription conflicts gracefully |
none | none |
REQ-002-US-002-011 Maintain delivery order per topic |
none | none |
REQ-002-US-002-012 Persist subscriptions across restarts |
none | none |
REQ-002-US-002-013 Auto-unsubscribe on agent termination |
none | none |
REQ-002-US-002-014 Track subscription creation timestamp |
orchestrata_ultimate/postman/types TopicSubscription L662 |
none |
REQ-002-US-002-015 Track last message received timestamp |
orchestrata_ultimate/postman/types TopicSubscription L662 |
none |
REQ-002-US-002-016 Support subscription TTL (time-to-live) |
orchestrata_ultimate/postman/envelope extend_ttl L361orchestrata_ultimate/postman/types TopicSubscription L662orchestrata_ultimate/postman/types is_expired L689 |
none |
REQ-002-US-002-017 Subscribe/unsubscribe within 50ms |
none | none |
REQ-002-US-002-018 Deliver to 100+ subscribers per topic |
none | none |
REQ-002-US-002-019 Handle 1000+ active subscriptions |
none | none |
REQ-002-US-002-020 Efficient topic matching algorithm |
none | none |
REQ-002-US-003-001 Create named message queues |
orchestrata_ultimate/postman/interfaces create_queue L442orchestrata_ultimate/postman/queue_manager QueueManager L30orchestrata_ultimate/postman/queue_manager create_queue L69 |
none |
REQ-002-US-003-002 Delete message queues |
orchestrata_ultimate/postman/interfaces delete_queue L455orchestrata_ultimate/postman/queue_manager QueueManager L30orchestrata_ultimate/postman/queue_manager delete_queue L112 |
none |
REQ-002-US-003-003 List available queues |
orchestrata_ultimate/postman/interfaces list_queues L478orchestrata_ultimate/postman/queue_manager QueueManager L30orchestrata_ultimate/postman/queue_manager list_queues L164 |
none |
REQ-002-US-003-004 Query queue metadata (size, age, etc.) |
orchestrata_ultimate/core/protocols/components get_queue_status L185orchestrata_ultimate/postman/interfaces get_status L487orchestrata_ultimate/postman/postman QueueStatus L73+3 more |
none |
REQ-002-US-003-005 Purge queue contents |
orchestrata_ultimate/postman/interfaces purge_queue L499orchestrata_ultimate/postman/queue_manager QueueManager L30orchestrata_ultimate/postman/queue_manager purge_queue L199 |
none |
REQ-002-US-003-006 FIFO (First-In-First-Out) ordering |
orchestrata_ultimate/postman/queue BaseQueue L31 |
none |
REQ-002-US-003-007 Priority queue support |
none | none |
REQ-002-US-003-008 Message deduplication |
orchestrata_ultimate/postman/postman _persist_packet L464orchestrata_ultimate/postman/sync_router _is_duplicate_sync L136 |
none |
REQ-002-US-003-009 Dead-letter queue for failed messages |
orchestrata_ultimate/postman/interfaces get_dead_letter_queue L511orchestrata_ultimate/postman/queue_manager QueueManager L30orchestrata_ultimate/postman/queue_manager get_dead_letter_queue L226 |
none |
REQ-002-US-003-010 Message TTL (time-to-live) |
orchestrata_ultimate/postman/types QueueEntry L510orchestrata_ultimate/postman/types is_expired L525 |
none |
REQ-002-US-003-011 Single consumer mode |
none | none |
REQ-002-US-003-012 Multiple consumer mode (load balancing) |
none | none |
REQ-002-US-003-013 Peek messages without consuming |
orchestrata_ultimate/cxp/postman_adapter peek L224 |
none |
REQ-002-US-003-014 Batch message retrieval |
none | none |
REQ-002-US-003-015 Acknowledge message consumption |
orchestrata_ultimate/core/protocols/components acknowledge L198orchestrata_ultimate/postman/event_emitting_postman acknowledge L64 |
none |
REQ-002-US-003-016 Maximum queue size (10000 messages) |
orchestrata_ultimate/knowledge_graph/query_engine cache_size L401orchestrata_ultimate/postman/queue BoundedQueue L371 |
none |
REQ-002-US-003-017 Maximum message age (24 hours) |
none | none |
REQ-002-US-003-018 Queue overflow handling |
none | none |
REQ-002-US-003-019 Memory limit per queue |
none | none |
REQ-002-US-003-020 Persist queue state to disk |
none | none |
REQ-002-US-003-021 Restore queues on restart |
none | none |
REQ-002-US-003-022 Handle corruption gracefully |
none | none |
REQ-002-US-003-023 Periodic checkpoint creation |
none | none |
REQ-002-US-004-001 CRITICAL priority level (0) |
orchestrata_ultimate/postman/types Priority L94 |
none |
REQ-002-US-004-002 HIGH priority level (1) |
orchestrata_ultimate/postman/types Priority L94 |
none |
REQ-002-US-004-003 NORMAL priority level (2) |
orchestrata_ultimate/postman/types Priority L94 |
none |
REQ-002-US-004-004 LOW priority level (3) |
orchestrata_ultimate/postman/types Priority L94 |
none |
REQ-002-US-004-005 BACKGROUND priority level (4) |
orchestrata_ultimate/postman/types Priority L94 |
none |
REQ-002-US-004-006 Process messages in priority order |
orchestrata_ultimate/postman/interfaces IPriorityQueue L387orchestrata_ultimate/postman/priority get_next L328 |
none |
REQ-002-US-004-007 Preempt lower priority messages |
none | none |
REQ-002-US-004-008 Prevent starvation of low-priority messages |
orchestrata_ultimate/postman/priority PriorityScheduler L297orchestrata_ultimate/postman/priority check_starvation L342 |
none |
REQ-002-US-004-009 Age-based priority boost |
orchestrata_ultimate/postman/priority _apply_starvation_boost L366orchestrata_ultimate/postman/priority _get_entry_age L286 |
none |
REQ-002-US-004-010 Priority inversion detection |
orchestrata_ultimate/postman/priority detect_priority_inversion L414 |
none |
REQ-002-US-004-011 Set default priority per agent |
none | none |
REQ-002-US-004-012 Override priority per message |
orchestrata_ultimate/postman/interfaces boost_priority L407orchestrata_ultimate/postman/interfaces enqueue_with_priority L394orchestrata_ultimate/postman/priority boost_priority L157 |
none |
REQ-002-US-004-013 Configure priority thresholds |
none | none |
REQ-002-US-004-014 Configure aging parameters |
orchestrata_ultimate/postman/priority __init__ L313 |
none |
REQ-002-US-004-015 Track processing time per priority |
none | none |
REQ-002-US-004-016 Monitor priority distribution |
orchestrata_ultimate/postman/priority get_priority_stats L397 |
none |
REQ-002-US-004-017 Alert on priority queue buildup |
none | none |
REQ-002-US-004-018 Report priority inversion incidents |
none | none |
REQ-002-US-005-001 Content-based filtering |
orchestrata_ultimate/postman/filter MessageFilter L33orchestrata_ultimate/postman/filter matches L47orchestrata_ultimate/postman/interfaces subscribe L671+3 more |
none |
REQ-002-US-005-002 Header-based filtering |
orchestrata_ultimate/postman/filter MessageFilter L33orchestrata_ultimate/postman/filter matches L47orchestrata_ultimate/postman/types FilterCriteria L719 |
none |
REQ-002-US-005-003 Sender-based filtering |
orchestrata_ultimate/postman/filter MessageFilter L33orchestrata_ultimate/postman/filter matches L47orchestrata_ultimate/postman/types FilterCriteria L719 |
none |
REQ-002-US-005-004 Topic-based filtering |
orchestrata_ultimate/postman/filter MessageFilter L33orchestrata_ultimate/postman/filter matches L47orchestrata_ultimate/postman/types FilterCriteria L719 |
none |
REQ-002-US-005-005 Pattern-based filtering (regex) |
none | none |
REQ-002-US-005-006 Composite filters (AND/OR logic) |
orchestrata_ultimate/postman/filter MessageFilter L33orchestrata_ultimate/postman/filter matches L47orchestrata_ultimate/postman/interfaces IMessageFilter L1194+5 more |
none |
REQ-002-US-005-007 Static routing by recipient |
orchestrata_ultimate/postman/router add_route L333 |
none |
REQ-002-US-005-008 Dynamic routing by content |
none | none |
REQ-002-US-005-009 Conditional routing (if-then rules) |
none | none |
REQ-002-US-005-010 Load-balanced routing |
none | none |
REQ-002-US-005-011 Failover routing |
none | none |
REQ-002-US-005-012 Create routing rules |
orchestrata_ultimate/postman/interfaces add_rule L1244orchestrata_ultimate/postman/routing_rules RoutingRulesEngine L49orchestrata_ultimate/postman/routing_rules add_rule L75+1 more |
none |
REQ-002-US-005-013 Update routing rules |
orchestrata_ultimate/postman/interfaces update_rule L1268orchestrata_ultimate/postman/routing_rules RoutingRulesEngine L49orchestrata_ultimate/postman/routing_rules update_rule L121 |
none |
REQ-002-US-005-014 Delete routing rules |
orchestrata_ultimate/postman/interfaces remove_rule L1256orchestrata_ultimate/postman/router remove_route L347orchestrata_ultimate/postman/routing_rules RoutingRulesEngine L49+1 more |
none |
REQ-002-US-005-015 List active rules |
orchestrata_ultimate/postman/interfaces list_rules L1281orchestrata_ultimate/postman/routing_rules RoutingRulesEngine L49orchestrata_ultimate/postman/routing_rules list_rules L141 |
none |
REQ-002-US-005-016 Enable/disable rules |
orchestrata_ultimate/postman/types RoutingRule L756 |
none |
REQ-002-US-005-017 Validate rule syntax |
orchestrata_ultimate/postman/exceptions InvalidRoutingRuleError L275orchestrata_ultimate/postman/routing_rules add_rule L75 |
none |
REQ-002-US-005-018 Evaluate rules in priority order |
orchestrata_ultimate/postman/interfaces evaluate L1290orchestrata_ultimate/postman/routing_rules RoutingRulesEngine L49orchestrata_ultimate/postman/routing_rules evaluate L152 |
none |
REQ-002-US-005-019 Stop on first match (if configured) |
orchestrata_ultimate/postman/routing_rules evaluate L152orchestrata_ultimate/postman/types RoutingRule L756 |
none |
REQ-002-US-005-020 Evaluate all matching rules |
orchestrata_ultimate/postman/routing_rules evaluate L152 |
none |
REQ-002-US-005-021 Handle rule conflicts |
none | none |
REQ-002-US-005-022 Log rule evaluations |
none | none |
REQ-002-US-005-023 Rule evaluation < 10ms per message |
none | none |
REQ-002-US-005-024 Support 1000+ active rules |
none | none |
REQ-002-US-005-025 Efficient pattern matching |
orchestrata_ultimate/postman/filter compile_filter L123orchestrata_ultimate/postman/interfaces compile_filter L1223 |
none |
REQ-002-US-005-026 Cache compiled rule expressions |
none | none |
REQ-002-US-006-001 Persist all messages to disk |
orchestrata_ultimate/postman/interfaces IMessageStore L765orchestrata_ultimate/postman/interfaces store L775orchestrata_ultimate/postman/message_store MessageStore L54+1 more |
none |
REQ-002-US-006-002 Store message metadata (timestamp, sender, etc.) |
orchestrata_ultimate/postman/message_store MessageStore L54orchestrata_ultimate/postman/message_store store L163 |
none |
REQ-002-US-006-003 Store message payload |
orchestrata_ultimate/postman/message_store MessageStore L54orchestrata_ultimate/postman/message_store store L163 |
none |
REQ-002-US-006-004 Store delivery receipts |
none | none |
REQ-002-US-006-005 Compress stored messages |
none | none |
REQ-002-US-006-006 Configure retention period (default 7 days) |
none | none |
REQ-002-US-006-007 Configure storage limits (default 10GB) |
none | none |
REQ-002-US-006-008 Automatic cleanup of old messages |
orchestrata_ultimate/postman/interfaces cleanup L840orchestrata_ultimate/postman/message_store cleanup L364 |
none |
REQ-002-US-006-009 Manual purge operations |
orchestrata_ultimate/postman/interfaces delete L804orchestrata_ultimate/postman/message_store delete L296 |
none |
REQ-002-US-006-010 Export messages to archive |
none | none |
REQ-002-US-006-011 Replay messages by time range |
orchestrata_ultimate/postman/message_store query L326orchestrata_ultimate/postman/replay_engine replay_by_query L309 |
none |
REQ-002-US-006-012 Replay messages by sender |
orchestrata_ultimate/postman/message_store query L326orchestrata_ultimate/postman/replay_engine replay_by_query L309 |
none |
REQ-002-US-006-013 Replay messages by topic |
orchestrata_ultimate/postman/replay_engine replay_by_query L309 |
none |
REQ-002-US-006-014 Replay messages by message ID |
orchestrata_ultimate/postman/interfaces replay L936orchestrata_ultimate/postman/message_store retrieve L231orchestrata_ultimate/postman/replay_engine ReplayEngine L58+1 more |
none |
REQ-002-US-006-015 Replay messages by filter criteria |
orchestrata_ultimate/postman/interfaces replay_by_query L953orchestrata_ultimate/postman/replay_engine ReplayEngine L58orchestrata_ultimate/postman/replay_engine replay_by_query L309 |
none |
REQ-002-US-006-016 Replay at original speed |
none | none |
REQ-002-US-006-017 Replay at accelerated speed |
orchestrata_ultimate/postman/types ReplayOptions L895 |
none |
REQ-002-US-006-018 Replay with delay between messages |
orchestrata_ultimate/postman/replay_engine _process_replay L235orchestrata_ultimate/postman/replay_engine _update_replay L166orchestrata_ultimate/postman/types ReplayOptions L895 |
none |
REQ-002-US-006-019 Replay to different recipients |
orchestrata_ultimate/postman/types ReplayOptions L895 |
none |
REQ-002-US-006-020 Dry-run replay (no delivery) |
orchestrata_ultimate/postman/types ReplayOptions L895 |
none |
REQ-002-US-006-021 Recover from storage corruption |
none | none |
REQ-002-US-006-022 Rebuild indexes from logs |
none | none |
REQ-002-US-006-023 Verify message integrity |
none | none |
REQ-002-US-006-024 Handle missing messages gracefully |
none | none |
REQ-002-US-007-001 At-most-once delivery (fire and forget) |
orchestrata_ultimate/postman/governance AuthResult L50orchestrata_ultimate/postman/guarantees DeliveryGuaranteeManager L44orchestrata_ultimate/postman/types DeliveryMode L81 |
none |
REQ-002-US-007-002 At-least-once delivery (with retries) |
orchestrata_ultimate/postman/guarantees DeliveryGuaranteeManager L44orchestrata_ultimate/postman/types DeliveryMode L81 |
none |
REQ-002-US-007-003 Exactly-once delivery (with deduplication) |
orchestrata_ultimate/postman/guarantees DeliveryGuaranteeManager L44orchestrata_ultimate/postman/guarantees is_duplicate L287orchestrata_ultimate/postman/types DeliveryMode L81 |
none |
REQ-002-US-007-004 Configure delivery mode per message |
orchestrata_ultimate/postman/guarantees send L94orchestrata_ultimate/postman/interfaces send L530 |
none |
REQ-002-US-007-005 Configure delivery mode per queue |
none | none |
REQ-002-US-007-006 Synchronous ACK (immediate response) |
none | none |
REQ-002-US-007-007 Asynchronous ACK (deferred response) |
none | none |
REQ-002-US-007-008 Negative ACK (NACK) for failures |
orchestrata_ultimate/postman/guarantees negative_acknowledge L196orchestrata_ultimate/postman/interfaces negative_acknowledge L559 |
none |
REQ-002-US-007-009 Batch acknowledgments |
none | none |
REQ-002-US-007-010 Selective acknowledgments |
none | none |
REQ-002-US-007-011 Configure ACK timeout per message |
none | none |
REQ-002-US-007-012 Configure ACK timeout per agent |
none | none |
REQ-002-US-007-013 Retry on timeout (up to max retries) |
none | none |
REQ-002-US-007-014 Exponential backoff for retries |
orchestrata_ultimate/postman/error_handler _calculate_backoff L157 |
none |
REQ-002-US-007-015 Alert on persistent timeouts |
none | none |
REQ-002-US-007-016 Generate unique receipt ID |
orchestrata_ultimate/postman/types DeliveryReceipt L409 |
none |
REQ-002-US-007-017 Track receipt status (pending/acked/nacked) |
none | none |
REQ-002-US-007-018 Query receipt status by message ID |
orchestrata_ultimate/postman/interfaces get_pending_acks L572 |
none |
REQ-002-US-007-019 Store receipts for audit trail |
orchestrata_ultimate/postman/receipt_store ReceiptStore L51orchestrata_ultimate/postman/receipt_store store L180 |
none |
REQ-002-US-007-020 Expire old receipts |
orchestrata_ultimate/postman/receipt_store expire L327 |
none |
REQ-002-US-007-021 Dead-letter queue for undeliverable messages |
none | none |
REQ-002-US-007-022 Alert on delivery failures |
none | none |
REQ-002-US-007-023 Log detailed failure reasons |
none | none |
REQ-002-US-007-024 Retry with different routes |
none | none |
REQ-002-US-007-025 Manual intervention support |
none | none |
REQ-002-US-008-001 Messages sent per second |
orchestrata_ultimate/postman/interfaces record_message_sent L1005orchestrata_ultimate/postman/metrics PostmanMetricsCollector L17orchestrata_ultimate/postman/metrics get_snapshot L98+2 more |
none |
REQ-002-US-008-002 Messages received per second |
orchestrata_ultimate/postman/interfaces record_message_received L1015orchestrata_ultimate/postman/metrics PostmanMetricsCollector L17orchestrata_ultimate/postman/metrics get_snapshot L98+2 more |
none |
REQ-002-US-008-003 Messages queued (current) |
orchestrata_ultimate/postman/types QueueStats L566 |
none |
REQ-002-US-008-004 Messages in-flight (current) |
none | none |
REQ-002-US-008-005 Messages failed (total) |
orchestrata_ultimate/postman/interfaces record_message_failed L1024orchestrata_ultimate/postman/metrics PostmanMetricsCollector L17orchestrata_ultimate/postman/metrics get_snapshot L98+2 more |
none |
REQ-002-US-008-006 Average message latency (p50, p95, p99) |
orchestrata_ultimate/postman/metrics PostmanMetricsCollector L17orchestrata_ultimate/postman/metrics get_snapshot L98orchestrata_ultimate/postman/metrics record_message_sent L68+1 more |
none |
REQ-002-US-008-007 Message throughput (bytes/sec) |
none | none |
REQ-002-US-008-008 Active agents count |
orchestrata_ultimate/knowledge_graph/synchronizer sync_count L944 |
none |
REQ-002-US-008-009 Messages per agent |
none | none |
REQ-002-US-008-010 Agent message latency |
none | none |
REQ-002-US-008-011 Agent error rate |
none | none |
REQ-002-US-008-012 Agent connection status |
none | none |
REQ-002-US-008-013 Queue depth per queue |
orchestrata_ultimate/postman/interfaces record_queue_depth L1033orchestrata_ultimate/postman/metrics PostmanMetricsCollector L17orchestrata_ultimate/postman/metrics get_snapshot L98+3 more |
none |
REQ-002-US-008-014 Queue age (oldest message) |
orchestrata_ultimate/postman/types QueueStats L566orchestrata_ultimate/postman/types QueueStatus L539 |
none |
REQ-002-US-008-015 Messages enqueued per queue |
none | none |
REQ-002-US-008-016 Messages dequeued per queue |
none | none |
REQ-002-US-008-017 Queue overflow events |
none | none |
REQ-002-US-008-018 Subscribers per topic |
none | none |
REQ-002-US-008-019 Messages per topic |
none | none |
REQ-002-US-008-020 Topic message rate |
none | none |
REQ-002-US-008-021 Topic latency |
none | none |
REQ-002-US-008-022 CPU usage |
none | none |
REQ-002-US-008-023 Memory usage |
none | none |
REQ-002-US-008-024 Disk I/O |
none | none |
REQ-002-US-008-025 Network I/O |
none | none |
REQ-002-US-008-026 Thread pool utilization |
none | none |
REQ-002-US-008-027 Prometheus format export |
orchestrata_ultimate/postman/interfaces export_prometheus L1051orchestrata_ultimate/postman/metrics PostmanMetricsCollector L17orchestrata_ultimate/postman/metrics export_prometheus L133 |
none |
REQ-002-US-008-028 JSON format export |
orchestrata_ultimate/postman/interfaces export_json L1060orchestrata_ultimate/postman/metrics PostmanMetricsCollector L17orchestrata_ultimate/postman/metrics export_json L137+1 more |
none |
REQ-002-US-008-029 CSV format export |
none | none |
REQ-002-US-008-030 Real-time streaming metrics |
none | none |
REQ-002-US-008-031 Historical metrics query |
none | none |
REQ-002-US-009-001 Load from YAML file |
orchestrata_ultimate/postman/cli _load_config L31orchestrata_ultimate/postman/sync_router route_sync L54 |
tests/postman/test_cxp_redis_delivery.py::test_route_sync_persists_to_thread_audit |
REQ-002-US-009-002 Load from environment variables |
none | tests/postman/test_cxp_redis_delivery.py::test_route_sync_enqueues_to_delivery_queue |
REQ-002-US-009-003 Load from command-line arguments |
none | tests/postman/test_cxp_redis_delivery.py::test_route_sync_dedup_prevents_duplicate |
REQ-002-US-009-004 Configuration priority order |
none | tests/postman/test_cxp_redis_delivery.py::test_route_sync_handler_receives_packet |
REQ-002-US-009-005 Validate configuration on load |
orchestrata_ultimate/postman/config load L95 |
tests/postman/test_cxp_redis_delivery.py::test_route_sync_response_persisted |
REQ-002-US-009-006 Postman service port |
orchestrata_ultimate/postman/types PostmanConfig L843 |
tests/postman/test_cxp_redis_delivery.py::test_get_thread_packets_reads_from_redis |
REQ-002-US-009-007 Maximum message size |
orchestrata_ultimate/postman/types PostmanConfig L843 |
tests/postman/test_cxp_redis_delivery.py::test_route_sync_stamps_deterministic_id |
REQ-002-US-009-008 Maximum queue size |
orchestrata_ultimate/knowledge_graph/query_engine cache_size L401orchestrata_ultimate/postman/types PostmanConfig L843 |
tests/postman/test_cxp_redis_delivery.py::test_volk_to_volk_communication |
REQ-002-US-009-009 Default message TTL |
orchestrata_ultimate/postman/types PostmanConfig L843 |
none |
REQ-002-US-009-010 Retry policy configuration |
orchestrata_ultimate/postman/types PostmanConfig L843 |
none |
REQ-002-US-009-011 Thread pool size |
orchestrata_ultimate/postman/types PostmanConfig L843 |
none |
REQ-002-US-009-012 Storage path configuration |
orchestrata_ultimate/postman/queue_manager __init__ L55orchestrata_ultimate/postman/types PostmanConfig L843 |
none |
REQ-002-US-009-013 Default topic patterns |
none | none |
REQ-002-US-009-014 Topic retention policy |
orchestrata_ultimate/postman/types TopicDefinition L631 |
none |
REQ-002-US-009-015 Topic access control |
none | none |
REQ-002-US-009-016 Topic rate limits |
none | none |
REQ-002-US-009-017 Default queue behavior (FIFO/priority) |
none | none |
REQ-002-US-009-018 Queue persistence settings |
orchestrata_ultimate/postman/types QueueConfig L597 |
none |
REQ-002-US-009-019 Queue size limits |
orchestrata_ultimate/knowledge_graph/query_engine cache_size L401orchestrata_ultimate/postman/types QueueConfig L597 |
none |
REQ-002-US-009-020 Dead-letter queue settings |
orchestrata_ultimate/postman/types QueueConfig L597 |
none |
REQ-002-US-009-021 Enable/disable authentication |
none | none |
REQ-002-US-009-022 Enable/disable encryption |
none | none |
REQ-002-US-009-023 Certificate paths |
none | none |
REQ-002-US-009-024 Access control policies |
none | none |
REQ-002-US-009-025 Reload configuration without restart |
orchestrata_ultimate/postman/config PostmanConfigManager L44orchestrata_ultimate/postman/config reload L150orchestrata_ultimate/postman/interfaces reload L1326 |
none |
REQ-002-US-009-026 Validate configuration changes |
none | none |
REQ-002-US-009-027 Rollback failed changes |
none | none |
REQ-002-US-009-028 Notify on configuration changes |
orchestrata_ultimate/postman/config PostmanConfigManager L44orchestrata_ultimate/postman/config _notify_callbacks L295orchestrata_ultimate/postman/config on_change L289+2 more |
none |
REQ-002-US-010-001 Handle 5000+ messages/second |
none | none |
REQ-002-US-010-002 Handle 10000+ concurrent connections |
none | none |
REQ-002-US-010-003 Handle 1000+ active queues |
none | none |
REQ-002-US-010-004 Handle 100+ topics with subscribers |
none | none |
REQ-002-US-010-005 Message delivery < 100ms (p95) |
none | none |
REQ-002-US-010-006 Queue operations < 50ms (p95) |
none | none |
REQ-002-US-010-007 Topic subscription < 50ms (p95) |
none | none |
REQ-002-US-010-008 ACK processing < 10ms (p95) |
none | none |
REQ-002-US-010-009 Maximum 1GB memory usage |
none | none |
REQ-002-US-010-010 Maximum 10GB disk usage |
none | none |
REQ-002-US-010-011 Maximum 100 threads |
none | none |
REQ-002-US-010-012 Efficient CPU utilization (<50% at peak) |
none | none |
REQ-002-US-010-013 Load test with 1000 messages/sec |
none | none |
REQ-002-US-010-014 Load test with 5000 messages/sec |
none | none |
REQ-002-US-010-015 Load test with 10000 messages/sec |
none | none |
REQ-002-US-010-016 Stress test with 100 concurrent agents |
none | none |
REQ-002-US-010-017 Stress test with 1000 concurrent agents |
none | none |
REQ-002-US-010-018 Spike test (sudden load increase) |
none | none |
REQ-002-US-010-019 Soak test (24-hour sustained load) |
none | none |
REQ-002-US-010-020 Message batching |
none | none |
REQ-002-US-010-021 Connection pooling |
none | none |
REQ-002-US-010-022 Zero-copy message transfer |
none | none |
REQ-002-US-010-023 Lock-free data structures |
none | none |
REQ-002-US-010-024 Asynchronous I/O |
none | none |
REQ-002-FR1-001 message_id field (UUID) |
orchestrata_ultimate/postman/types MessageEnvelope L136 |
none |
REQ-002-FR1-002 sender field (agent ID) |
orchestrata_ultimate/postman/types MessageEnvelope L136 |
none |
REQ-002-FR1-003 recipient field (agent ID or topic) |
orchestrata_ultimate/postman/types MessageEnvelope L136 |
none |
REQ-002-FR1-004 timestamp field (ISO 8601) |
orchestrata_ultimate/postman/types MessageEnvelope L136orchestrata_ultimate/postman/types _utc_now L31 |
none |
REQ-002-FR1-005 priority field (0-4) |
orchestrata_ultimate/postman/types MessageEnvelope L136 |
none |
REQ-002-FR1-006 ttl field (seconds) |
orchestrata_ultimate/postman/types MessageEnvelope L136 |
none |
REQ-002-FR1-007 correlation_id field (for request-response) |
orchestrata_ultimate/postman/envelope create L52orchestrata_ultimate/postman/types MessageEnvelope L136orchestrata_ultimate/postman/types from_dict L290 |
tests/postman/test_envelope.py::test_correlation_id_round_trips_through_to_dict_from_dicttests/scripts/test_check_feature_loss.py::test_surface_loss_flagship_reproduces_2883703a |
REQ-002-FR1-008 reply_to field (for responses) |
orchestrata_ultimate/postman/types MessageEnvelope L136 |
none |
REQ-002-FR1-009 content_type field (MIME type) |
orchestrata_ultimate/postman/types MessagePayload L314 |
none |
REQ-002-FR1-010 Validate all required fields present |
orchestrata_ultimate/postman/envelope EnvelopeHandler L38orchestrata_ultimate/postman/envelope create L52orchestrata_ultimate/postman/envelope validate L164+1 more |
none |
REQ-002-FR1-011 Validate field types |
orchestrata_ultimate/postman/envelope _validate_message_id L198orchestrata_ultimate/postman/envelope validate L164 |
none |
REQ-002-FR1-012 Validate field constraints (e.g., priority range) |
orchestrata_ultimate/postman/envelope create L52orchestrata_ultimate/postman/envelope validate L164orchestrata_ultimate/postman/envelope validate_content_type L395 |
none |
REQ-002-FR1-013 Validate message_id uniqueness |
orchestrata_ultimate/postman/sync_router _is_duplicate_sync L136 |
none |
REQ-002-FR1-014 Reject invalid envelopes |
orchestrata_ultimate/postman/delivery _validate_envelope L197orchestrata_ultimate/postman/envelope create L52orchestrata_ultimate/postman/envelope validate L164+2 more |
none |
REQ-002-FR1-015 Parse envelope from JSON |
orchestrata_ultimate/postman/envelope EnvelopeHandler L38orchestrata_ultimate/postman/envelope deserialize L285orchestrata_ultimate/postman/interfaces deserialize L99+1 more |
none |
REQ-002-FR1-016 Serialize envelope to JSON |
orchestrata_ultimate/postman/envelope EnvelopeHandler L38orchestrata_ultimate/postman/envelope serialize L261orchestrata_ultimate/postman/interfaces serialize L87+1 more |
none |
REQ-002-FR1-017 Extract routing information |
orchestrata_ultimate/postman/envelope EnvelopeHandler L38orchestrata_ultimate/postman/envelope get_routing_key L336 |
none |
REQ-002-FR1-018 Extract priority information |
orchestrata_ultimate/postman/types MessageEnvelope L136 |
none |
REQ-002-FR1-019 Generate envelope from message |
orchestrata_ultimate/postman/envelope EnvelopeHandler L38orchestrata_ultimate/postman/envelope create L52orchestrata_ultimate/postman/interfaces create L48 |
none |
REQ-002-FR2-001 Plain text payloads |
orchestrata_ultimate/postman/interfaces create_payload L165orchestrata_ultimate/postman/payload PayloadHandler L64orchestrata_ultimate/postman/payload create_payload L201+1 more |
none |
REQ-002-FR2-002 JSON payloads |
orchestrata_ultimate/postman/interfaces create_payload L165orchestrata_ultimate/postman/payload PayloadHandler L64orchestrata_ultimate/postman/payload _encode_json_value L33+2 more |
none |
REQ-002-FR2-003 Binary payloads |
orchestrata_ultimate/postman/interfaces create_payload L165orchestrata_ultimate/postman/payload PayloadHandler L64orchestrata_ultimate/postman/payload create_payload L201+1 more |
none |
REQ-002-FR2-004 Compressed payloads |
orchestrata_ultimate/postman/interfaces compress L141orchestrata_ultimate/postman/interfaces create_payload L165orchestrata_ultimate/postman/payload PayloadHandler L64+4 more |
none |
REQ-002-FR2-005 Encrypted payloads |
none | none |
REQ-002-FR2-006 Validate payload size (max 1MB) |
orchestrata_ultimate/postman/interfaces validate L125orchestrata_ultimate/postman/payload PayloadHandler L64orchestrata_ultimate/postman/payload validate L88 |
none |
REQ-002-FR2-007 Validate content_type matches payload |
orchestrata_ultimate/postman/exceptions InvalidPayloadError L93orchestrata_ultimate/postman/payload validate L88 |
none |
REQ-002-FR2-008 Validate JSON structure |
orchestrata_ultimate/postman/payload validate L88 |
none |
REQ-002-FR2-009 Validate character encoding |
orchestrata_ultimate/postman/payload validate L88 |
none |
REQ-002-FR2-010 Reject oversized payloads |
orchestrata_ultimate/postman/payload validate L88 |
none |
REQ-002-FR2-011 Parse JSON payloads |
orchestrata_ultimate/postman/payload PayloadHandler L64orchestrata_ultimate/postman/payload decode L315 |
none |
REQ-002-FR2-012 Decompress compressed payloads |
orchestrata_ultimate/postman/interfaces decompress L153orchestrata_ultimate/postman/payload PayloadHandler L64orchestrata_ultimate/postman/payload decode L315+1 more |
none |
REQ-002-FR2-013 Decrypt encrypted payloads |
none | none |
REQ-002-FR2-014 Handle binary data |
orchestrata_ultimate/postman/payload decode L315orchestrata_ultimate/postman/payload encode L270 |
none |
REQ-002-FR2-015 Preserve payload integrity |
none | none |
REQ-002-FR3-001 Direct routing (agent-to-agent) |
orchestrata_ultimate/postman/router RoutingEngine L27orchestrata_ultimate/postman/router get_routing_type L81 |
none |
REQ-002-FR3-002 Topic-based routing |
orchestrata_ultimate/postman/router RoutingEngine L27orchestrata_ultimate/postman/router get_routing_type L81 |
none |
REQ-002-FR3-003 Queue-based routing |
none | none |
REQ-002-FR3-004 Broadcast routing |
orchestrata_ultimate/postman/router RoutingEngine L27orchestrata_ultimate/postman/router get_routing_type L81 |
none |
REQ-002-FR3-005 Multicast routing |
orchestrata_ultimate/postman/router RoutingEngine L27orchestrata_ultimate/postman/router get_routing_type L81 |
none |
REQ-002-FR3-006 Resolve recipient by agent ID |
orchestrata_ultimate/cxp/postman_adapter _resolve_recipient L39orchestrata_ultimate/postman/interfaces resolve L203orchestrata_ultimate/postman/router _resolve_direct L169 |
none |
REQ-002-FR3-007 Resolve recipients by topic |
orchestrata_ultimate/postman/interfaces resolve L203orchestrata_ultimate/postman/router _resolve_topic L186 |
none |
REQ-002-FR3-008 Resolve recipients by queue |
none | none |
REQ-002-FR3-009 Resolve recipients by filter |
orchestrata_ultimate/postman/filter compiled L142orchestrata_ultimate/postman/routing_rules compile_filter L44orchestrata_ultimate/postman/routing_rules evaluate L152 |
none |
REQ-002-FR3-010 Handle unresolved routes |
orchestrata_ultimate/postman/delivery _resolve_recipients L246orchestrata_ultimate/postman/exceptions NoRouteFoundError L265orchestrata_ultimate/postman/router resolve L280 |
none |
REQ-002-FR3-011 Cache resolved routes |
orchestrata_ultimate/postman/router _get_cached_route L249orchestrata_ultimate/postman/router _set_cached_route L268orchestrata_ultimate/postman/router resolve L280 |
none |
REQ-002-FR3-012 Invalidate cache on changes |
orchestrata_ultimate/postman/interfaces invalidate_cache L235orchestrata_ultimate/postman/router invalidate_cache L364 |
none |
REQ-002-FR3-013 Configure cache size |
none | none |
REQ-002-FR3-014 Configure cache TTL |
orchestrata_ultimate/postman/router __init__ L62 |
none |
REQ-002-FR3-015 Cache hit/miss metrics |
none | none |
REQ-002-FR4-001 In-memory queue implementation |
orchestrata_ultimate/postman/delivery _get_or_create_recipient_queue L323orchestrata_ultimate/postman/queue InMemoryQueue L179 |
none |
REQ-002-FR4-002 Disk-backed queue implementation |
orchestrata_ultimate/postman/queue DiskBackedQueue L207orchestrata_ultimate/postman/queue __init__ L220orchestrata_ultimate/postman/queue _deserialize_entry L346+1 more |
none |
REQ-002-FR4-003 Priority queue implementation |
orchestrata_ultimate/postman/priority PriorityQueueImpl L38orchestrata_ultimate/postman/queue PriorityQueue L483orchestrata_ultimate/postman/queue enqueue L499 |
none |
REQ-002-FR4-004 Bounded queue with overflow handling |
orchestrata_ultimate/postman/exceptions QueueFullError L192orchestrata_ultimate/postman/queue BoundedQueue L371orchestrata_ultimate/postman/queue __init__ L382+2 more |
none |
REQ-002-FR4-005 Concurrent queue access |
orchestrata_ultimate/postman/priority PriorityQueueImpl L38orchestrata_ultimate/postman/queue BaseQueue L31 |
none |
REQ-002-FR4-006 Enqueue message |
orchestrata_ultimate/core/protocols/components enqueue L150orchestrata_ultimate/postman/delivery _deliver_to_recipient L358orchestrata_ultimate/postman/interfaces enqueue L313+9 more |
none |
REQ-002-FR4-007 Dequeue message |
orchestrata_ultimate/core/protocols/components dequeue L164orchestrata_ultimate/postman/interfaces dequeue L325orchestrata_ultimate/postman/postman dequeue L442+7 more |
none |
REQ-002-FR4-008 Peek message |
orchestrata_ultimate/postman/interfaces peek L334orchestrata_ultimate/postman/priority peek L112orchestrata_ultimate/postman/queue BaseQueue L31+3 more |
none |
REQ-002-FR4-009 Get queue size |
orchestrata_ultimate/postman/interfaces size L343orchestrata_ultimate/postman/priority size L128orchestrata_ultimate/postman/queue BaseQueue L31+4 more |
none |
REQ-002-FR4-010 Clear queue |
orchestrata_ultimate/postman/interfaces clear L352orchestrata_ultimate/postman/priority clear L139orchestrata_ultimate/postman/queue BaseQueue L31+3 more |
none |
REQ-002-FR4-011 Iterate queue (for admin) |
orchestrata_ultimate/postman/interfaces get_by_priority L420orchestrata_ultimate/postman/priority get_by_priority L187 |
none |
REQ-002-FR4-012 Write-ahead log for durability |
none | none |
REQ-002-FR4-013 Periodic checkpoints |
orchestrata_ultimate/postman/interfaces checkpoint L361orchestrata_ultimate/postman/priority checkpoint L197orchestrata_ultimate/postman/queue DiskBackedQueue L207+8 more |
none |
REQ-002-FR4-014 Recovery on startup |
orchestrata_ultimate/postman/interfaces recover L366orchestrata_ultimate/postman/priority recover L234orchestrata_ultimate/postman/queue DiskBackedQueue L207+3 more |
none |
REQ-002-FR4-015 Corruption detection |
orchestrata_ultimate/postman/queue DiskBackedQueue L207orchestrata_ultimate/postman/queue recover L273 |
none |
REQ-002-FR4-016 Repair corrupted queues |
none | none |
REQ-002-FR5-001 Store topic definitions |
orchestrata_ultimate/postman/interfaces ITopicRegistry L590orchestrata_ultimate/postman/topic_registry TopicRegistry L24orchestrata_ultimate/postman/topic_registry __init__ L40+1 more |
none |
REQ-002-FR5-002 Store topic subscriptions |
orchestrata_ultimate/postman/types TopicSubscription L662 |
none |
REQ-002-FR5-003 Store topic metadata |
orchestrata_ultimate/postman/topic_registry TopicRegistry L24orchestrata_ultimate/postman/types TopicDefinition L631 |
none |
REQ-002-FR5-004 Persist registry to disk |
none | none |
REQ-002-FR5-005 Load registry on startup |
none | none |
REQ-002-FR5-006 Create topic |
orchestrata_ultimate/postman/interfaces create_topic L600orchestrata_ultimate/postman/topic_registry TopicRegistry L24orchestrata_ultimate/postman/topic_registry create_topic L44 |
none |
REQ-002-FR5-007 Delete topic |
orchestrata_ultimate/postman/interfaces delete_topic L612orchestrata_ultimate/postman/topic_registry TopicRegistry L24orchestrata_ultimate/postman/topic_registry delete_topic L69 |
none |
REQ-002-FR5-008 List topics |
orchestrata_ultimate/postman/interfaces list_topics L636orchestrata_ultimate/postman/topic_registry TopicRegistry L24 |
none |
REQ-002-FR5-009 Query topic info |
orchestrata_ultimate/postman/interfaces get_topic L624orchestrata_ultimate/postman/topic_registry TopicRegistry L24orchestrata_ultimate/postman/topic_registry get_topic L91 |
none |
REQ-002-FR5-010 Subscribe to topic |
none | none |
REQ-002-FR5-011 Unsubscribe from topic |
orchestrata_ultimate/postman/router unsubscribe_from_topic L409 |
none |
REQ-002-FR5-012 Exact match |
none | none |
REQ-002-FR5-013 Wildcard match (*) |
orchestrata_ultimate/postman/interfaces match_topics L648orchestrata_ultimate/postman/topic_registry TopicRegistry L24orchestrata_ultimate/postman/topic_registry match_topics L137 |
none |
REQ-002-FR5-014 Pattern match (regex) |
orchestrata_ultimate/postman/interfaces match_topics L648 |
none |
REQ-002-FR5-015 Hierarchical match (topic.subtopic) |
none | none |
REQ-002-FR5-016 Efficient matching algorithm |
none | none |
REQ-002-FR6-001 Store subscriptions in memory |
orchestrata_ultimate/postman/subscription_manager SubscriptionManager L63orchestrata_ultimate/postman/subscription_manager __init__ L79 |
none |
REQ-002-FR6-002 Persist subscriptions to disk |
none | none |
REQ-002-FR6-003 Index subscriptions by topic |
none | none |
REQ-002-FR6-004 Index subscriptions by agent |
orchestrata_ultimate/postman/subscription_manager SubscriptionManager L63 |
none |
REQ-002-FR6-005 Handle large subscription counts |
none | none |
REQ-002-FR6-006 Add subscription |
orchestrata_ultimate/postman/subscription_manager SubscriptionManager L63orchestrata_ultimate/postman/subscription_manager subscribe L84 |
none |
REQ-002-FR6-007 Remove subscription |
orchestrata_ultimate/postman/exceptions SubscriptionNotFoundError L243orchestrata_ultimate/postman/interfaces unsubscribe_all L711orchestrata_ultimate/postman/subscription_manager SubscriptionManager L63+2 more |
none |
REQ-002-FR6-008 List subscriptions by agent |
orchestrata_ultimate/postman/interfaces get_subscriptions L735orchestrata_ultimate/postman/subscription_manager SubscriptionManager L63 |
none |
REQ-002-FR6-009 List subscriptions by topic |
orchestrata_ultimate/postman/interfaces get_subscribers L723 |
none |
REQ-002-FR6-010 Update subscription metadata |
none | none |
REQ-002-FR6-011 Match message to subscriptions |
orchestrata_ultimate/postman/interfaces match_subscribers L747orchestrata_ultimate/postman/subscription_manager SubscriptionManager L63orchestrata_ultimate/postman/subscription_manager match_subscribers L232 |
none |
REQ-002-FR6-012 Return all matching subscribers |
orchestrata_ultimate/postman/postman publish_topic L210orchestrata_ultimate/postman/subscription_manager SubscriptionManager L63orchestrata_ultimate/postman/subscription_manager get_subscribers L195 |
none |
REQ-002-FR6-013 Filter by agent status (active) |
none | none |
REQ-002-FR6-014 Cache frequent matches |
none | none |
REQ-002-FR6-015 Optimize for common patterns |
none | none |
REQ-002-FR7-001 Generate receipt on message receipt |
orchestrata_ultimate/postman/types ReceiptType L116 |
none |
REQ-002-FR7-002 Generate receipt on message delivery |
orchestrata_ultimate/postman/delivery _deliver_to_recipient L358orchestrata_ultimate/postman/types ReceiptType L116 |
none |
REQ-002-FR7-003 Generate receipt on message failure |
orchestrata_ultimate/postman/delivery _deliver_to_recipient L358orchestrata_ultimate/postman/types ReceiptType L116 |
none |
REQ-002-FR7-004 Include delivery timestamp |
orchestrata_ultimate/postman/types DeliveryReceipt L409 |
none |
REQ-002-FR7-005 Include failure reason (if applicable) |
orchestrata_ultimate/postman/types DeliveryReceipt L409 |
none |
REQ-002-FR7-006 Store receipts in memory |
orchestrata_ultimate/postman/interfaces IReceiptStore L861orchestrata_ultimate/postman/interfaces store L871orchestrata_ultimate/postman/receipt_store ReceiptStore L51+1 more |
none |
REQ-002-FR7-007 Persist receipts to disk |
orchestrata_ultimate/postman/receipt_store ReceiptStore L51orchestrata_ultimate/postman/receipt_store _init_sqlite L109orchestrata_ultimate/postman/receipt_store store L180+2 more |
none |
REQ-002-FR7-008 Index by message ID |
orchestrata_ultimate/postman/receipt_store ReceiptStore L51orchestrata_ultimate/postman/receipt_store _init_sqlite L109orchestrata_ultimate/postman/receipt_store sync_init L117 |
none |
REQ-002-FR7-009 Index by recipient |
none | none |
REQ-002-FR7-010 Expire old receipts |
orchestrata_ultimate/postman/interfaces expire L915orchestrata_ultimate/postman/receipt_store ReceiptStore L51orchestrata_ultimate/postman/receipt_store expire L327 |
none |
REQ-002-FR7-011 Query receipt by message ID |
orchestrata_ultimate/postman/interfaces get L880orchestrata_ultimate/postman/receipt_store get L234orchestrata_ultimate/postman/types from_dict L456 |
none |
REQ-002-FR7-012 Query receipts by time range |
orchestrata_ultimate/postman/interfaces query L892orchestrata_ultimate/postman/receipt_store query L273 |
none |
REQ-002-FR7-013 Query receipts by sender |
orchestrata_ultimate/postman/receipt_store query L273 |
none |
REQ-002-FR7-014 Query receipts by recipient |
orchestrata_ultimate/postman/receipt_store query L273 |
none |
REQ-002-FR7-015 Export receipts for audit |
none | none |
REQ-002-FR8-001 Connection errors |
none | none |
REQ-002-FR8-002 Timeout errors |
none | none |
REQ-002-FR8-003 Validation errors |
none | none |
REQ-002-FR8-004 Authorization errors |
none | none |
REQ-002-FR8-005 System errors (OOM, disk full) |
none | none |
REQ-002-FR8-006 Generate error message |
orchestrata_ultimate/core/patterns/error_handling handle_error L79orchestrata_ultimate/postman/exceptions PostmanError L16orchestrata_ultimate/postman/exceptions __str__ L55 |
none |
REQ-002-FR8-007 Include error code |
orchestrata_ultimate/postman/exceptions PostmanError L16orchestrata_ultimate/postman/exceptions __init__ L39 |
none |
REQ-002-FR8-008 Include error description |
orchestrata_ultimate/core/patterns/error_handling handle_error_from_string L135orchestrata_ultimate/postman/exceptions PostmanError L16orchestrata_ultimate/postman/exceptions __str__ L55 |
none |
REQ-002-FR8-009 Include stack trace (if debug) |
orchestrata_ultimate/core/patterns/error_handling ErrorDetail L20orchestrata_ultimate/core/patterns/error_handling debug_mode L61orchestrata_ultimate/core/patterns/error_handling set_debug_mode L73 |
none |
REQ-002-FR8-010 Send error to sender |
none | none |
REQ-002-FR8-011 Log all errors |
orchestrata_ultimate/core/patterns/error_handling handle_error L79 |
none |
REQ-002-FR8-012 Include context information |
orchestrata_ultimate/core/patterns/error_handling to_dict L32orchestrata_ultimate/postman/exceptions PostmanError L16orchestrata_ultimate/postman/exceptions __init__ L39 |
none |
REQ-002-FR8-013 Include timestamp |
none | none |
REQ-002-FR8-014 Rotate log files |
none | none |
REQ-002-FR8-015 Export logs for analysis |
none | none |
REQ-002-FR8-016 Retry transient errors |
orchestrata_ultimate/postman/error_handler PostmanErrorHandler L74orchestrata_ultimate/postman/error_handler handle L95orchestrata_ultimate/postman/interfaces handle L1080 |
none |
REQ-002-FR8-017 Fallback for permanent errors |
orchestrata_ultimate/postman/error_handler PostmanErrorHandler L74orchestrata_ultimate/postman/error_handler handle L95orchestrata_ultimate/postman/exceptions DeliveryFailedError L152 |
none |
REQ-002-FR8-018 Alert on critical errors |
none | none |
REQ-002-FR8-019 Graceful degradation |
orchestrata_ultimate/postman/error_handler PostmanErrorHandler L74orchestrata_ultimate/postman/error_handler handle L95 |
none |
REQ-002-FR8-020 Circuit breaker pattern |
orchestrata_ultimate/postman/error_handler CircuitBreaker L32orchestrata_ultimate/postman/error_handler PostmanErrorHandler L74orchestrata_ultimate/postman/error_handler __init__ L36+13 more |
none |
REQ-002-FR9-001 Collect core metrics (see US-008) |
orchestrata_ultimate/postman/health create_health_router L164orchestrata_ultimate/postman/health get_health_router L194orchestrata_ultimate/postman/interfaces IMetricsCollector L995 |
none |
REQ-002-FR9-002 Aggregate metrics by time window |
none | none |
REQ-002-FR9-003 Calculate percentiles (p50, p95, p99) |
none | none |
REQ-002-FR9-004 Track metric trends |
none | none |
REQ-002-FR9-005 Alert on anomalies |
none | none |
REQ-002-FR9-006 /metrics endpoint (Prometheus format) |
none | none |
REQ-002-FR9-007 /health endpoint (health check) |
orchestrata_ultimate/postman/admin PostmanAdmin L36orchestrata_ultimate/postman/admin get_system_status L98orchestrata_ultimate/postman/admin get_system_status L145+7 more |
none |
REQ-002-FR9-008 /stats endpoint (JSON stats) |
none | none |
REQ-002-FR9-009 Real-time metrics WebSocket |
none | none |
REQ-002-FR9-010 Historical metrics API |
none | none |
REQ-002-FR9-011 Structured logging (JSON) |
none | none |
REQ-002-FR9-012 Log levels (DEBUG, INFO, WARN, ERROR) |
none | none |
REQ-002-FR9-013 Log filtering |
none | none |
REQ-002-FR9-014 Log aggregation |
none | none |
REQ-002-FR9-015 Log search |
none | none |
REQ-002-FR10-001 List all agents |
orchestrata_ultimate/postman/admin PostmanAdmin L36orchestrata_ultimate/postman/admin create_admin_router L119orchestrata_ultimate/postman/admin get_admin_router L165+3 more |
none |
REQ-002-FR10-002 List all queues |
none | none |
REQ-002-FR10-003 List all topics |
none | none |
REQ-002-FR10-004 View agent details |
none | none |
REQ-002-FR10-005 View queue details |
none | none |
REQ-002-FR10-006 View topic details |
none | none |
REQ-002-FR10-007 Purge queue |
none | none |
REQ-002-FR10-008 Delete topic |
none | none |
REQ-002-FR10-009 Disconnect agent |
orchestrata_ultimate/postman/admin PostmanAdmin L36orchestrata_ultimate/postman/admin disconnect_agent L70orchestrata_ultimate/postman/admin disconnect_agent L135+1 more |
none |
REQ-002-FR10-010 Replay messages |
orchestrata_ultimate/postman/replay_engine ReplayEngine L58 |
none |
REQ-002-FR10-011 Export configuration |
orchestrata_ultimate/postman/admin PostmanAdmin L36orchestrata_ultimate/postman/admin export_config L106orchestrata_ultimate/postman/admin export_config L150+1 more |
none |
REQ-002-FR10-012 Import configuration |
orchestrata_ultimate/postman/admin PostmanAdmin L36orchestrata_ultimate/postman/admin import_config L110orchestrata_ultimate/postman/admin import_config L155+1 more |
none |
REQ-002-FR10-013 REST API for admin operations |
none | none |
REQ-002-FR10-014 Authentication required |
none | none |
REQ-002-FR10-015 Authorization by role |
orchestrata_ultimate/postman/governance check_admin_authority L402 |
none |
REQ-002-FR10-016 Audit log all admin actions |
none | none |
REQ-002-FR10-017 Rate limit admin requests |
none | none |
REQ-002-FR11-001 Load from postman.yaml |
orchestrata_ultimate/postman/config PostmanConfigManager L44orchestrata_ultimate/postman/config load L95 |
none |
REQ-002-FR11-002 Load from environment variables |
orchestrata_ultimate/postman/config PostmanConfigManager L44orchestrata_ultimate/postman/config _apply_env_overrides L173orchestrata_ultimate/postman/config _convert_env_value L195+1 more |
none |
REQ-002-FR11-003 Load from CLI arguments |
none | none |
REQ-002-FR11-004 Merge configurations |
orchestrata_ultimate/postman/config load L95orchestrata_ultimate/postman/interfaces load L1317 |
none |
REQ-002-FR11-005 Validate loaded configuration |
orchestrata_ultimate/postman/config PostmanConfigManager L44orchestrata_ultimate/postman/config load L95orchestrata_ultimate/postman/config validate L254+1 more |
none |
REQ-002-FR11-006 Define YAML schema |
none | none |
REQ-002-FR11-007 Validate against schema |
none | none |
REQ-002-FR11-008 Provide schema documentation |
none | none |
REQ-002-FR11-009 Default values for all settings |
orchestrata_ultimate/postman/config _dict_to_config L214orchestrata_ultimate/postman/config load L95 |
none |
REQ-002-FR11-010 Required vs optional settings |
none | none |
REQ-002-FR11-011 Watch configuration file |
orchestrata_ultimate/postman/config PostmanConfigManager L44orchestrata_ultimate/postman/config _start_watch L312orchestrata_ultimate/postman/config stop_watch L343 |
none |
REQ-002-FR11-012 Detect changes |
orchestrata_ultimate/postman/config _stop_wait L338orchestrata_ultimate/postman/config _watch_loop L323 |
none |
REQ-002-FR11-013 Validate new configuration |
none | none |
REQ-002-FR11-014 Apply changes atomically |
none | none |
REQ-002-FR11-015 Rollback on failure |
none | none |
REQ-002-FR11-016 Postman facts stored in Prolog KB |
none | none |
REQ-002-FR11-017 Query message routing via Prolog |
none | none |
REQ-002-FR11-018 Query subscription rules via Prolog |
none | none |
REQ-002-FR11-019 Update Postman state in Prolog |
none | none |
REQ-002-FR11-020 Prolog-based message filtering |
none | none |
REQ-002-FR11-021 Agent registration with Postman |
orchestrata_ultimate/agents/volks/base set_postman L99orchestrata_ultimate/postman/postman register L205 |
none |
REQ-002-FR11-022 Agent deregistration |
none | none |
REQ-002-FR11-023 Agent message send/receive |
none | none |
REQ-002-FR11-024 Agent status tracking |
none | none |
REQ-002-FR11-025 Agent capability discovery |
none | none |
REQ-002-FR11-026 Session-based message isolation |
none | none |
REQ-002-FR11-027 Per-session queues |
none | none |
REQ-002-FR11-028 Per-session topics |
none | none |
REQ-002-FR11-029 Session cleanup on end |
none | none |
REQ-002-FR11-030 Session message history |
none | none |
REQ-002-FR11-031 Installation guide |
none | none |
REQ-002-FR11-032 Configuration guide |
none | none |
REQ-002-FR11-033 User manual |
none | none |
REQ-002-FR11-034 API reference |
none | none |
REQ-002-FR11-035 Examples and tutorials |
none | none |
REQ-002-FR11-036 Architecture overview |
none | none |
REQ-002-FR11-037 Component design docs |
none | none |
REQ-002-FR11-038 API documentation |
none | none |
REQ-002-FR11-039 Testing guide |
none | none |
REQ-002-FR11-040 Contribution guide |
none | none |
REQ-002-FR11-041 Deployment guide |
none | none |
REQ-002-FR11-042 Monitoring guide |
none | none |
REQ-002-FR11-043 Troubleshooting guide |
none | none |
REQ-002-FR11-044 Performance tuning guide |
none | none |
REQ-002-FR11-045 Backup/restore procedures |
none | none |