Orchestrata Ultimate / RTM / 001-kernel
RTM: 001-kernel
Requirement to symbol to test rows for 001-kernel: Orchestration Kernel (U:KR).
At a glance
| Item | Value |
|---|---|
| Requirement IDs | 373 |
Traced from src/ |
298 (79.9%) |
| Untraced | 75 |
Cited from tests/ |
64 (17.2%) |
Traced in src/ but not cited from tests/ |
242 |
Reading this matrix
This matrix lists each of the 373 requirement IDs of spec 001-kernel with the src/ symbols that cite it and the tests that cite it. 298 of them (79.9%) have at least one citing symbol and 75 have none.
64 requirements are also cited from tests/, and 242 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-001-US-006 (27), REQ-001-US-007 (15), REQ-001-US-005 (12).
Requirement to symbols to tests
| Requirement | Symbols in src/ |
Tests citing it |
|---|---|---|
REQ-001-001 Volk can register with unique alias (e.g., U:Ox, U:PS) |
orchestrata_ultimate/agents/volk_registry InvalidAliasError L345orchestrata_ultimate/agents/volk_registry VolkDefinition L147orchestrata_ultimate/agents/volk_registry VolkRegistry L355+6 more |
tests/core/test_traceability.py::Clstests/core/test_tracing.py::Clstests/knowledge_graph/sample-sync/src/sample_module.py::SampleService+6 more |
REQ-001-002 Registration includes capabilities declaration |
orchestrata_ultimate/agents/volk_registry VolkCapability L115orchestrata_ultimate/agents/volk_registry VolkDefinition L147 |
tests/core/test_traceability.py::Clstests/core/test_tracing.py::Clstests/knowledge_graph/sample-sync/src/sample_module.py::process+1 more |
REQ-001-003 Registration includes supported protocols (CXP, gRPC, WS) |
orchestrata_ultimate/agents/volk_registry VolkDefinition L147orchestrata_ultimate/agents/volk_registry VolkProtocol L45 |
tests/core/test_traceability.py::Clstests/core/test_tracing.py::Clstests/knowledge_graph/sample-sync/src/sample_module.py::top_level_function |
REQ-001-004 Registration includes resource requirements |
orchestrata_ultimate/agents/volk_registry ResourceRequirements L82orchestrata_ultimate/agents/volk_registry VolkDefinition L147 |
none |
REQ-001-005 Registration validates alias uniqueness |
orchestrata_ultimate/agents/volk_registry DuplicateAliasError L328orchestrata_ultimate/agents/volk_registry _validate_definition L669orchestrata_ultimate/agents/volk_registry register_volk L758+1 more |
tests/kernel/test_kernel_defect_regressions.py::test_concurrent_duplicate_register_only_one_succeeds |
REQ-001-006 Registration validates capability schema |
orchestrata_ultimate/agents/volk_registry InvalidCapabilityError L337orchestrata_ultimate/agents/volk_registry _validate_capabilities L650orchestrata_ultimate/agents/volk_registry _validate_definition L669 |
none |
REQ-001-007 Registration returns registration token |
orchestrata_ultimate/agents/volk_registry VolkRegistration L278orchestrata_ultimate/agents/volk_registry _create_registration L697orchestrata_ultimate/agents/volk_registry _generate_token L605 |
none |
REQ-001-008 Registration updates Volk registry |
orchestrata_ultimate/agents/volk_registry _create_registration L697orchestrata_ultimate/agents/volk_registry _sync_governance_facts L545orchestrata_ultimate/agents/volk_registry register_volk L758+3 more |
none |
REQ-001-009 Registration notifies other Volks of new agent |
orchestrata_ultimate/agents/volk_registry _notify_registration L798orchestrata_ultimate/agents/volk_registry _post_register_hooks L726orchestrata_ultimate/kernel/cli_main _boot_intent_pipeline L223+5 more |
tests/gateway/test_volk_status_event_broadcast.py::test_status_change_event_reaches_gateway_broadcast |
REQ-001-010 Registration persists to Redis state |
orchestrata_ultimate/agents/volk_registry _persist_registration L812orchestrata_ultimate/agents/volk_registry _post_register_hooks L726 |
none |
REQ-001-011 Volk can query all registered Volks |
orchestrata_ultimate/agents/volk_registry VolkRegistry L355orchestrata_ultimate/agents/volk_registry count L1343orchestrata_ultimate/agents/volk_registry list_volks L857+3 more |
none |
REQ-001-012 Volk can query Volks by capability |
orchestrata_ultimate/agents/volk_registry list_volks_by_capability L866orchestrata_ultimate/core/protocols/decoupling list_volks_by_capability L78orchestrata_ultimate/kernel/pipeline_escalation resolve_capability L207 |
none |
REQ-001-013 Volk can query Volks by protocol support |
orchestrata_ultimate/agents/volk_registry list_volks_by_protocol L886orchestrata_ultimate/core/protocols/decoupling list_volks_by_protocol L81 |
none |
REQ-001-014 Volk can subscribe to registry updates |
orchestrata_ultimate/agents/volk_registry __init__ L376orchestrata_ultimate/agents/volk_registry _fire_status_change L497orchestrata_ultimate/agents/volk_registry _sync_governance_active L564+7 more |
tests/gateway/test_volk_status_event_broadcast.py::test_status_change_event_reaches_gateway_broadcasttests/kernel/test_volk_registry_status_events.py::test_heartbeat_transition_fires_on_status_changetests/kernel/test_volk_registry_status_events.py::test_lazy_timeout_transition_fires_on_status_change+1 more |
REQ-001-015 Discovery returns Volk metadata (alias, capabilities, protocols) |
orchestrata_ultimate/agents/volk_registry VolkMetadata L234orchestrata_ultimate/agents/volk_registry get_volk_metadata L1052orchestrata_ultimate/agents/volk_registry to_dict L249+6 more |
tests/kernel/test_kernel_pipeline_registry_binding.py::test_bound_registry_reflects_live_mutations_through_the_volktests/kernel/test_status_report_health.py::TestStatusReportHeartbeatHealth |
REQ-001-016 Discovery uses caching for performance |
orchestrata_ultimate/agents/volk_registry __init__ L376orchestrata_ultimate/agents/volk_registry get_volk_metadata L1052 |
none |
REQ-001-017 Discovery handles partial failures gracefully |
orchestrata_ultimate/agents/volk_registry _fire_status_change L497orchestrata_ultimate/agents/volk_registry get_volk_metadata L1052orchestrata_ultimate/agents/volk_registry record_heartbeat L1182+2 more |
tests/kernel/test_heartbeat_pump.py::test_beat_once_tolerates_probe_exceptiontests/kernel/test_heartbeat_pump.py::test_partial_failure_toleratedtests/kernel/test_heartbeat_pump.py::test_stop_joins_thread+3 more |
REQ-001-018 Discovery provides health status for each Volk |
orchestrata_ultimate/agents/prolog_bridge volk_healthy L313orchestrata_ultimate/agents/runtime get_instance_health L351orchestrata_ultimate/agents/volk_registry VolkHealth L208+20 more |
tests/agents/test_message_volk_delivery_status.py::test_message_volk_health_warning_preservedtests/agents/test_message_volk_delivery_status.py::test_message_volk_records_recipient_heartbeattests/kernel/test_heartbeat_pump.py::test_beat_once_records_all_rostered_volks+6 more |
REQ-001-019 Discovery supports filtering and pagination |
orchestrata_ultimate/agents/volk_registry VolkQueryFilter L265orchestrata_ultimate/agents/volk_registry _apply_query_filters L1301orchestrata_ultimate/agents/volk_registry query_volks L1261+1 more |
none |
REQ-001-020 Discovery validates query parameters |
orchestrata_ultimate/agents/volk_registry _apply_query_filters L1301orchestrata_ultimate/agents/volk_registry query_volks L1261 |
none |
REQ-001-021 Volk can deregister cleanly |
orchestrata_ultimate/agents/volk_registry VolkRegistry L355orchestrata_ultimate/agents/volk_registry deregister_volk L980orchestrata_ultimate/core/protocols/components fire_volk L243+2 more |
none |
REQ-001-022 Deregistration notifies dependent Volks |
orchestrata_ultimate/agents/volk_registry _notify_deregistration L1029orchestrata_ultimate/agents/volk_registry _post_deregister_cleanup L949orchestrata_ultimate/agents/volk_registry add_deregistration_handler L1043+5 more |
tests/kernel/test_volk_status_bridge.py::TestOnStatusChangeNeverRaises |
REQ-001-023 Deregistration updates registry |
orchestrata_ultimate/agents/volk_registry deregister_volk L980 |
none |
REQ-001-024 Deregistration cleans up resources |
orchestrata_ultimate/agents/volk_registry _post_deregister_cleanup L949orchestrata_ultimate/agents/volk_registry deregister_volk L980 |
none |
REQ-001-025 Deregistration handles in-flight messages |
orchestrata_ultimate/agents/volk_registry _drain_in_flight_messages L915orchestrata_ultimate/agents/volk_registry decrement_in_flight_messages L1242orchestrata_ultimate/agents/volk_registry increment_in_flight_messages L1224+2 more |
none |
REQ-001-US-002-001 Route message based on TO field in CXP packet |
orchestrata_ultimate/agents/kernel_handler _build_failure_packet L471orchestrata_ultimate/agents/kernel_handler _build_reply L271orchestrata_ultimate/agents/kernel_handler _process_in_background L323+19 more |
tests/core/test_traceability.py::my_functests/core/test_tracing.py::my_functests/test_core.py::Stacked+2 more |
REQ-001-US-002-002 Validate FROM field matches sender identity |
orchestrata_ultimate/kernel/router validate_sender L395 |
none |
REQ-001-US-002-003 Support unicast (single recipient) routing |
orchestrata_ultimate/cxp/reply_router ReplyRouter L78orchestrata_ultimate/cxp/reply_router queue_for L189orchestrata_ultimate/cxp/reply_router route L243+9 more |
none |
REQ-001-US-002-004 Support multicast (multiple recipients) routing |
orchestrata_ultimate/kernel/router CXPRouter L165orchestrata_ultimate/kernel/router RoutingMode L28orchestrata_ultimate/kernel/router _determine_routing_mode L522+2 more |
none |
REQ-001-US-002-005 Support broadcast (all Volks) routing |
orchestrata_ultimate/kernel/router CXPRouter L165orchestrata_ultimate/kernel/router RoutingMode L28orchestrata_ultimate/kernel/router _determine_routing_mode L522+3 more |
none |
REQ-001-US-002-006 Route to specific Volk instance by alias |
orchestrata_ultimate/agents/prolog_bridge find_best_volk_for_task L221orchestrata_ultimate/agents/task_executor _resolve_alias L301orchestrata_ultimate/kernel/router _resolve_single_recipient L485 |
none |
REQ-001-US-002-007 Route to Volk role (e.g., any QA agent) |
orchestrata_ultimate/kernel/router _resolve_single_recipient L485orchestrata_ultimate/kernel/router resolve_recipients L426 |
none |
REQ-001-US-002-008 Handle routing to offline Volks |
orchestrata_ultimate/cxp/reply_router ReplyRouter L78orchestrata_ultimate/cxp/reply_router _sweep L282orchestrata_ultimate/cxp/reply_router close_drain L229+5 more |
tests/cxp/test_reply_router.py::test_active_drain_never_evictedtests/cxp/test_reply_router.py::test_cap_evicts_oldest_idle_inactive_firsttests/cxp/test_reply_router.py::test_close_drain_on_unknown_consumer_is_a_noop+7 more |
REQ-001-US-002-009 Handle routing to unknown recipients |
orchestrata_ultimate/cxp/router is_valid_route L155orchestrata_ultimate/kernel/router RoutingResult L140orchestrata_ultimate/kernel/router RoutingStatus L41+5 more |
tests/agents/test_message_volk_delivery_status.py::test_message_volk_reports_no_route_as_failuretests/postman/test_aroute_outcome.py::test_no_route_outcome |
REQ-001-US-002-010 Validate message schema before routing |
orchestrata_ultimate/kernel/router CXPRouter L165orchestrata_ultimate/kernel/router _validate_packet_schema L203orchestrata_ultimate/kernel/router route L313 |
none |
REQ-001-US-002-011 Dispatch message via Volk-specified protocol |
orchestrata_ultimate/kernel/dispatcher MessageDispatcher L290orchestrata_ultimate/kernel/dispatcher _dispatch_by_protocol L625orchestrata_ultimate/kernel/dispatcher _select_protocol L610+2 more |
none |
REQ-001-US-002-012 Support CXP over gRPC dispatch |
orchestrata_ultimate/agents/kernel_handler build_kernel_packet_handler L772orchestrata_ultimate/cxp/direct_cxp_adapter DirectCXPClient L337orchestrata_ultimate/cxp/direct_cxp_adapter DirectCXPServer L117+6 more |
none |
REQ-001-US-002-013 Support CXP over WebSocket dispatch |
orchestrata_ultimate/kernel/dispatcher _exchange_websocket L835orchestrata_ultimate/kernel/dispatcher _send_websocket L798orchestrata_ultimate/kernel/dispatcher dispatch_websocket L770 |
none |
REQ-001-US-002-014 Support CXP over HTTP dispatch |
orchestrata_ultimate/kernel/dispatcher _post_http L962orchestrata_ultimate/kernel/dispatcher _serialize_packet L942orchestrata_ultimate/kernel/dispatcher dispatch_http L914 |
none |
REQ-001-US-002-015 Retry failed dispatches with exponential backoff |
orchestrata_ultimate/kernel/dispatcher DispatchAttempt L225orchestrata_ultimate/kernel/dispatcher dispatch L367orchestrata_ultimate/kernel/dispatcher get_dispatch_history L1015+1 more |
tests/kernel/test_dispatcher_expanded.py::test_dispatch_succeeds_after_one_retry_records_backoff |
REQ-001-US-002-016 Track dispatch attempts and failures |
orchestrata_ultimate/kernel/dispatcher DispatchAttempt L225orchestrata_ultimate/kernel/dispatcher DispatchResult L251orchestrata_ultimate/kernel/dispatcher DispatchStatus L214+4 more |
tests/kernel/test_dispatcher_expanded.py::test_dispatch_succeeds_after_one_retry_records_backoff |
REQ-001-US-002-017 Timeout stale dispatch attempts |
orchestrata_ultimate/kernel/dispatcher _attempt_dispatch L532orchestrata_ultimate/kernel/dispatcher dispatch L367orchestrata_ultimate/postman/guarantees check_timeouts L303 |
none |
REQ-001-US-002-018 Queue messages for offline Volks |
orchestrata_ultimate/kernel/queue_manager enqueue L197 |
none |
REQ-001-US-002-019 Provide delivery acknowledgments |
orchestrata_ultimate/agents/kernel_handler _process_in_background L323orchestrata_ultimate/cxp/servicer enqueue_reply L217orchestrata_ultimate/kernel/dispatcher DispatchResult L251+3 more |
tests/postman/test_aroute_outcome.py::test_aroute_backcompat_delegates |
REQ-001-US-002-020 Handle partial delivery failures (multicast) |
none | none |
REQ-001-US-002-021 Queue messages when recipient unavailable |
orchestrata_ultimate/kernel/queue_manager QueueManager L86orchestrata_ultimate/kernel/queue_manager _redis_result L34orchestrata_ultimate/kernel/queue_manager dequeue L285+1 more |
none |
REQ-001-US-002-022 Persist queue to Redis for durability |
orchestrata_ultimate/core/protocols/decoupling queue_pop L264orchestrata_ultimate/core/protocols/decoupling queue_push L261orchestrata_ultimate/infra/redis_state queue_pop L533+5 more |
none |
REQ-001-US-002-023 Support priority queuing (urgent messages first) |
orchestrata_ultimate/kernel/queue_manager QueueManager L86orchestrata_ultimate/kernel/queue_manager _queue_key L182orchestrata_ultimate/kernel/queue_manager enqueue L197 |
none |
REQ-001-US-002-024 Apply backpressure when queue full |
orchestrata_ultimate/kernel/performance/resources BackpressureController L540orchestrata_ultimate/kernel/performance/resources should_accept L620orchestrata_ultimate/kernel/queue_manager QueueManager L86 |
none |
REQ-001-US-002-025 Monitor queue depth and latency |
orchestrata_ultimate/core/protocols/decoupling queue_length L267orchestrata_ultimate/infra/redis_state queue_length L551orchestrata_ultimate/kernel/queue_manager get_queue_depth L392+1 more |
none |
REQ-001-US-002-026 Expire stale messages from queue |
orchestrata_ultimate/kernel/queue_manager expire_stale_messages L477 |
none |
REQ-001-US-002-027 Support dead-letter queue for failed messages |
orchestrata_ultimate/kernel/queue_manager QueueManager L86orchestrata_ultimate/kernel/queue_manager _dlq_key L187orchestrata_ultimate/kernel/queue_manager move_to_dead_letter L417+1 more |
none |
REQ-001-US-002-028 Provide queue statistics (depth, rate, latency) |
orchestrata_ultimate/kernel/queue_manager QueueManager L86orchestrata_ultimate/kernel/queue_manager QueueStats L48orchestrata_ultimate/kernel/queue_manager get_stats L543+3 more |
none |
REQ-001-US-002-029 Support queue inspection for debugging |
orchestrata_ultimate/kernel/queue_manager inspect_queue L613 |
none |
REQ-001-US-002-030 Handle queue overflow gracefully |
orchestrata_ultimate/agents/kernel_handler _build_draining_packet L551orchestrata_ultimate/cxp/reply_router ReplyRouter L78orchestrata_ultimate/cxp/reply_router _QueueEntry L59+3 more |
tests/cxp/test_reply_router.py::test_active_drain_never_evictedtests/cxp/test_reply_router.py::test_cap_evicts_oldest_idle_inactive_firsttests/cxp/test_reply_router.py::test_close_drain_on_unknown_consumer_is_a_noop+5 more |
REQ-001-US-002-031 Track message status: queued |
orchestrata_ultimate/agents/kernel_handler _process_in_background L323orchestrata_ultimate/kernel/router MessageStatus L54orchestrata_ultimate/kernel/router _determine_status_and_track L265+3 more |
none |
REQ-001-US-002-032 Track message status: dispatched |
orchestrata_ultimate/agents/kernel_handler _process_in_background L323orchestrata_ultimate/kernel/router MessageStatus L54 |
none |
REQ-001-US-002-033 Track message status: delivered |
orchestrata_ultimate/agents/kernel_handler _build_no_reply_packet L504orchestrata_ultimate/agents/kernel_handler _build_reply L271orchestrata_ultimate/agents/kernel_handler _build_terminal_packet L396+6 more |
tests/agents/test_kernel_handler_ack_only.py::test_no_match_round_emits_no_reply_terminaltests/agents/test_kernel_handler_ack_only.py::test_second_round_never_reemits_first_rounds_replytests/postman/test_aroute_outcome.py::test_delivered_with_and_without_reply |
REQ-001-US-002-034 Track message status: acknowledged |
orchestrata_ultimate/kernel/router MessageStatus L54orchestrata_ultimate/postman/guarantees acknowledge L179orchestrata_ultimate/postman/interfaces acknowledge L549+1 more |
none |
REQ-001-US-002-035 Track message status: failed |
orchestrata_ultimate/agents/kernel_handler _build_draining_packet L551orchestrata_ultimate/agents/kernel_handler _build_failure_packet L471orchestrata_ultimate/agents/kernel_handler _build_terminal_packet L396+6 more |
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+1 more |
REQ-001-US-002-036 Provide message status query API |
orchestrata_ultimate/kernel/router CXPRouter L165orchestrata_ultimate/kernel/router get_message_status L617orchestrata_ultimate/postman/guarantees get_pending_acks L239+1 more |
none |
REQ-001-US-002-037 Store status transitions with timestamps |
orchestrata_ultimate/agents/kernel_handler _build_no_reply_packet L504orchestrata_ultimate/agents/kernel_handler _build_terminal_packet L396orchestrata_ultimate/kernel/queue_manager _metadata_key L192+3 more |
none |
REQ-001-US-002-038 Notify sender of status changes |
orchestrata_ultimate/agents/kernel_handler _build_draining_packet L551orchestrata_ultimate/agents/kernel_handler _build_failure_packet L471orchestrata_ultimate/agents/kernel_handler _build_no_reply_packet L504+4 more |
tests/agents/test_message_volk_delivery_status.py::test_message_volk_reports_no_route_as_failure |
REQ-001-US-002-039 Support message tracing across hops |
orchestrata_ultimate/agents/kernel_handler _build_draining_packet L551orchestrata_ultimate/agents/kernel_handler _build_failure_packet L471orchestrata_ultimate/agents/kernel_handler _build_no_reply_packet L504+9 more |
none |
REQ-001-US-002-040 Generate routing metrics (latency, success rate) |
orchestrata_ultimate/kernel/router CXPRouter L165orchestrata_ultimate/kernel/router RoutingMetrics L100orchestrata_ultimate/kernel/router get_metrics L641+2 more |
none |
REQ-001-US-003-001 Query Prolog for routing decisions |
orchestrata_ultimate/cxp/prolog_bridge validate_route_via_prolog L402orchestrata_ultimate/cxp/router _check_governance L216orchestrata_ultimate/kernel/dispatcher MessageDispatcher L290+11 more |
none |
REQ-001-US-003-002 Query Prolog for permission checks |
orchestrata_ultimate/core/protocols/components evaluate_policy L267orchestrata_ultimate/governance/resource_access ResourceAccessController L33orchestrata_ultimate/kernel/policy_evaluator PermissionLevel L62+9 more |
none |
REQ-001-US-003-003 Query Prolog for ownership validation |
orchestrata_ultimate/kernel/policy_evaluator OwnershipResult L142orchestrata_ultimate/kernel/policy_evaluator OwnershipStatus L72orchestrata_ultimate/kernel/policy_evaluator PolicyEvaluator L275+3 more |
none |
REQ-001-US-003-004 Query Prolog for escalation rules |
orchestrata_ultimate/kernel/policy_evaluator PolicyEvaluator L275orchestrata_ultimate/kernel/policy_evaluator get_escalation_path L1061orchestrata_ultimate/kernel/policy_evaluator to_dict L182 |
none |
REQ-001-US-003-005 Cache Prolog query results for performance |
orchestrata_ultimate/core/protocols/decoupling cache_governance_decision L242orchestrata_ultimate/core/protocols/decoupling get_cached_decision L247orchestrata_ultimate/governance/policy_engine _check_cache L162+10 more |
none |
REQ-001-US-003-006 Invalidate cache on policy updates |
orchestrata_ultimate/kernel/policy_evaluator invalidate_cache L408orchestrata_ultimate/orchestrator/policy_registry activate L207orchestrata_ultimate/orchestrator/policy_registry deactivate L187+1 more |
none |
REQ-001-US-003-007 Handle Prolog query timeouts |
orchestrata_ultimate/kernel/policy_evaluator PolicyTimeoutError L255orchestrata_ultimate/kernel/policy_evaluator _execute_with_timeout L486 |
none |
REQ-001-US-003-008 Handle Prolog query failures |
orchestrata_ultimate/governance/_strict governance_strict L19orchestrata_ultimate/governance/policy_engine _evaluate_prolog_and_finalise L292orchestrata_ultimate/kernel/policy_evaluator PolicyEvaluationError L250+3 more |
none |
REQ-001-US-003-009 Log all policy queries for audit |
orchestrata_ultimate/kernel/dispatcher dispatch L367orchestrata_ultimate/kernel/policy_evaluator PolicyAuditEntry L221orchestrata_ultimate/kernel/policy_evaluator _log_audit L434+3 more |
none |
REQ-001-US-003-010 Support policy dry-run mode (testing) |
orchestrata_ultimate/kernel/policy_evaluator DryRunResult L198orchestrata_ultimate/kernel/policy_evaluator dry_run L1216orchestrata_ultimate/kernel/policy_evaluator to_dict L208 |
none |
REQ-001-US-003-011 Validate message sender has authority |
orchestrata_ultimate/kernel/pam/enforcer PAMEnforcer L33orchestrata_ultimate/kernel/pam/enforcer _check_direct_ownership L77orchestrata_ultimate/kernel/pam/enforcer _lookup_actual_owner L119+6 more |
none |
REQ-001-US-003-012 Validate message recipient is correct owner |
orchestrata_ultimate/kernel/pam/enforcer PAMEnforcer L33orchestrata_ultimate/kernel/pam/enforcer _lookup_actual_component_owner L254orchestrata_ultimate/kernel/pam/enforcer check_ownership L277+1 more |
none |
REQ-001-US-003-013 Enforce component ownership boundaries |
orchestrata_ultimate/kernel/pam/enforcer PAMEnforcer L33orchestrata_ultimate/kernel/pam/enforcer enforce_boundary L327orchestrata_ultimate/kernel/pam/types BoundaryResult L118+5 more |
none |
REQ-001-US-003-014 Block unauthorized cross-boundary messages |
orchestrata_ultimate/kernel/pam/enforcer PAMEnforcer L33orchestrata_ultimate/kernel/pam/enforcer enforce_boundary L327orchestrata_ultimate/kernel/pam/types BoundaryResult L118+1 more |
none |
REQ-001-US-003-015 Allow whitelisted cross-boundary exceptions |
orchestrata_ultimate/kernel/pam/enforcer PAMEnforcer L33orchestrata_ultimate/kernel/pam/enforcer enforce_boundary L327orchestrata_ultimate/kernel/pam/types BoundaryResult L118 |
none |
REQ-001-US-003-016 Validate workflow step permissions |
orchestrata_ultimate/kernel/pam/enforcer PAMEnforcer L33orchestrata_ultimate/kernel/pam/enforcer check_permission L401orchestrata_ultimate/kernel/pam/types PermissionResult L136 |
none |
REQ-001-US-003-017 Enforce read/write/execute permissions |
orchestrata_ultimate/kernel/pam/enforcer PAMEnforcer L33orchestrata_ultimate/kernel/pam/enforcer check_permission L401orchestrata_ultimate/kernel/pam/types PermissionResult L136+2 more |
none |
REQ-001-US-003-018 Support ownership delegation |
orchestrata_ultimate/kernel/pam/enforcer PAMEnforcer L33orchestrata_ultimate/kernel/pam/enforcer _check_delegation L98orchestrata_ultimate/kernel/pam/enforcer _check_temporary_ownership L205+5 more |
none |
REQ-001-US-003-019 Support temporary permission grants |
orchestrata_ultimate/kernel/pam/enforcer PAMEnforcer L33orchestrata_ultimate/kernel/pam/enforcer grant_temporary_permission L519orchestrata_ultimate/kernel/pam/types PermissionResult L136 |
none |
REQ-001-US-003-020 Log all permission violations |
orchestrata_ultimate/core/protocols/decoupling log_violation L157orchestrata_ultimate/kernel/pam/enforcer PAMEnforcer L33orchestrata_ultimate/kernel/pam/enforcer _log_violation L549+1 more |
none |
REQ-001-US-003-021 Detect conflicts requiring escalation |
orchestrata_ultimate/kernel/pam/escalation EscalationManager L39orchestrata_ultimate/kernel/pam/escalation detect_conflict L76orchestrata_ultimate/kernel/pam/types Conflict L166+1 more |
none |
REQ-001-US-003-022 Query Prolog for escalation path |
orchestrata_ultimate/governance/escalation_handler/handler get_escalation_path L518orchestrata_ultimate/kernel/pam/escalation get_escalation_path L117orchestrata_ultimate/kernel/policy_evaluator get_escalation_path L1061 |
none |
REQ-001-US-003-023 Route escalation to correct authority (e.g., U:Ox) |
orchestrata_ultimate/kernel/pam/escalation EscalationManager L39orchestrata_ultimate/kernel/pam/escalation MultiHopEscalationManager L354orchestrata_ultimate/kernel/pam/escalation escalate L177+3 more |
none |
REQ-001-US-003-024 Track escalation history |
orchestrata_ultimate/core/protocols/decoupling get_escalations L199orchestrata_ultimate/core/protocols/decoupling get_resolutions L205orchestrata_ultimate/governance/escalation_handler/handler track_escalation_state L386+6 more |
none |
REQ-001-US-003-025 Timeout stale escalations |
orchestrata_ultimate/kernel/pam/escalation timeout_stale L268orchestrata_ultimate/orchestrator/graph_audit log_timeout L464 |
none |
REQ-001-US-003-026 Notify stakeholders of escalation |
orchestrata_ultimate/governance/escalation_handler/sla _notify_sla_breach L223orchestrata_ultimate/kernel/pam/escalation escalate L177 |
none |
REQ-001-US-003-027 Support escalation priority levels |
none | none |
REQ-001-US-003-028 Handle recursive escalations |
orchestrata_ultimate/kernel/pam/escalation MultiHopEscalationManager L354orchestrata_ultimate/kernel/pam/escalation multi_hop_escalate L422 |
none |
REQ-001-US-003-029 Provide escalation resolution feedback |
orchestrata_ultimate/kernel/pam/escalation resolve L229orchestrata_ultimate/kernel/pam/types Resolution L212 |
none |
REQ-001-US-003-030 Log all escalation events |
orchestrata_ultimate/kernel/audit/logger log_escalation L310orchestrata_ultimate/kernel/pam/escalation escalate L177 |
none |
REQ-001-US-004-001 Create new session with unique session ID |
orchestrata_ultimate/kernel/session_manager Session L74orchestrata_ultimate/kernel/session_manager create_session L342orchestrata_ultimate/orchestrator/engine start_session L632 |
tests/session/test_kernel_session.py::test_create_session_with_metadatatests/session/test_kernel_session.py::test_create_session_with_unique_id |
REQ-001-US-004-002 Initialize session context (facts, portfolio, carryover) |
none | tests/session/test_kernel_session.py::test_resume_session_from_redis |
REQ-001-US-004-003 Load session-specific Prolog rules |
orchestrata_ultimate/core/protocols/decoupling load_rules L20 |
tests/session/test_kernel_session.py::test_close_session_marks_inactive |
REQ-001-US-004-004 Notify all Volks of session start |
none | tests/session/test_kernel_session.py::test_archive_session_to_neo4j |
REQ-001-US-004-005 Persist session metadata to Redis |
orchestrata_ultimate/core/protocols/decoupling create_session L226orchestrata_ultimate/infra/redis_state SessionState L100orchestrata_ultimate/infra/redis_state create_session L204+3 more |
tests/session/test_kernel_session.py::test_get_active_sessions_by_user |
REQ-001-US-004-006 Support session templates (pre-configured sessions) |
none | tests/session/test_kernel_session.py::test_delete_expired_sessions |
REQ-001-US-004-007 Validate session configuration |
none | tests/session/test_kernel_session.py::test_query_session_history |
REQ-001-US-004-008 Handle concurrent session initialization |
none | tests/session/test_kernel_session.py::test_delete_expired_sessionstests/session/test_kernel_session.py::test_session_ttl_expiration |
REQ-001-US-004-009 Set session resource limits |
orchestrata_ultimate/kernel/session_manager close L697orchestrata_ultimate/kernel/session_manager initialize L292orchestrata_ultimate/kernel/session_manager resume_session L392 |
tests/session/test_kernel_session.py::test_resume_session_from_redistests/session/test_kernel_session.py::test_session_persistence_across_restarts |
REQ-001-US-004-010 Log session initialization events |
orchestrata_ultimate/core/protocols/decoupling log_session_start L178orchestrata_ultimate/kernel/audit/logger log_session_lifecycle L350 |
tests/session/test_kernel_session.py::test_create_session_with_metadata |
REQ-001-US-004-011 Maintain session-specific facts |
orchestrata_ultimate/core/protocols/decoupling assert_fact L35orchestrata_ultimate/core/protocols/decoupling retract_fact L45orchestrata_ultimate/infra/prolog_bridge assert_fact L306+4 more |
tests/session/test_kernel_session.py::test_set_context_variable |
REQ-001-US-004-012 Maintain session portfolio (artifacts) |
orchestrata_ultimate/session/interfaces get_portfolio_context L123orchestrata_ultimate/session/interfaces get_portfolio_sessions L118 |
tests/session/test_kernel_session.py::test_get_context_with_default |
REQ-001-US-004-013 Maintain session carryover (todos) |
orchestrata_ultimate/session/interfaces create_carryover L94orchestrata_ultimate/session/interfaces get_carryover L99orchestrata_ultimate/session/interfaces resolve_carryover L104+4 more |
tests/session/test_kernel_session.py::test_update_context_atomically |
REQ-001-US-004-014 Isolate session state from other sessions |
orchestrata_ultimate/kernel/session_context SessionContext L149orchestrata_ultimate/kernel/session_context _context_key L232orchestrata_ultimate/kernel/session_context route_within_session L626+1 more |
tests/session/test_kernel_session.py::test_delete_context_key |
REQ-001-US-004-015 Support session context queries |
orchestrata_ultimate/core/protocols/decoupling get_session L229orchestrata_ultimate/kernel/session_context SessionContext L149orchestrata_ultimate/kernel/session_context get L299+1 more |
tests/session/test_kernel_session.py::test_clear_all_context |
REQ-001-US-004-016 Support session context updates |
orchestrata_ultimate/core/protocols/decoupling update_session L232orchestrata_ultimate/kernel/session_context SessionContext L149orchestrata_ultimate/kernel/session_context clear L411+5 more |
tests/session/test_kernel_session.py::test_inject_context_into_cxp_packet |
REQ-001-US-004-017 Validate context schema |
orchestrata_ultimate/kernel/session_context ContextValidator L47orchestrata_ultimate/kernel/session_context extract_context L456orchestrata_ultimate/kernel/session_context validate_key L90+3 more |
tests/session/test_kernel_session.py::test_extract_context_from_cxp_packet |
REQ-001-US-004-018 Persist context changes to Redis |
orchestrata_ultimate/infra/redis_state update_session L260orchestrata_ultimate/kernel/session_context SessionContext L149orchestrata_ultimate/kernel/session_context __init__ L167+4 more |
tests/session/test_kernel_session.py::test_validate_context_schema |
REQ-001-US-004-019 Handle context merge conflicts |
none | tests/session/test_kernel_session.py::test_serialize_context_for_storage |
REQ-001-US-004-020 Provide context versioning |
none | tests/session/test_kernel_session.py::test_deserialize_context_from_storage |
REQ-001-US-004-021 Gracefully terminate session |
orchestrata_ultimate/kernel/pipeline_session ashutdown L490orchestrata_ultimate/kernel/pipeline_session shutdown L468orchestrata_ultimate/kernel/session_context route_within_session L626+1 more |
tests/session/test_kernel_session.py::test_route_message_within_session |
REQ-001-US-004-022 Archive session artifacts |
orchestrata_ultimate/kernel/session_context route_within_session L626orchestrata_ultimate/kernel/session_manager _project_slug L60orchestrata_ultimate/kernel/session_manager archive_session L455 |
tests/session/test_kernel_session.py::test_prevent_cross_session_leakage |
REQ-001-US-004-023 Clean up session resources |
orchestrata_ultimate/core/protocols/decoupling delete_session L235orchestrata_ultimate/infra/redis_state delete_session L286orchestrata_ultimate/kernel/session_context SessionContext L149+4 more |
tests/session/test_kernel_session.py::test_session_specific_volk_instances |
REQ-001-US-004-024 Notify all Volks of session end |
orchestrata_ultimate/kernel/session_context broadcast_to_session L671 |
tests/session/test_kernel_session.py::test_broadcast_to_session_volks |
REQ-001-US-004-025 Generate session summary report |
none | tests/session/test_kernel_session.py::test_query_active_volks_for_session |
REQ-001-US-004-026 Persist final session state |
orchestrata_ultimate/kernel/session_context broadcast_to_session L671orchestrata_ultimate/kernel/session_manager archive_session L455 |
tests/session/test_kernel_session.py::test_broadcast_to_session_volkstests/session/test_kernel_session.py::test_session_scoped_multicast |
REQ-001-US-004-027 Handle forced session termination |
orchestrata_ultimate/kernel/session_context route_within_session L626 |
tests/session/test_kernel_session.py::test_prevent_cross_session_leakagetests/session/test_kernel_session.py::test_session_isolation_validation |
REQ-001-US-004-028 Transfer carryover to next session |
orchestrata_ultimate/kernel/session_context broadcast_to_session L671orchestrata_ultimate/session/carryover import_from_session L235orchestrata_ultimate/session/graph_store persist_carryover L338+1 more |
tests/session/test_kernel_session.py::test_session_routing_metrics |
REQ-001-US-004-029 Log session teardown events |
orchestrata_ultimate/core/protocols/decoupling log_session_end L183orchestrata_ultimate/kernel/audit/logger log_session_lifecycle L350 |
none |
REQ-001-US-004-030 Validate session closure conditions |
none | none |
REQ-001-US-005-001 Detect ownership conflicts |
orchestrata_ultimate/governance/escalation_handler/resolver ConflictResolver L63orchestrata_ultimate/governance/escalation_handler/resolver detect_conflict L88orchestrata_ultimate/kernel/pam/escalation detect_conflict L76+1 more |
none |
REQ-001-US-005-002 Detect permission conflicts |
orchestrata_ultimate/governance/escalation_handler/resolver detect_conflict L88orchestrata_ultimate/kernel/pam/escalation detect_conflict L76orchestrata_ultimate/kernel/pam/types ConflictType L59 |
none |
REQ-001-US-005-003 Detect resource conflicts |
orchestrata_ultimate/governance/escalation_handler/handler escalate L105orchestrata_ultimate/kernel/pam/escalation detect_conflict L76orchestrata_ultimate/kernel/pam/types ConflictType L59 |
none |
REQ-001-US-005-004 Detect workflow deadlocks |
none | none |
REQ-001-US-005-005 Detect policy violations |
orchestrata_ultimate/kernel/pam/types ConflictType L59 |
none |
REQ-001-US-005-006 Classify conflict severity (low, medium, high, critical) |
none | none |
REQ-001-US-005-007 Log conflict detection events |
orchestrata_ultimate/kernel/audit/logger log_escalation L310 |
none |
REQ-001-US-005-008 Notify involved Volks of conflict |
none | none |
REQ-001-US-005-009 Track conflict resolution time |
none | none |
REQ-001-US-005-010 Generate conflict metrics |
none | none |
REQ-001-US-005-011 Query Prolog for escalation authority |
orchestrata_ultimate/governance/escalation_handler/handler AdvancedEscalationHandler L65orchestrata_ultimate/kernel/pam/escalation get_escalation_path L117orchestrata_ultimate/kernel/policy_evaluator EscalationPath L169+1 more |
none |
REQ-001-US-005-012 Route escalation to U:Ox (Orchestrator) |
orchestrata_ultimate/core/protocols/components escalate L280orchestrata_ultimate/orchestrator/orchestrator escalate L195 |
none |
REQ-001-US-005-013 Route escalation to component owner |
none | none |
REQ-001-US-005-014 Support multi-level escalation paths |
orchestrata_ultimate/governance/escalation_handler/handler AdvancedEscalationHandler L65orchestrata_ultimate/governance/escalation_handler/handler _is_terminal_authority L548orchestrata_ultimate/governance/escalation_handler/handler execute_multi_hop L210+5 more |
none |
REQ-001-US-005-015 Handle circular escalation dependencies |
orchestrata_ultimate/kernel/pam/escalation MultiHopEscalationManager L354orchestrata_ultimate/kernel/pam/escalation multi_hop_escalate L422orchestrata_ultimate/kernel/pipeline_escalation PipelineEscalationMixin L104+1 more |
none |
REQ-001-US-005-016 Timeout stale escalations |
orchestrata_ultimate/governance/escalation_handler/handler _attempt_hop_once L338orchestrata_ultimate/governance/escalation_handler/handler handle_escalation_timeout L419orchestrata_ultimate/governance/escalation_handler/sla EscalationSLATracker L43+4 more |
none |
REQ-001-US-005-017 Provide escalation context (parties, issue, history) |
orchestrata_ultimate/governance/escalation_handler/handler _build_escalation_packet L288orchestrata_ultimate/kernel/pam/types ConflictContext L155orchestrata_ultimate/kernel/pipeline_escalation _build_escalation L519+1 more |
none |
REQ-001-US-005-018 Support escalation priority override |
orchestrata_ultimate/orchestrator/orchestrator EscalationIssue L90 |
none |
REQ-001-US-005-019 Log escalation routing decisions |
orchestrata_ultimate/governance/escalation_handler/handler _log_escalation_hop L567orchestrata_ultimate/kernel/audit/logger log_escalation L310 |
none |
REQ-001-US-005-020 Track escalation routing latency |
none | none |
REQ-001-US-005-021 Apply escalation resolution decision |
orchestrata_ultimate/governance/escalation_handler/handler _build_escalation_result L144orchestrata_ultimate/governance/escalation_handler/resolver ConflictResolver L63orchestrata_ultimate/governance/escalation_handler/resolver _apply_delegation_strategy L352+6 more |
none |
REQ-001-US-005-022 Notify all parties of resolution |
none | none |
REQ-001-US-005-023 Update Prolog rules if needed |
none | none |
REQ-001-US-005-024 Log resolution for future reference |
orchestrata_ultimate/core/protocols/decoupling log_resolution L163orchestrata_ultimate/governance/escalation_handler/resolver _log_resolution_decision L371orchestrata_ultimate/kernel/audit/logger log_escalation L310+2 more |
none |
REQ-001-US-005-025 Support resolution appeals |
none | none |
REQ-001-US-005-026 Track resolution compliance |
orchestrata_ultimate/governance/escalation_handler/sla EscalationSLATracker L43 |
none |
REQ-001-US-005-027 Generate resolution metrics |
orchestrata_ultimate/governance/escalation_handler/sla _calculate_avg_resolution_time L310orchestrata_ultimate/governance/escalation_handler/sla get_sla_metrics L174 |
none |
REQ-001-US-005-028 Archive escalation history |
orchestrata_ultimate/governance/escalation_handler/handler _store_escalation L597orchestrata_ultimate/kernel/audit/logger log_escalation L310 |
none |
REQ-001-US-005-029 Learn from escalation patterns |
none | none |
REQ-001-US-005-030 Prevent similar future escalations |
none | none |
REQ-001-US-006-001 Parse workflow definitions (YAML or JSON) |
none | none |
REQ-001-US-006-002 Validate workflow schema |
none | none |
REQ-001-US-006-003 Support sequential workflow steps |
none | none |
REQ-001-US-006-004 Support parallel workflow steps |
none | none |
REQ-001-US-006-005 Support conditional branching (if/else) |
none | none |
REQ-001-US-006-006 Support loops and retries |
none | none |
REQ-001-US-006-007 Define step dependencies (DAG) |
none | none |
REQ-001-US-006-008 Define step timeouts |
none | none |
REQ-001-US-006-009 Define step rollback actions |
none | none |
REQ-001-US-006-010 Persist workflow definitions |
none | none |
REQ-001-US-006-011 Initialize workflow instance |
none | none |
REQ-001-US-006-012 Execute steps in dependency order |
none | none |
REQ-001-US-006-013 Track step completion status |
none | none |
REQ-001-US-006-014 Handle step failures with retries |
none | none |
REQ-001-US-006-015 Apply step timeouts |
none | none |
REQ-001-US-006-016 Support workflow pause/resume |
orchestrata_ultimate/kernel/pipeline_session _checkpoint_stage L369orchestrata_ultimate/orchestrator/intent_workflow pause L452orchestrata_ultimate/orchestrator/intent_workflow resume L461 |
none |
REQ-001-US-006-017 Support workflow cancellation |
none | none |
REQ-001-US-006-018 Collect step outputs for next steps |
orchestrata_ultimate/context/providers/artifact_digest render_artifact_digest L67orchestrata_ultimate/core/artifact_store ArtifactStore L195orchestrata_ultimate/core/artifact_store PipelineArtifact L68+5 more |
none |
REQ-001-US-006-019 Pass context between steps |
none | none |
REQ-001-US-006-020 Log workflow execution events |
orchestrata_ultimate/kernel/audit/logger log_workflow_event L419orchestrata_ultimate/kernel/pipeline_events PipelineEvent L84orchestrata_ultimate/kernel/pipeline_events _forward_to_ui L291+1 more |
none |
REQ-001-US-006-021 Provide workflow status query API |
none | none |
REQ-001-US-006-022 Track workflow progress percentage |
none | none |
REQ-001-US-006-023 Track step-level metrics (duration, success rate) |
none | none |
REQ-001-US-006-024 Generate workflow execution reports |
none | none |
REQ-001-US-006-025 Alert on workflow failures |
none | none |
REQ-001-US-006-026 Support workflow debugging |
none | none |
REQ-001-US-006-027 Visualize workflow state |
none | none |
REQ-001-US-006-028 Archive completed workflows |
none | none |
REQ-001-US-006-029 Support workflow replay (for debugging) |
none | none |
REQ-001-US-006-030 Generate workflow analytics |
none | none |
REQ-001-US-007-001 Track available system resources (CPU, memory, network) |
orchestrata_ultimate/kernel/resource_monitor ResourceMonitor L85orchestrata_ultimate/kernel/resource_monitor ResourceSnapshot L48orchestrata_ultimate/kernel/resource_monitor take_snapshot L203 |
none |
REQ-001-US-007-002 Allocate resources to Volks on request |
none | none |
REQ-001-US-007-003 Enforce resource quotas per Volk |
none | none |
REQ-001-US-007-004 Support resource reservation (future allocation) |
none | none |
REQ-001-US-007-005 Handle resource contention (prioritization) |
orchestrata_ultimate/kernel/performance/resources BackpressureController L540 |
none |
REQ-001-US-007-006 Deallocate resources when Volk completes |
none | none |
REQ-001-US-007-007 Reclaim resources from idle Volks |
none | none |
REQ-001-US-007-008 Log resource allocation events |
orchestrata_ultimate/kernel/audit/logger log_resource_event L380 |
none |
REQ-001-US-007-009 Track resource utilization metrics |
orchestrata_ultimate/kernel/resource_monitor ResourceMonitor L85orchestrata_ultimate/kernel/resource_monitor get_system_summary L283 |
none |
REQ-001-US-007-010 Alert on resource exhaustion |
orchestrata_ultimate/kernel/resource_monitor ResourceAlert L29orchestrata_ultimate/kernel/resource_monitor ResourceMonitor L85orchestrata_ultimate/kernel/resource_monitor check_thresholds L168+2 more |
none |
REQ-001-US-007-011 Enforce per-Volk CPU limits |
orchestrata_ultimate/agents/constraints _check_alias_and_resources L145orchestrata_ultimate/agents/constraints check_resource_limits L316 |
none |
REQ-001-US-007-012 Enforce per-Volk memory limits |
orchestrata_ultimate/agents/constraints _check_alias_and_resources L145orchestrata_ultimate/agents/constraints check_resource_limits L316 |
none |
REQ-001-US-007-013 Enforce per-Volk network bandwidth limits |
none | none |
REQ-001-US-007-014 Enforce per-Volk storage limits |
none | none |
REQ-001-US-007-015 Enforce system-wide resource limits |
none | none |
REQ-001-US-007-016 Throttle Volks exceeding limits |
none | none |
REQ-001-US-007-017 Terminate Volks violating hard limits |
none | none |
REQ-001-US-007-018 Log limit violations |
none | none |
REQ-001-US-007-019 Notify Volks of approaching limits |
orchestrata_ultimate/kernel/resource_monitor register_alert_callback L259 |
none |
REQ-001-US-007-020 Support dynamic limit adjustments |
orchestrata_ultimate/kernel/resource_monitor set_thresholds L268 |
none |
REQ-001-US-007-021 Monitor CPU usage per Volk |
orchestrata_ultimate/kernel/resource_monitor get_cpu_percent L141 |
none |
REQ-001-US-007-022 Monitor memory usage per Volk |
orchestrata_ultimate/kernel/resource_monitor get_memory_stats L146 |
none |
REQ-001-US-007-023 Monitor network usage per Volk |
none | none |
REQ-001-US-007-024 Monitor storage usage per Volk |
orchestrata_ultimate/kernel/resource_monitor get_disk_stats L157 |
none |
REQ-001-US-007-025 Provide resource usage query API |
orchestrata_ultimate/kernel/resource_monitor ResourceMonitor L85orchestrata_ultimate/kernel/resource_monitor get_system_summary L283 |
none |
REQ-001-US-007-026 Generate resource usage reports |
orchestrata_ultimate/kernel/resource_monitor get_system_summary L283orchestrata_ultimate/kernel/resource_monitor to_dict L62 |
none |
REQ-001-US-007-027 Track resource usage trends |
orchestrata_ultimate/kernel/resource_monitor ResourceMonitor L85orchestrata_ultimate/kernel/resource_monitor get_average_cpu L238orchestrata_ultimate/kernel/resource_monitor get_peak_cpu L246+1 more |
none |
REQ-001-US-007-028 Alert on anomalous resource usage |
none | none |
REQ-001-US-007-029 Support resource profiling |
none | none |
REQ-001-US-007-030 Archive resource usage history |
none | none |
REQ-001-US-008-001 Log all message routing decisions |
orchestrata_ultimate/kernel/audit/logger log_message_routing L254orchestrata_ultimate/kernel/audit/model AuditEventType L14orchestrata_ultimate/postman/sync_router get_log L286 |
none |
REQ-001-US-008-002 Log all policy queries and results |
orchestrata_ultimate/kernel/audit/logger log_policy_query L283orchestrata_ultimate/kernel/audit/model AuditEventType L14orchestrata_ultimate/kernel/audit/model AuditOutcome L65 |
none |
REQ-001-US-008-003 Log all escalation events |
orchestrata_ultimate/core/protocols/decoupling log_escalation L160orchestrata_ultimate/kernel/audit/logger log_escalation L310orchestrata_ultimate/kernel/audit/model AuditEventType L14+1 more |
none |
REQ-001-US-008-004 Log all session lifecycle events |
orchestrata_ultimate/kernel/audit/logger log_session_lifecycle L350orchestrata_ultimate/kernel/audit/model AuditEventType L14 |
none |
REQ-001-US-008-005 Log all resource allocation events |
orchestrata_ultimate/kernel/audit/logger log_resource_event L380orchestrata_ultimate/kernel/audit/model AuditEventType L14 |
none |
REQ-001-US-008-006 Log all workflow execution steps |
orchestrata_ultimate/kernel/audit/logger log_workflow_event L419orchestrata_ultimate/kernel/audit/model AuditEventType L14 |
none |
REQ-001-US-008-007 Log all Volk registration/deregistration |
orchestrata_ultimate/agents/volk_registry _fire_volk_audit L462orchestrata_ultimate/kernel/audit/logger log_volk_lifecycle L457orchestrata_ultimate/kernel/audit/model AuditEventType L14+2 more |
none |
REQ-001-US-008-008 Include timestamps in all log entries |
orchestrata_ultimate/core/logging format L64orchestrata_ultimate/kernel/audit/_common _utc_now L27orchestrata_ultimate/kernel/audit/logger _create_entry L198+1 more |
none |
REQ-001-US-008-009 Include session context in log entries |
orchestrata_ultimate/core/logging format L64orchestrata_ultimate/kernel/audit/logger _create_entry L198orchestrata_ultimate/kernel/audit/model AuditEntry L78 |
none |
REQ-001-US-008-010 Include correlation IDs for tracing |
orchestrata_ultimate/core/logging new_correlation_id L153orchestrata_ultimate/kernel/audit/logger _create_entry L198orchestrata_ultimate/kernel/audit/model AuditEntry L78 |
none |
REQ-001-US-008-011 Persist logs to Neo4j knowledge graph |
orchestrata_ultimate/governance/escalation_handler/handler _audit_escalation_to_graph L174orchestrata_ultimate/governance/escalation_handler/sla _audit_breach_to_graph L279orchestrata_ultimate/kernel/audit/model AuditLogConfig L149+3 more |
none |
REQ-001-US-008-012 Persist logs to file system |
orchestrata_ultimate/core/logging configure_logging L109orchestrata_ultimate/kernel/audit/model AuditLogConfig L149orchestrata_ultimate/kernel/audit/writers FileAuditWriter L60+3 more |
none |
REQ-001-US-008-013 Support log rotation (size and time-based) |
orchestrata_ultimate/kernel/audit/model AuditLogConfig L149orchestrata_ultimate/kernel/audit/writers FileAuditWriter L60orchestrata_ultimate/kernel/audit/writers _rotate_log L112+1 more |
none |
REQ-001-US-008-014 Compress archived logs |
orchestrata_ultimate/kernel/audit/model AuditLogConfig L149orchestrata_ultimate/kernel/audit/writers FileAuditWriter L60orchestrata_ultimate/kernel/audit/writers _compress_file L134+1 more |
none |
REQ-001-US-008-015 Support log retention policies |
orchestrata_ultimate/kernel/audit/model AuditLogConfig L149orchestrata_ultimate/kernel/audit/writers FileAuditWriter L60orchestrata_ultimate/kernel/audit/writers _cleanup_old_logs L149 |
none |
REQ-001-US-008-016 Encrypt sensitive log data |
orchestrata_ultimate/kernel/audit/model AuditLogConfig L149orchestrata_ultimate/kernel/audit/writers FileAuditWriter L60orchestrata_ultimate/kernel/audit/writers _mask_sensitive_data L164 |
none |
REQ-001-US-008-017 Support log export (JSON, CSV) |
orchestrata_ultimate/kernel/audit/logger export_logs L655 |
none |
REQ-001-US-008-018 Handle log storage failures gracefully |
orchestrata_ultimate/kernel/audit/queue RedisAuditQueue L37orchestrata_ultimate/kernel/audit/queue _redis_result L23orchestrata_ultimate/kernel/audit/queue connect L80+6 more |
none |
REQ-001-US-008-019 Provide log backup/restore |
orchestrata_ultimate/kernel/audit/logger backup_logs L798orchestrata_ultimate/kernel/audit/logger restore_logs L817 |
none |
REQ-001-US-008-020 Support multi-destination logging |
orchestrata_ultimate/core/logging configure_logging L109orchestrata_ultimate/kernel/audit/logger AuditLogger L39orchestrata_ultimate/kernel/audit/logger __init__ L53+8 more |
none |
REQ-001-US-008-021 Query logs by session ID |
orchestrata_ultimate/kernel/audit/logger query_by_session L491 |
none |
REQ-001-US-008-022 Query logs by Volk alias |
orchestrata_ultimate/kernel/audit/logger query_by_volk L515 |
none |
REQ-001-US-008-023 Query logs by event type |
orchestrata_ultimate/kernel/audit/logger query_by_event_type L534 |
none |
REQ-001-US-008-024 Query logs by time range |
orchestrata_ultimate/kernel/audit/logger query_by_time_range L553 |
none |
REQ-001-US-008-025 Query logs by correlation ID |
orchestrata_ultimate/kernel/audit/logger query_by_correlation_id L574 |
none |
REQ-001-US-008-026 Support full-text log search |
orchestrata_ultimate/kernel/audit/logger _collect_matching_entries L774orchestrata_ultimate/kernel/audit/logger _query_file_logs L741orchestrata_ultimate/kernel/audit/logger search_logs L597 |
none |
REQ-001-US-008-027 Support log filtering and aggregation |
orchestrata_ultimate/core/protocols/decoupling query_audit_trail L208orchestrata_ultimate/kernel/audit/logger aggregate_logs L620 |
none |
REQ-001-US-008-028 Provide log visualization |
none | none |
REQ-001-US-008-029 Support log export for external analysis |
orchestrata_ultimate/kernel/audit/logger export_logs L655 |
none |
REQ-001-US-008-030 Generate audit reports from logs |
orchestrata_ultimate/kernel/audit/logger generate_audit_report L692 |
none |
REQ-001-US-009-001 Load configuration from YAML files |
orchestrata_ultimate/core/config/manager ConfigurationManager L68orchestrata_ultimate/core/config/manager _detect_file_format L259orchestrata_ultimate/core/config/manager _load_file L239+7 more |
none |
REQ-001-US-009-002 Load configuration from environment variables |
orchestrata_ultimate/core/config/manager ConfigurationManager L68orchestrata_ultimate/core/config/manager _convert_value L374orchestrata_ultimate/core/config/manager _load_env L304+6 more |
none |
REQ-001-US-009-003 Load configuration from Redis |
orchestrata_ultimate/kernel/config_manager _parse_redis_value L398orchestrata_ultimate/kernel/config_manager _redis_get L348orchestrata_ultimate/kernel/config_manager _redis_keys L336+1 more |
none |
REQ-001-US-009-004 Validate configuration schema |
orchestrata_ultimate/core/config/manager ConfigValidationError L53orchestrata_ultimate/core/config/manager ConfigurationManager L68orchestrata_ultimate/core/config/manager _enumerate_paths L612+12 more |
none |
REQ-001-US-009-005 Support configuration defaults |
orchestrata_ultimate/kernel/config_manager set_defaults L441 |
none |
REQ-001-US-009-006 Support configuration overrides (env > file > defaults) |
orchestrata_ultimate/core/config/manager ConfigSource L41orchestrata_ultimate/core/config/manager ConfigurationManager L68orchestrata_ultimate/core/config/manager _deep_update L429+6 more |
none |
REQ-001-US-009-007 Log configuration loading events |
orchestrata_ultimate/core/config/manager load L171orchestrata_ultimate/kernel/config_manager load_from_yaml L250 |
none |
REQ-001-US-009-008 Handle configuration loading errors |
orchestrata_ultimate/core/config/manager load L171orchestrata_ultimate/postman/exceptions InvalidConfigError L300 |
none |
REQ-001-US-009-009 Support encrypted configuration values |
orchestrata_ultimate/kernel/config_manager __init__ L158orchestrata_ultimate/kernel/config_manager encrypted L179orchestrata_ultimate/kernel/config_manager get_decrypted L1017+1 more |
none |
REQ-001-US-009-010 Persist configuration to Redis |
orchestrata_ultimate/kernel/config_manager _redis_set L357orchestrata_ultimate/kernel/config_manager persist_to_redis L928 |
none |
REQ-001-US-009-011 Reload configuration without restart |
orchestrata_ultimate/core/config/manager ConfigurationManager L68orchestrata_ultimate/core/config/manager _start_file_watcher L691orchestrata_ultimate/core/config/manager _start_watchers L684+6 more |
none |
REQ-001-US-009-012 Apply configuration changes incrementally |
orchestrata_ultimate/core/config/manager set L471orchestrata_ultimate/kernel/config_manager _set_value L514orchestrata_ultimate/kernel/config_manager set L491+1 more |
none |
REQ-001-US-009-013 Validate configuration before applying |
orchestrata_ultimate/core/config/manager _validate_path L554orchestrata_ultimate/core/config/manager set L471orchestrata_ultimate/kernel/config_manager validate_before_apply L412 |
none |
REQ-001-US-009-014 Rollback invalid configuration changes |
orchestrata_ultimate/kernel/config_manager _create_snapshot L646orchestrata_ultimate/kernel/config_manager _restore_snapshot L654orchestrata_ultimate/kernel/config_manager rollback L612 |
none |
REQ-001-US-009-015 Notify Volks of configuration changes |
orchestrata_ultimate/core/config/manager ConfigurationManager L68orchestrata_ultimate/core/config/manager _notify_listeners L728orchestrata_ultimate/core/config/manager add_listener L718+1 more |
none |
REQ-001-US-009-016 Support configuration versioning |
orchestrata_ultimate/kernel/config_manager ConfigManager L195orchestrata_ultimate/kernel/config_manager ConfigVersion L85orchestrata_ultimate/kernel/config_manager _create_snapshot L646+3 more |
none |
REQ-001-US-009-017 Track configuration change history |
orchestrata_ultimate/kernel/config_manager ConfigChange L55orchestrata_ultimate/kernel/config_manager ConfigManager L195orchestrata_ultimate/kernel/config_manager _set_value L514+2 more |
none |
REQ-001-US-009-018 Log all configuration changes |
orchestrata_ultimate/kernel/config_manager _set_value L514 |
none |
REQ-001-US-009-019 Support configuration dry-run (test mode) |
orchestrata_ultimate/kernel/config_manager dry_run L1043 |
none |
REQ-001-US-009-020 Provide configuration diff API |
orchestrata_ultimate/kernel/config_manager diff L774 |
none |
REQ-001-US-009-021 Query current configuration |
orchestrata_ultimate/core/config/manager ConfigurationManager L68orchestrata_ultimate/core/config/manager to_dict L755orchestrata_ultimate/kernel/config_manager get_all L480+1 more |
none |
REQ-001-US-009-022 Query configuration history |
orchestrata_ultimate/kernel/config_manager query_history L715 |
none |
REQ-001-US-009-023 Query configuration for specific Volk |
orchestrata_ultimate/kernel/config_manager query_for_volk L723 |
none |
REQ-001-US-009-024 Query configuration by key |
orchestrata_ultimate/core/config/manager get L448orchestrata_ultimate/kernel/config_manager get L447orchestrata_ultimate/kernel/config_manager get_typed L464+1 more |
none |
REQ-001-US-009-025 Export configuration as YAML |
orchestrata_ultimate/kernel/config_manager export_yaml L752 |
none |
REQ-001-US-009-026 Export configuration as JSON |
orchestrata_ultimate/core/config/manager __str__ L765orchestrata_ultimate/kernel/config_manager export_json L763 |
none |
REQ-001-US-009-027 Support configuration comparison |
orchestrata_ultimate/kernel/config_manager diff L774 |
none |
REQ-001-US-009-028 Validate configuration compliance |
orchestrata_ultimate/kernel/config_manager validate_compliance L820 |
none |
REQ-001-US-009-029 Generate configuration documentation |
orchestrata_ultimate/kernel/config_manager generate_documentation L838 |
none |
REQ-001-US-009-030 Support configuration templates |
orchestrata_ultimate/kernel/config_manager apply_template L888 |
none |
REQ-001-US-010-001 Achieve <50ms p95 routing latency |
orchestrata_ultimate/kernel/performance/manager get_routing_p95 L149orchestrata_ultimate/kernel/performance/metrics LatencyTracker L30orchestrata_ultimate/kernel/performance/metrics get_p95 L103+2 more |
none |
REQ-001-US-010-002 Achieve <100ms p99 routing latency |
orchestrata_ultimate/kernel/performance/manager get_routing_p99 L154orchestrata_ultimate/kernel/performance/metrics LatencyTracker L30orchestrata_ultimate/kernel/performance/metrics get_p99 L112+2 more |
none |
REQ-001-US-010-003 Achieve <10ms p95 policy query latency |
orchestrata_ultimate/kernel/performance/manager get_policy_p95 L159orchestrata_ultimate/kernel/performance/metrics LatencyTracker L30orchestrata_ultimate/kernel/performance/metrics get_p95 L103+2 more |
none |
REQ-001-US-010-004 Achieve <20ms p99 policy query latency |
orchestrata_ultimate/kernel/performance/manager get_policy_p99 L164orchestrata_ultimate/kernel/performance/metrics LatencyTracker L30orchestrata_ultimate/kernel/performance/metrics get_p99 L112+2 more |
none |
REQ-001-US-010-005 Support 10,000 messages/sec throughput |
orchestrata_ultimate/kernel/performance/manager get_throughput L181orchestrata_ultimate/kernel/performance/metrics ThroughputTracker L164orchestrata_ultimate/kernel/performance/metrics _prune_old L195+2 more |
none |
REQ-001-US-010-006 Maintain <5MB memory per session |
orchestrata_ultimate/kernel/performance/manager get_average_session_memory_mb L209orchestrata_ultimate/kernel/performance/manager get_session_memory_mb L204orchestrata_ultimate/kernel/performance/manager record_session_memory L194+3 more |
none |
REQ-001-US-010-007 Startup in <2 seconds |
orchestrata_ultimate/kernel/performance/manager start L95orchestrata_ultimate/kernel/performance/sla SLATarget L10 |
none |
REQ-001-US-010-008 Handle 1000+ concurrent Volks |
orchestrata_ultimate/kernel/performance/sla SLATarget L10 |
none |
REQ-001-US-010-009 Maintain 99.9% uptime |
orchestrata_ultimate/kernel/performance/manager get_uptime_percent L228orchestrata_ultimate/kernel/performance/manager mark_system_down L218orchestrata_ultimate/kernel/performance/manager mark_system_up L223+3 more |
none |
REQ-001-US-010-010 Support graceful degradation under load |
orchestrata_ultimate/kernel/performance/manager should_accept_request L290orchestrata_ultimate/kernel/performance/resources BackpressureController L540orchestrata_ultimate/kernel/performance/sla SLATarget L10 |
none |
REQ-001-US-010-011 Cache Prolog query results |
orchestrata_ultimate/kernel/performance/manager cache_get L237orchestrata_ultimate/kernel/performance/manager cache_invalidate L260orchestrata_ultimate/kernel/performance/manager cache_put L249+3 more |
none |
REQ-001-US-010-012 Use connection pooling for Redis |
orchestrata_ultimate/core/redis_factory create_async_redis L158orchestrata_ultimate/core/redis_factory create_sync_redis L93orchestrata_ultimate/infra/redis_state async_client L184+4 more |
none |
REQ-001-US-010-013 Use connection pooling for Neo4j |
orchestrata_ultimate/core/graph/adapters/bolt_async driver L53orchestrata_ultimate/core/graph/adapters/bolt_sync driver L80orchestrata_ultimate/kernel/audit/writers GraphAuditWriter L236+4 more |
none |
REQ-001-US-010-014 Batch message dispatches where possible |
orchestrata_ultimate/kernel/performance/resources BatchProcessor L364 |
none |
REQ-001-US-010-015 Use async I/O for all network operations |
orchestrata_ultimate/core/graph/adapters/bolt_async close L160orchestrata_ultimate/core/graph/adapters/bolt_async driver L53orchestrata_ultimate/core/graph/adapters/bolt_async execute_read L93+12 more |
none |
REQ-001-US-010-016 Minimize serialization overhead |
orchestrata_ultimate/kernel/audit/model from_dict L131orchestrata_ultimate/kernel/audit/model to_dict L115orchestrata_ultimate/orchestrator/engine _deserialize_result L724+1 more |
none |
REQ-001-US-010-017 Use efficient data structures (ring buffers, etc.) |
orchestrata_ultimate/core/monitoring/engine TracerEngine L64orchestrata_ultimate/core/monitoring/engine __init__ L76orchestrata_ultimate/kernel/performance/resources RingBuffer L449 |
none |
REQ-001-US-010-018 Avoid blocking operations in critical paths |
orchestrata_ultimate/kernel/audit/logger _flush_loop L144orchestrata_ultimate/kernel/audit/logger _worker_loop L156orchestrata_ultimate/kernel/audit/logger log L228+1 more |
none |
REQ-001-US-010-019 Profile and optimize hot paths |
orchestrata_ultimate/core/monitoring/engine TracerEngine L64orchestrata_ultimate/core/monitoring/engine monitor L345 |
none |
REQ-001-US-010-020 Implement backpressure mechanisms |
orchestrata_ultimate/kernel/performance/manager get_backpressure_state L304orchestrata_ultimate/kernel/performance/manager should_accept_request L290orchestrata_ultimate/kernel/performance/manager update_load L281+2 more |
none |
REQ-001-US-010-021 Support horizontal scaling (multiple kernel instances) |
orchestrata_ultimate/kernel/performance/cluster ClusterManager L300orchestrata_ultimate/kernel/performance/cluster on_node_added L548orchestrata_ultimate/kernel/performance/cluster register_node L448 |
none |
REQ-001-US-010-022 Support sharding by session ID |
orchestrata_ultimate/kernel/performance/cluster get_node L80orchestrata_ultimate/kernel/performance/cluster get_node_for_session L489orchestrata_ultimate/kernel/performance/manager get_node_for_session L313 |
none |
REQ-001-US-010-023 Support sharding by Volk alias |
orchestrata_ultimate/kernel/performance/cluster get_node L80orchestrata_ultimate/kernel/performance/cluster get_node_for_volk L502orchestrata_ultimate/kernel/performance/manager get_node_for_volk L325 |
none |
REQ-001-US-010-024 Use consistent hashing for routing |
orchestrata_ultimate/kernel/performance/cluster ConsistentHash L22orchestrata_ultimate/kernel/performance/cluster _hash L44orchestrata_ultimate/kernel/performance/cluster add_node L49+1 more |
none |
REQ-001-US-010-025 Support leader election for coordination |
orchestrata_ultimate/kernel/performance/cluster LeaderElection L136orchestrata_ultimate/kernel/performance/cluster _notify_follower L254orchestrata_ultimate/kernel/performance/cluster _notify_leader L243+7 more |
none |
REQ-001-US-010-026 Handle kernel instance failures |
orchestrata_ultimate/kernel/performance/cluster ClusterManager L300orchestrata_ultimate/kernel/performance/cluster NodeHealth L286orchestrata_ultimate/kernel/performance/cluster _handle_node_failure L409+3 more |
none |
REQ-001-US-010-027 Rebalance load across kernel instances |
orchestrata_ultimate/kernel/performance/cluster ClusterManager L300orchestrata_ultimate/kernel/performance/cluster _rebalance L436orchestrata_ultimate/kernel/performance/cluster on_rebalance L558 |
none |
REQ-001-US-010-028 Support autoscaling based on load |
orchestrata_ultimate/kernel/performance/manager evaluate_scaling L350orchestrata_ultimate/kernel/performance/scaling AutoScaler L34orchestrata_ultimate/kernel/performance/scaling ScalingDecision L21+3 more |
none |
REQ-001-US-010-029 Provide metrics for scaling decisions |
orchestrata_ultimate/kernel/performance/cluster get_cluster_stats L523orchestrata_ultimate/kernel/performance/manager evaluate_scaling L350orchestrata_ultimate/kernel/performance/manager get_scaling_decisions L367+5 more |
none |
REQ-001-US-010-030 Test scaling with chaos engineering |
orchestrata_ultimate/kernel/performance/chaos ChaosController L14orchestrata_ultimate/kernel/performance/manager add_chaos_fault L388orchestrata_ultimate/kernel/performance/manager disable_chaos_testing L383+2 more |
none |
REQ-006-031 PipelineEvent.event_type values SHALL be defined by a single |
orchestrata_ultimate/kernel/pipeline_events PipelineEventType L37orchestrata_ultimate/kernel/pipeline_events build_cancelled_event L195orchestrata_ultimate/kernel/pipeline_events build_complete_event L161+4 more |
none |
REQ-006-032 The change SHALL be byte-for-byte wire-compatible: serialized |
orchestrata_ultimate/kernel/pipeline_events PipelineEventType L37 |
none |
REQ-006-033 Documented-but-never-emitted types (pipeline.governance, |
orchestrata_ultimate/kernel/pipeline_events PipelineEventType L37orchestrata_ultimate/kernel/pipeline_events build_cancelled_event L195orchestrata_ultimate/kernel/pipeline_events build_complete_event L161+4 more |
none |
REQ-003-US-004 102). The fallback producer's pipeline.stage / pipeline.paused / |
none | none |
REQ-006-034 PipelineEvent SHALL carry a driver: str = "" field recording |
none | none |
REQ-006-035 Attribution SHALL be resolve, never mutate. A wire producer |
none | none |
REQ-006-036 There SHALL be exactly two production producers of the canonical |
none | none |
REQ-006-037 Human-facing rendering of an event (the orchestrata watch CLI) |
none | none |
REQ-008-001 Log all message routing decisions |
orchestrata_ultimate/knowledge_graph/graph_client GraphClient L43orchestrata_ultimate/knowledge_graph/interfaces IKnowledgeGraph L43 |
tests/kernel/test_audit_logger_enforcement_proof.py::TestMessageRoutingAuditEnforcementtests/knowledge_graph/test_code_intelligence_coverage.py::TestNodesCoveragetests/knowledge_graph/test_code_intelligence_coverage.py::TestTypesNodesSerialization+5 more |
REQ-008-002 Log all policy queries and results |
orchestrata_ultimate/kernel/pipeline_kg sync_intent_to_kg L522orchestrata_ultimate/knowledge_graph/interfaces ITemporalManager L110orchestrata_ultimate/knowledge_graph/sync full_sync L217+3 more |
tests/kernel/test_pipeline_escalation.py::TestPipelineEscalationAuditWiringtests/kernel/test_pipeline_escalation.py::test_approve_fires_policy_query_audittests/knowledge_graph/test_schema_completeness.py::test_19_fr002_relationships_enumerated+2 more |
REQ-008-003 Log all escalation events |
orchestrata_ultimate/knowledge_graph/portfolio KGPortfolioManager L23orchestrata_ultimate/knowledge_graph/portfolio cross_project_query L94orchestrata_ultimate/knowledge_graph/sync map_classes L1500 |
tests/kernel/test_pipeline_escalation.py::TestPipelineEscalationAuditWiringtests/kernel/test_pipeline_escalation.py::test_announce_escalation_fires_escalation_audittests/knowledge_graph/test_graph_context_injection.py::test_calls_section+5 more |
REQ-008-004 Log all session lifecycle events |
orchestrata_ultimate/knowledge_graph/interfaces IQueryEngine L125orchestrata_ultimate/knowledge_graph/query_engine QueryEngine L43orchestrata_ultimate/knowledge_graph/query_engine get_context L367+3 more |
tests/kernel/test_pipeline_session.py::TestSessionLifecycleAuditWiring |
REQ-008-005 Log all resource allocation events |
orchestrata_ultimate/gateway/handlers/knowledge handle_volk_work_context L207orchestrata_ultimate/knowledge_graph/context_injector _append_file_record L894orchestrata_ultimate/knowledge_graph/context_injector _query_context L701+8 more |
none |
REQ-008-006 Log all workflow execution steps |
orchestrata_ultimate/kernel/pipeline_kg _component_from_source_path L57orchestrata_ultimate/kernel/pipeline_kg sync_artifacts_to_kg L395orchestrata_ultimate/kernel/pipeline_kg sync_components_to_kg L342+16 more |
tests/e2e/test_full_pipeline.py::test_full_pipeline_submits_completes_and_syncs_kgtests/knowledge_graph/test_schema_completeness.py::test_task_id_constraint_presenttests/knowledge_graph/test_schema_completeness.py::test_task_node_type_defined+1 more |
REQ-008-007 Log all Volk registration/deregistration |
orchestrata_ultimate/knowledge_graph/portfolio KGPortfolioManager L23orchestrata_ultimate/knowledge_graph/portfolio add_project L54orchestrata_ultimate/knowledge_graph/portfolio create_portfolio L40 |
tests/kernel/test_audit_logger_enforcement_proof.py::TestVolkLifecycleAuditEnforcementtests/kernel/test_volk_registry_pure.py::TestVolkRegistryAuditWiring |
REQ-008-008 Include timestamps in all log entries |
orchestrata_ultimate/knowledge_graph/types DependencyGraph L152 |
none |
REQ-008-009 Include session context in log entries |
orchestrata_ultimate/knowledge_graph/portfolio get_dashboard L85orchestrata_ultimate/knowledge_graph/types Dashboard L235 |
none |
REQ-008-010 Include correlation IDs for tracing |
none | none |
REQ-008-011 Persist logs to Neo4j knowledge graph |
none | none |
REQ-008-012 Persist logs to file system |
orchestrata_ultimate/gateway/handlers/knowledge handle_component_work_context L255orchestrata_ultimate/knowledge_graph/interfaces IQueryEngine L125orchestrata_ultimate/knowledge_graph/query_engine component_work_context L252+2 more |
none |
REQ-008-013 Support log rotation (size and time-based) |
orchestrata_ultimate/kernel/pipeline_kg _assemble_context_for_subject L929orchestrata_ultimate/kernel/pipeline_kg _init_context_injector L131orchestrata_ultimate/kernel/pipeline_kg _kg_available_now L202+16 more |
tests/knowledge_graph/test_graph_context_injection.py::test_architect_has_extracttests/knowledge_graph/test_graph_context_injection.py::test_concierge_has_extracttests/knowledge_graph/test_graph_context_injection.py::test_extracts_from_payload+39 more |
REQ-008-014 Compress archived logs |
orchestrata_ultimate/knowledge_graph/query_engine QueryEngine L43 |
none |
REQ-008-015 Support log retention policies |
orchestrata_ultimate/knowledge_graph/config CacheConfig L53orchestrata_ultimate/knowledge_graph/query_engine _cache_get L419orchestrata_ultimate/knowledge_graph/query_engine _cache_put L428+3 more |
none |
REQ-008-016 Encrypt sensitive log data |
orchestrata_ultimate/knowledge_graph/prolog_bridge check_can_modify L77 |
none |
REQ-008-017 Support log export (JSON, CSV) |
orchestrata_ultimate/knowledge_graph/code_parser CodeParser L30orchestrata_ultimate/knowledge_graph/code_parser _extract_import L256orchestrata_ultimate/knowledge_graph/code_parser _is_method L281+3 more |
none |
REQ-008-018 Handle log storage failures gracefully |
orchestrata_ultimate/knowledge_graph/code_parser _parse_prolog L293orchestrata_ultimate/knowledge_graph/code_parser parse_file L39orchestrata_ultimate/knowledge_graph/graph_node_mixins create_predicate_node L108+3 more |
none |
REQ-008-019 Provide log backup/restore |
orchestrata_ultimate/knowledge_graph/synchronizer _load_state L880orchestrata_ultimate/knowledge_graph/synchronizer _save_state L893orchestrata_ultimate/knowledge_graph/synchronizer _state_file L875+2 more |
none |
REQ-008-020 Support multi-destination logging |
orchestrata_ultimate/knowledge_graph/types FileAnalysis L80 |
tests/knowledge_graph/test_code_intelligence_coverage.py::TestCodeParserErrorBranches |
REQ-008-021 Query logs by session ID |
orchestrata_ultimate/knowledge_graph/code_parser get_file_hash L79orchestrata_ultimate/knowledge_graph/graph_node_mixins _execute L35orchestrata_ultimate/knowledge_graph/graph_node_mixins create_class_node L76+29 more |
tests/knowledge_graph/test_kg_sync_edges.py::TestContainsEdgestests/knowledge_graph/test_kg_sync_edges.py::TestDefinesEdgestests/knowledge_graph/test_kg_sync_edges.py::TestNodeProperties+1 more |
REQ-008-022 Query logs by Volk alias |
orchestrata_ultimate/knowledge_graph/synchronizer FileSynchronizer L39orchestrata_ultimate/knowledge_graph/synchronizer ensure_fresh L1000 |
tests/knowledge_graph/test_graph_context_injection.py::test_ensure_fresh_empty_dirtests/knowledge_graph/test_graph_context_injection.py::test_ensure_fresh_nonexistent_dirtests/knowledge_graph/test_graph_context_injection.py::test_ensure_fresh_respects_extensions+3 more |
REQ-008-023 Query logs by event type |
orchestrata_ultimate/kernel/pipeline_kg sync_artifacts_to_kg L395orchestrata_ultimate/kernel/pipeline_kg sync_decisions_to_kg L589orchestrata_ultimate/knowledge_graph/interfaces sync_file L36+14 more |
none |
REQ-008-024 Query logs by time range |
orchestrata_ultimate/kernel/pipeline_kg _get_graph_client L111orchestrata_ultimate/kernel/pipeline_kg _pre_task_sync L1011orchestrata_ultimate/kernel/pipeline_kg _sync_to_graph L243+3 more |
none |
REQ-008-025 Query logs by correlation ID |
orchestrata_ultimate/knowledge_graph/anomaly_detector Anomaly L43orchestrata_ultimate/knowledge_graph/anomaly_detector AnomalyDetector L77orchestrata_ultimate/knowledge_graph/anomaly_detector AnomalyReport L65+9 more |
none |
REQ-008-026 Support full-text log search |
orchestrata_ultimate/knowledge_graph/config SyncConfig L62orchestrata_ultimate/knowledge_graph/file_watcher FileWatcher L30orchestrata_ultimate/knowledge_graph/file_watcher _filter_changes L129+11 more |
tests/knowledge_graph/test_code_intelligence_coverage.py::TestSynchronizerCoverage |
REQ-008-027 Support log filtering and aggregation |
orchestrata_ultimate/knowledge_graph/temporal invalidate L156orchestrata_ultimate/knowledge_graph/temporal version_node L40orchestrata_ultimate/knowledge_graph/types_nodes Node L19 |
none |
REQ-008-028 Provide log visualization |
orchestrata_ultimate/knowledge_graph/history get_timeline L89orchestrata_ultimate/knowledge_graph/interfaces get_state_at L114orchestrata_ultimate/knowledge_graph/temporal get_state_at L87 |
none |
REQ-008-029 Support log export for external analysis |
orchestrata_ultimate/knowledge_graph/interfaces ITemporalManager L110orchestrata_ultimate/knowledge_graph/temporal TemporalManager L27orchestrata_ultimate/knowledge_graph/versioning VersioningManager L49+4 more |
none |
REQ-008-030 Generate audit reports from logs |
orchestrata_ultimate/knowledge_graph/history HistoryManager L30orchestrata_ultimate/knowledge_graph/history get_change_log L67orchestrata_ultimate/knowledge_graph/history record_change L40+1 more |
none |
REQ-010-001 Achieve <50ms p95 routing latency |
orchestrata_ultimate/core/protocols/memory MemoryEngineProtocol L152 |
tests/agents/volks/test_base_memory_fold.py::test_all_three_paths_pass_through_cleanly_with_no_memory_registeredtests/agents/volks/test_base_memory_fold.py::test_call_llm_real_path_folds_recalled_memory_into_graph_contexttests/agents/volks/test_base_memory_fold.py::test_call_llm_with_tools_real_path_folds_recalled_memory_into_user_message+1 more |
REQ-010-002 Achieve <100ms p99 routing latency |
orchestrata_ultimate/gateway/server _register_memory_engine L467orchestrata_ultimate/memory/hot_store retrieve L175orchestrata_ultimate/memory/hot_store retrieve_by_scope L198+2 more |
tests/agents/volks/test_base_memory_fold.py::test_all_three_paths_pass_through_cleanly_with_no_memory_registeredtests/agents/volks/test_base_memory_fold.py::test_call_llm_real_path_folds_recalled_memory_into_graph_contexttests/agents/volks/test_base_memory_fold.py::test_call_llm_with_tools_real_path_folds_recalled_memory_into_user_message+1 more |
REQ-010-003 Achieve <10ms p95 policy query latency |
orchestrata_ultimate/gateway/handlers/memory _ensure_engine L58orchestrata_ultimate/memory/memory_engine MemoryEngine L47orchestrata_ultimate/memory/memory_engine get_health L130+3 more |
tests/agents/volks/test_base_memory_fold.py::_seed_memory |
REQ-010-004 Achieve <20ms p99 policy query latency |
orchestrata_ultimate/core/protocols/memory MemoryEntry L64orchestrata_ultimate/gateway/handlers/memory _entry_to_dict L24 |
none |
REQ-010-005 Support 10,000 messages/sec throughput |
orchestrata_ultimate/core/protocols/memory MemoryScope L46 |
none |
REQ-010-006 Maintain <5MB memory per session |
orchestrata_ultimate/core/protocols/memory store L160orchestrata_ultimate/gateway/handlers/memory handle_store L76orchestrata_ultimate/memory/memory_engine store L141 |
tests/agents/volks/test_base_memory_fold.py::_seed_memory |
REQ-010-007 Startup in <2 seconds |
orchestrata_ultimate/core/protocols/memory store L160orchestrata_ultimate/memory/memory_engine store L141 |
none |
REQ-010-008 Handle 1000+ concurrent Volks |
orchestrata_ultimate/memory/memory_engine store L141 |
none |
REQ-010-009 Maintain 99.9% uptime |
orchestrata_ultimate/gateway/handlers/memory handle_store L76orchestrata_ultimate/memory/memory_engine store L141 |
none |
REQ-010-010 Support graceful degradation under load |
orchestrata_ultimate/memory/cold_store store L145 |
none |
REQ-010-011 Cache Prolog query results |
orchestrata_ultimate/core/protocols/memory retrieve L176orchestrata_ultimate/gateway/handlers/memory handle_retrieve L96orchestrata_ultimate/memory/cold_store retrieve L239 |
none |
REQ-010-012 Use connection pooling for Redis |
orchestrata_ultimate/memory/hot_store retrieve_by_tag L248 |
none |
REQ-010-013 Use connection pooling for Neo4j |
orchestrata_ultimate/memory/cold_store search_by_scope L253 |
none |
REQ-010-014 Batch message dispatches where possible |
orchestrata_ultimate/core/protocols/memory retrieve L176 |
none |
REQ-010-015 Use async I/O for all network operations |
orchestrata_ultimate/core/protocols/memory search L186orchestrata_ultimate/gateway/handlers/memory handle_search L105orchestrata_ultimate/memory/embedding EmbeddingService L15+1 more |
none |
REQ-010-016 Minimize serialization overhead |
none | none |
REQ-010-017 Use efficient data structures (ring buffers, etc.) |
orchestrata_ultimate/core/protocols/memory search L186orchestrata_ultimate/memory/hot_store _matches_scope L350orchestrata_ultimate/memory/memory_engine search L204 |
none |
REQ-010-018 Avoid blocking operations in critical paths |
orchestrata_ultimate/memory/memory_engine search L204 |
none |
REQ-010-019 Profile and optimize hot paths |
orchestrata_ultimate/core/protocols/memory search L186orchestrata_ultimate/gateway/handlers/memory handle_search L105orchestrata_ultimate/memory/memory_engine search L204 |
none |
REQ-010-020 Implement backpressure mechanisms |
orchestrata_ultimate/core/protocols/memory summarize L216orchestrata_ultimate/memory/memory_engine summarize L263 |
none |
REQ-010-021 Support horizontal scaling (multiple kernel instances) |
orchestrata_ultimate/memory/compressor ContextCompressor L20 |
tests/agents/volks/test_memory_context.py::test_newest_engine_wins_while_counted |
REQ-010-022 Support sharding by session ID |
orchestrata_ultimate/core/protocols/memory summarize L216orchestrata_ultimate/memory/compressor ContextCompressor L20 |
none |
REQ-010-023 Support sharding by Volk alias |
orchestrata_ultimate/core/protocols/memory MemorySummary L115orchestrata_ultimate/memory/compressor ContextCompressor L20 |
none |
REQ-010-024 Use consistent hashing for routing |
orchestrata_ultimate/memory/hot_store RedisMemoryStore L48orchestrata_ultimate/memory/hot_store store L133 |
none |
REQ-010-025 Support leader election for coordination |
orchestrata_ultimate/memory/hot_store store L133 |
none |
REQ-010-026 Handle kernel instance failures |
none | none |
REQ-010-027 Rebalance load across kernel instances |
orchestrata_ultimate/memory/hot_store get_embeddings L263orchestrata_ultimate/memory/hot_store store L133 |
none |
REQ-010-028 Support autoscaling based on load |
orchestrata_ultimate/memory/cold_store GraphMemoryStore L54orchestrata_ultimate/memory/cold_store store L145 |
none |
REQ-010-029 Provide metrics for scaling decisions |
orchestrata_ultimate/memory/cold_store GraphMemoryStore L54orchestrata_ultimate/memory/cold_store store L145 |
none |
REQ-010-030 Test scaling with chaos engineering |
orchestrata_ultimate/memory/cold_store search_by_scope L253 |
none |