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 L345
orchestrata_ultimate/agents/volk_registry VolkDefinition L147
orchestrata_ultimate/agents/volk_registry VolkRegistry L355
+6 more
tests/core/test_traceability.py::Cls
tests/core/test_tracing.py::Cls
tests/knowledge_graph/sample-sync/src/sample_module.py::SampleService
+6 more
REQ-001-002 Registration includes capabilities declaration orchestrata_ultimate/agents/volk_registry VolkCapability L115
orchestrata_ultimate/agents/volk_registry VolkDefinition L147
tests/core/test_traceability.py::Cls
tests/core/test_tracing.py::Cls
tests/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 L147
orchestrata_ultimate/agents/volk_registry VolkProtocol L45
tests/core/test_traceability.py::Cls
tests/core/test_tracing.py::Cls
tests/knowledge_graph/sample-sync/src/sample_module.py::top_level_function
REQ-001-004 Registration includes resource requirements orchestrata_ultimate/agents/volk_registry ResourceRequirements L82
orchestrata_ultimate/agents/volk_registry VolkDefinition L147
none
REQ-001-005 Registration validates alias uniqueness orchestrata_ultimate/agents/volk_registry DuplicateAliasError L328
orchestrata_ultimate/agents/volk_registry _validate_definition L669
orchestrata_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 L337
orchestrata_ultimate/agents/volk_registry _validate_capabilities L650
orchestrata_ultimate/agents/volk_registry _validate_definition L669
none
REQ-001-007 Registration returns registration token orchestrata_ultimate/agents/volk_registry VolkRegistration L278
orchestrata_ultimate/agents/volk_registry _create_registration L697
orchestrata_ultimate/agents/volk_registry _generate_token L605
none
REQ-001-008 Registration updates Volk registry orchestrata_ultimate/agents/volk_registry _create_registration L697
orchestrata_ultimate/agents/volk_registry _sync_governance_facts L545
orchestrata_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 L798
orchestrata_ultimate/agents/volk_registry _post_register_hooks L726
orchestrata_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 L812
orchestrata_ultimate/agents/volk_registry _post_register_hooks L726
none
REQ-001-011 Volk can query all registered Volks orchestrata_ultimate/agents/volk_registry VolkRegistry L355
orchestrata_ultimate/agents/volk_registry count L1343
orchestrata_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 L866
orchestrata_ultimate/core/protocols/decoupling list_volks_by_capability L78
orchestrata_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 L886
orchestrata_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__ L376
orchestrata_ultimate/agents/volk_registry _fire_status_change L497
orchestrata_ultimate/agents/volk_registry _sync_governance_active L564
+7 more
tests/gateway/test_volk_status_event_broadcast.py::test_status_change_event_reaches_gateway_broadcast
tests/kernel/test_volk_registry_status_events.py::test_heartbeat_transition_fires_on_status_change
tests/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 L234
orchestrata_ultimate/agents/volk_registry get_volk_metadata L1052
orchestrata_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_volk
tests/kernel/test_status_report_health.py::TestStatusReportHeartbeatHealth
REQ-001-016 Discovery uses caching for performance orchestrata_ultimate/agents/volk_registry __init__ L376
orchestrata_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 L497
orchestrata_ultimate/agents/volk_registry get_volk_metadata L1052
orchestrata_ultimate/agents/volk_registry record_heartbeat L1182
+2 more
tests/kernel/test_heartbeat_pump.py::test_beat_once_tolerates_probe_exception
tests/kernel/test_heartbeat_pump.py::test_partial_failure_tolerated
tests/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 L313
orchestrata_ultimate/agents/runtime get_instance_health L351
orchestrata_ultimate/agents/volk_registry VolkHealth L208
+20 more
tests/agents/test_message_volk_delivery_status.py::test_message_volk_health_warning_preserved
tests/agents/test_message_volk_delivery_status.py::test_message_volk_records_recipient_heartbeat
tests/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 L265
orchestrata_ultimate/agents/volk_registry _apply_query_filters L1301
orchestrata_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 L1301
orchestrata_ultimate/agents/volk_registry query_volks L1261
none
REQ-001-021 Volk can deregister cleanly orchestrata_ultimate/agents/volk_registry VolkRegistry L355
orchestrata_ultimate/agents/volk_registry deregister_volk L980
orchestrata_ultimate/core/protocols/components fire_volk L243
+2 more
none
REQ-001-022 Deregistration notifies dependent Volks orchestrata_ultimate/agents/volk_registry _notify_deregistration L1029
orchestrata_ultimate/agents/volk_registry _post_deregister_cleanup L949
orchestrata_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 L949
orchestrata_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 L915
orchestrata_ultimate/agents/volk_registry decrement_in_flight_messages L1242
orchestrata_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 L471
orchestrata_ultimate/agents/kernel_handler _build_reply L271
orchestrata_ultimate/agents/kernel_handler _process_in_background L323
+19 more
tests/core/test_traceability.py::my_func
tests/core/test_tracing.py::my_func
tests/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 L78
orchestrata_ultimate/cxp/reply_router queue_for L189
orchestrata_ultimate/cxp/reply_router route L243
+9 more
none
REQ-001-US-002-004 Support multicast (multiple recipients) routing orchestrata_ultimate/kernel/router CXPRouter L165
orchestrata_ultimate/kernel/router RoutingMode L28
orchestrata_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 L165
orchestrata_ultimate/kernel/router RoutingMode L28
orchestrata_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 L221
orchestrata_ultimate/agents/task_executor _resolve_alias L301
orchestrata_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 L485
orchestrata_ultimate/kernel/router resolve_recipients L426
none
REQ-001-US-002-008 Handle routing to offline Volks orchestrata_ultimate/cxp/reply_router ReplyRouter L78
orchestrata_ultimate/cxp/reply_router _sweep L282
orchestrata_ultimate/cxp/reply_router close_drain L229
+5 more
tests/cxp/test_reply_router.py::test_active_drain_never_evicted
tests/cxp/test_reply_router.py::test_cap_evicts_oldest_idle_inactive_first
tests/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 L155
orchestrata_ultimate/kernel/router RoutingResult L140
orchestrata_ultimate/kernel/router RoutingStatus L41
+5 more
tests/agents/test_message_volk_delivery_status.py::test_message_volk_reports_no_route_as_failure
tests/postman/test_aroute_outcome.py::test_no_route_outcome
REQ-001-US-002-010 Validate message schema before routing orchestrata_ultimate/kernel/router CXPRouter L165
orchestrata_ultimate/kernel/router _validate_packet_schema L203
orchestrata_ultimate/kernel/router route L313
none
REQ-001-US-002-011 Dispatch message via Volk-specified protocol orchestrata_ultimate/kernel/dispatcher MessageDispatcher L290
orchestrata_ultimate/kernel/dispatcher _dispatch_by_protocol L625
orchestrata_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 L772
orchestrata_ultimate/cxp/direct_cxp_adapter DirectCXPClient L337
orchestrata_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 L835
orchestrata_ultimate/kernel/dispatcher _send_websocket L798
orchestrata_ultimate/kernel/dispatcher dispatch_websocket L770
none
REQ-001-US-002-014 Support CXP over HTTP dispatch orchestrata_ultimate/kernel/dispatcher _post_http L962
orchestrata_ultimate/kernel/dispatcher _serialize_packet L942
orchestrata_ultimate/kernel/dispatcher dispatch_http L914
none
REQ-001-US-002-015 Retry failed dispatches with exponential backoff orchestrata_ultimate/kernel/dispatcher DispatchAttempt L225
orchestrata_ultimate/kernel/dispatcher dispatch L367
orchestrata_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 L225
orchestrata_ultimate/kernel/dispatcher DispatchResult L251
orchestrata_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 L532
orchestrata_ultimate/kernel/dispatcher dispatch L367
orchestrata_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 L323
orchestrata_ultimate/cxp/servicer enqueue_reply L217
orchestrata_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 L86
orchestrata_ultimate/kernel/queue_manager _redis_result L34
orchestrata_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 L264
orchestrata_ultimate/core/protocols/decoupling queue_push L261
orchestrata_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 L86
orchestrata_ultimate/kernel/queue_manager _queue_key L182
orchestrata_ultimate/kernel/queue_manager enqueue L197
none
REQ-001-US-002-024 Apply backpressure when queue full orchestrata_ultimate/kernel/performance/resources BackpressureController L540
orchestrata_ultimate/kernel/performance/resources should_accept L620
orchestrata_ultimate/kernel/queue_manager QueueManager L86
none
REQ-001-US-002-025 Monitor queue depth and latency orchestrata_ultimate/core/protocols/decoupling queue_length L267
orchestrata_ultimate/infra/redis_state queue_length L551
orchestrata_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 L86
orchestrata_ultimate/kernel/queue_manager _dlq_key L187
orchestrata_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 L86
orchestrata_ultimate/kernel/queue_manager QueueStats L48
orchestrata_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 L551
orchestrata_ultimate/cxp/reply_router ReplyRouter L78
orchestrata_ultimate/cxp/reply_router _QueueEntry L59
+3 more
tests/cxp/test_reply_router.py::test_active_drain_never_evicted
tests/cxp/test_reply_router.py::test_cap_evicts_oldest_idle_inactive_first
tests/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 L323
orchestrata_ultimate/kernel/router MessageStatus L54
orchestrata_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 L323
orchestrata_ultimate/kernel/router MessageStatus L54
none
REQ-001-US-002-033 Track message status: delivered orchestrata_ultimate/agents/kernel_handler _build_no_reply_packet L504
orchestrata_ultimate/agents/kernel_handler _build_reply L271
orchestrata_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_terminal
tests/agents/test_kernel_handler_ack_only.py::test_second_round_never_reemits_first_rounds_reply
tests/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 L54
orchestrata_ultimate/postman/guarantees acknowledge L179
orchestrata_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 L551
orchestrata_ultimate/agents/kernel_handler _build_failure_packet L471
orchestrata_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_terminal
tests/agents/test_kernel_handler_ack_only.py::test_shutdown_cancels_and_sinks_failure
tests/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 L165
orchestrata_ultimate/kernel/router get_message_status L617
orchestrata_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 L504
orchestrata_ultimate/agents/kernel_handler _build_terminal_packet L396
orchestrata_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 L551
orchestrata_ultimate/agents/kernel_handler _build_failure_packet L471
orchestrata_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 L551
orchestrata_ultimate/agents/kernel_handler _build_failure_packet L471
orchestrata_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 L165
orchestrata_ultimate/kernel/router RoutingMetrics L100
orchestrata_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 L402
orchestrata_ultimate/cxp/router _check_governance L216
orchestrata_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 L267
orchestrata_ultimate/governance/resource_access ResourceAccessController L33
orchestrata_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 L142
orchestrata_ultimate/kernel/policy_evaluator OwnershipStatus L72
orchestrata_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 L275
orchestrata_ultimate/kernel/policy_evaluator get_escalation_path L1061
orchestrata_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 L242
orchestrata_ultimate/core/protocols/decoupling get_cached_decision L247
orchestrata_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 L408
orchestrata_ultimate/orchestrator/policy_registry activate L207
orchestrata_ultimate/orchestrator/policy_registry deactivate L187
+1 more
none
REQ-001-US-003-007 Handle Prolog query timeouts orchestrata_ultimate/kernel/policy_evaluator PolicyTimeoutError L255
orchestrata_ultimate/kernel/policy_evaluator _execute_with_timeout L486
none
REQ-001-US-003-008 Handle Prolog query failures orchestrata_ultimate/governance/_strict governance_strict L19
orchestrata_ultimate/governance/policy_engine _evaluate_prolog_and_finalise L292
orchestrata_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 L367
orchestrata_ultimate/kernel/policy_evaluator PolicyAuditEntry L221
orchestrata_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 L198
orchestrata_ultimate/kernel/policy_evaluator dry_run L1216
orchestrata_ultimate/kernel/policy_evaluator to_dict L208
none
REQ-001-US-003-011 Validate message sender has authority orchestrata_ultimate/kernel/pam/enforcer PAMEnforcer L33
orchestrata_ultimate/kernel/pam/enforcer _check_direct_ownership L77
orchestrata_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 L33
orchestrata_ultimate/kernel/pam/enforcer _lookup_actual_component_owner L254
orchestrata_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 L33
orchestrata_ultimate/kernel/pam/enforcer enforce_boundary L327
orchestrata_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 L33
orchestrata_ultimate/kernel/pam/enforcer enforce_boundary L327
orchestrata_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 L33
orchestrata_ultimate/kernel/pam/enforcer enforce_boundary L327
orchestrata_ultimate/kernel/pam/types BoundaryResult L118
none
REQ-001-US-003-016 Validate workflow step permissions orchestrata_ultimate/kernel/pam/enforcer PAMEnforcer L33
orchestrata_ultimate/kernel/pam/enforcer check_permission L401
orchestrata_ultimate/kernel/pam/types PermissionResult L136
none
REQ-001-US-003-017 Enforce read/write/execute permissions orchestrata_ultimate/kernel/pam/enforcer PAMEnforcer L33
orchestrata_ultimate/kernel/pam/enforcer check_permission L401
orchestrata_ultimate/kernel/pam/types PermissionResult L136
+2 more
none
REQ-001-US-003-018 Support ownership delegation orchestrata_ultimate/kernel/pam/enforcer PAMEnforcer L33
orchestrata_ultimate/kernel/pam/enforcer _check_delegation L98
orchestrata_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 L33
orchestrata_ultimate/kernel/pam/enforcer grant_temporary_permission L519
orchestrata_ultimate/kernel/pam/types PermissionResult L136
none
REQ-001-US-003-020 Log all permission violations orchestrata_ultimate/core/protocols/decoupling log_violation L157
orchestrata_ultimate/kernel/pam/enforcer PAMEnforcer L33
orchestrata_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 L39
orchestrata_ultimate/kernel/pam/escalation detect_conflict L76
orchestrata_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 L518
orchestrata_ultimate/kernel/pam/escalation get_escalation_path L117
orchestrata_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 L39
orchestrata_ultimate/kernel/pam/escalation MultiHopEscalationManager L354
orchestrata_ultimate/kernel/pam/escalation escalate L177
+3 more
none
REQ-001-US-003-024 Track escalation history orchestrata_ultimate/core/protocols/decoupling get_escalations L199
orchestrata_ultimate/core/protocols/decoupling get_resolutions L205
orchestrata_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 L268
orchestrata_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 L223
orchestrata_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 L354
orchestrata_ultimate/kernel/pam/escalation multi_hop_escalate L422
none
REQ-001-US-003-029 Provide escalation resolution feedback orchestrata_ultimate/kernel/pam/escalation resolve L229
orchestrata_ultimate/kernel/pam/types Resolution L212
none
REQ-001-US-003-030 Log all escalation events orchestrata_ultimate/kernel/audit/logger log_escalation L310
orchestrata_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 L74
orchestrata_ultimate/kernel/session_manager create_session L342
orchestrata_ultimate/orchestrator/engine start_session L632
tests/session/test_kernel_session.py::test_create_session_with_metadata
tests/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 L226
orchestrata_ultimate/infra/redis_state SessionState L100
orchestrata_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_sessions
tests/session/test_kernel_session.py::test_session_ttl_expiration
REQ-001-US-004-009 Set session resource limits orchestrata_ultimate/kernel/session_manager close L697
orchestrata_ultimate/kernel/session_manager initialize L292
orchestrata_ultimate/kernel/session_manager resume_session L392
tests/session/test_kernel_session.py::test_resume_session_from_redis
tests/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 L178
orchestrata_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 L35
orchestrata_ultimate/core/protocols/decoupling retract_fact L45
orchestrata_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 L123
orchestrata_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 L94
orchestrata_ultimate/session/interfaces get_carryover L99
orchestrata_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 L149
orchestrata_ultimate/kernel/session_context _context_key L232
orchestrata_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 L229
orchestrata_ultimate/kernel/session_context SessionContext L149
orchestrata_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 L232
orchestrata_ultimate/kernel/session_context SessionContext L149
orchestrata_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 L47
orchestrata_ultimate/kernel/session_context extract_context L456
orchestrata_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 L260
orchestrata_ultimate/kernel/session_context SessionContext L149
orchestrata_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 L490
orchestrata_ultimate/kernel/pipeline_session shutdown L468
orchestrata_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 L626
orchestrata_ultimate/kernel/session_manager _project_slug L60
orchestrata_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 L235
orchestrata_ultimate/infra/redis_state delete_session L286
orchestrata_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 L671
orchestrata_ultimate/kernel/session_manager archive_session L455
tests/session/test_kernel_session.py::test_broadcast_to_session_volks
tests/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_leakage
tests/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 L671
orchestrata_ultimate/session/carryover import_from_session L235
orchestrata_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 L183
orchestrata_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 L63
orchestrata_ultimate/governance/escalation_handler/resolver detect_conflict L88
orchestrata_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 L88
orchestrata_ultimate/kernel/pam/escalation detect_conflict L76
orchestrata_ultimate/kernel/pam/types ConflictType L59
none
REQ-001-US-005-003 Detect resource conflicts orchestrata_ultimate/governance/escalation_handler/handler escalate L105
orchestrata_ultimate/kernel/pam/escalation detect_conflict L76
orchestrata_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 L65
orchestrata_ultimate/kernel/pam/escalation get_escalation_path L117
orchestrata_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 L280
orchestrata_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 L65
orchestrata_ultimate/governance/escalation_handler/handler _is_terminal_authority L548
orchestrata_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 L354
orchestrata_ultimate/kernel/pam/escalation multi_hop_escalate L422
orchestrata_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 L338
orchestrata_ultimate/governance/escalation_handler/handler handle_escalation_timeout L419
orchestrata_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 L288
orchestrata_ultimate/kernel/pam/types ConflictContext L155
orchestrata_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 L567
orchestrata_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 L144
orchestrata_ultimate/governance/escalation_handler/resolver ConflictResolver L63
orchestrata_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 L163
orchestrata_ultimate/governance/escalation_handler/resolver _log_resolution_decision L371
orchestrata_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 L310
orchestrata_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 L597
orchestrata_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 L369
orchestrata_ultimate/orchestrator/intent_workflow pause L452
orchestrata_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 L67
orchestrata_ultimate/core/artifact_store ArtifactStore L195
orchestrata_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 L419
orchestrata_ultimate/kernel/pipeline_events PipelineEvent L84
orchestrata_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 L85
orchestrata_ultimate/kernel/resource_monitor ResourceSnapshot L48
orchestrata_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 L85
orchestrata_ultimate/kernel/resource_monitor get_system_summary L283
none
REQ-001-US-007-010 Alert on resource exhaustion orchestrata_ultimate/kernel/resource_monitor ResourceAlert L29
orchestrata_ultimate/kernel/resource_monitor ResourceMonitor L85
orchestrata_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 L145
orchestrata_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 L145
orchestrata_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 L85
orchestrata_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 L283
orchestrata_ultimate/kernel/resource_monitor to_dict L62
none
REQ-001-US-007-027 Track resource usage trends orchestrata_ultimate/kernel/resource_monitor ResourceMonitor L85
orchestrata_ultimate/kernel/resource_monitor get_average_cpu L238
orchestrata_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 L254
orchestrata_ultimate/kernel/audit/model AuditEventType L14
orchestrata_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 L283
orchestrata_ultimate/kernel/audit/model AuditEventType L14
orchestrata_ultimate/kernel/audit/model AuditOutcome L65
none
REQ-001-US-008-003 Log all escalation events orchestrata_ultimate/core/protocols/decoupling log_escalation L160
orchestrata_ultimate/kernel/audit/logger log_escalation L310
orchestrata_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 L350
orchestrata_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 L380
orchestrata_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 L419
orchestrata_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 L462
orchestrata_ultimate/kernel/audit/logger log_volk_lifecycle L457
orchestrata_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 L64
orchestrata_ultimate/kernel/audit/_common _utc_now L27
orchestrata_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 L64
orchestrata_ultimate/kernel/audit/logger _create_entry L198
orchestrata_ultimate/kernel/audit/model AuditEntry L78
none
REQ-001-US-008-010 Include correlation IDs for tracing orchestrata_ultimate/core/logging new_correlation_id L153
orchestrata_ultimate/kernel/audit/logger _create_entry L198
orchestrata_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 L174
orchestrata_ultimate/governance/escalation_handler/sla _audit_breach_to_graph L279
orchestrata_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 L109
orchestrata_ultimate/kernel/audit/model AuditLogConfig L149
orchestrata_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 L149
orchestrata_ultimate/kernel/audit/writers FileAuditWriter L60
orchestrata_ultimate/kernel/audit/writers _rotate_log L112
+1 more
none
REQ-001-US-008-014 Compress archived logs orchestrata_ultimate/kernel/audit/model AuditLogConfig L149
orchestrata_ultimate/kernel/audit/writers FileAuditWriter L60
orchestrata_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 L149
orchestrata_ultimate/kernel/audit/writers FileAuditWriter L60
orchestrata_ultimate/kernel/audit/writers _cleanup_old_logs L149
none
REQ-001-US-008-016 Encrypt sensitive log data orchestrata_ultimate/kernel/audit/model AuditLogConfig L149
orchestrata_ultimate/kernel/audit/writers FileAuditWriter L60
orchestrata_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 L37
orchestrata_ultimate/kernel/audit/queue _redis_result L23
orchestrata_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 L798
orchestrata_ultimate/kernel/audit/logger restore_logs L817
none
REQ-001-US-008-020 Support multi-destination logging orchestrata_ultimate/core/logging configure_logging L109
orchestrata_ultimate/kernel/audit/logger AuditLogger L39
orchestrata_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 L774
orchestrata_ultimate/kernel/audit/logger _query_file_logs L741
orchestrata_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 L208
orchestrata_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 L68
orchestrata_ultimate/core/config/manager _detect_file_format L259
orchestrata_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 L68
orchestrata_ultimate/core/config/manager _convert_value L374
orchestrata_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 L398
orchestrata_ultimate/kernel/config_manager _redis_get L348
orchestrata_ultimate/kernel/config_manager _redis_keys L336
+1 more
none
REQ-001-US-009-004 Validate configuration schema orchestrata_ultimate/core/config/manager ConfigValidationError L53
orchestrata_ultimate/core/config/manager ConfigurationManager L68
orchestrata_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 L41
orchestrata_ultimate/core/config/manager ConfigurationManager L68
orchestrata_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 L171
orchestrata_ultimate/kernel/config_manager load_from_yaml L250
none
REQ-001-US-009-008 Handle configuration loading errors orchestrata_ultimate/core/config/manager load L171
orchestrata_ultimate/postman/exceptions InvalidConfigError L300
none
REQ-001-US-009-009 Support encrypted configuration values orchestrata_ultimate/kernel/config_manager __init__ L158
orchestrata_ultimate/kernel/config_manager encrypted L179
orchestrata_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 L357
orchestrata_ultimate/kernel/config_manager persist_to_redis L928
none
REQ-001-US-009-011 Reload configuration without restart orchestrata_ultimate/core/config/manager ConfigurationManager L68
orchestrata_ultimate/core/config/manager _start_file_watcher L691
orchestrata_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 L471
orchestrata_ultimate/kernel/config_manager _set_value L514
orchestrata_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 L554
orchestrata_ultimate/core/config/manager set L471
orchestrata_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 L646
orchestrata_ultimate/kernel/config_manager _restore_snapshot L654
orchestrata_ultimate/kernel/config_manager rollback L612
none
REQ-001-US-009-015 Notify Volks of configuration changes orchestrata_ultimate/core/config/manager ConfigurationManager L68
orchestrata_ultimate/core/config/manager _notify_listeners L728
orchestrata_ultimate/core/config/manager add_listener L718
+1 more
none
REQ-001-US-009-016 Support configuration versioning orchestrata_ultimate/kernel/config_manager ConfigManager L195
orchestrata_ultimate/kernel/config_manager ConfigVersion L85
orchestrata_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 L55
orchestrata_ultimate/kernel/config_manager ConfigManager L195
orchestrata_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 L68
orchestrata_ultimate/core/config/manager to_dict L755
orchestrata_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 L448
orchestrata_ultimate/kernel/config_manager get L447
orchestrata_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__ L765
orchestrata_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 L149
orchestrata_ultimate/kernel/performance/metrics LatencyTracker L30
orchestrata_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 L154
orchestrata_ultimate/kernel/performance/metrics LatencyTracker L30
orchestrata_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 L159
orchestrata_ultimate/kernel/performance/metrics LatencyTracker L30
orchestrata_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 L164
orchestrata_ultimate/kernel/performance/metrics LatencyTracker L30
orchestrata_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 L181
orchestrata_ultimate/kernel/performance/metrics ThroughputTracker L164
orchestrata_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 L209
orchestrata_ultimate/kernel/performance/manager get_session_memory_mb L204
orchestrata_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 L95
orchestrata_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 L228
orchestrata_ultimate/kernel/performance/manager mark_system_down L218
orchestrata_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 L290
orchestrata_ultimate/kernel/performance/resources BackpressureController L540
orchestrata_ultimate/kernel/performance/sla SLATarget L10
none
REQ-001-US-010-011 Cache Prolog query results orchestrata_ultimate/kernel/performance/manager cache_get L237
orchestrata_ultimate/kernel/performance/manager cache_invalidate L260
orchestrata_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 L158
orchestrata_ultimate/core/redis_factory create_sync_redis L93
orchestrata_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 L53
orchestrata_ultimate/core/graph/adapters/bolt_sync driver L80
orchestrata_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 L160
orchestrata_ultimate/core/graph/adapters/bolt_async driver L53
orchestrata_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 L131
orchestrata_ultimate/kernel/audit/model to_dict L115
orchestrata_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 L64
orchestrata_ultimate/core/monitoring/engine __init__ L76
orchestrata_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 L144
orchestrata_ultimate/kernel/audit/logger _worker_loop L156
orchestrata_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 L64
orchestrata_ultimate/core/monitoring/engine monitor L345
none
REQ-001-US-010-020 Implement backpressure mechanisms orchestrata_ultimate/kernel/performance/manager get_backpressure_state L304
orchestrata_ultimate/kernel/performance/manager should_accept_request L290
orchestrata_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 L300
orchestrata_ultimate/kernel/performance/cluster on_node_added L548
orchestrata_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 L80
orchestrata_ultimate/kernel/performance/cluster get_node_for_session L489
orchestrata_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 L80
orchestrata_ultimate/kernel/performance/cluster get_node_for_volk L502
orchestrata_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 L22
orchestrata_ultimate/kernel/performance/cluster _hash L44
orchestrata_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 L136
orchestrata_ultimate/kernel/performance/cluster _notify_follower L254
orchestrata_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 L300
orchestrata_ultimate/kernel/performance/cluster NodeHealth L286
orchestrata_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 L300
orchestrata_ultimate/kernel/performance/cluster _rebalance L436
orchestrata_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 L350
orchestrata_ultimate/kernel/performance/scaling AutoScaler L34
orchestrata_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 L523
orchestrata_ultimate/kernel/performance/manager evaluate_scaling L350
orchestrata_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 L14
orchestrata_ultimate/kernel/performance/manager add_chaos_fault L388
orchestrata_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 L37
orchestrata_ultimate/kernel/pipeline_events build_cancelled_event L195
orchestrata_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 L37
orchestrata_ultimate/kernel/pipeline_events build_cancelled_event L195
orchestrata_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 L43
orchestrata_ultimate/knowledge_graph/interfaces IKnowledgeGraph L43
tests/kernel/test_audit_logger_enforcement_proof.py::TestMessageRoutingAuditEnforcement
tests/knowledge_graph/test_code_intelligence_coverage.py::TestNodesCoverage
tests/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 L522
orchestrata_ultimate/knowledge_graph/interfaces ITemporalManager L110
orchestrata_ultimate/knowledge_graph/sync full_sync L217
+3 more
tests/kernel/test_pipeline_escalation.py::TestPipelineEscalationAuditWiring
tests/kernel/test_pipeline_escalation.py::test_approve_fires_policy_query_audit
tests/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 L23
orchestrata_ultimate/knowledge_graph/portfolio cross_project_query L94
orchestrata_ultimate/knowledge_graph/sync map_classes L1500
tests/kernel/test_pipeline_escalation.py::TestPipelineEscalationAuditWiring
tests/kernel/test_pipeline_escalation.py::test_announce_escalation_fires_escalation_audit
tests/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 L125
orchestrata_ultimate/knowledge_graph/query_engine QueryEngine L43
orchestrata_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 L207
orchestrata_ultimate/knowledge_graph/context_injector _append_file_record L894
orchestrata_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 L57
orchestrata_ultimate/kernel/pipeline_kg sync_artifacts_to_kg L395
orchestrata_ultimate/kernel/pipeline_kg sync_components_to_kg L342
+16 more
tests/e2e/test_full_pipeline.py::test_full_pipeline_submits_completes_and_syncs_kg
tests/knowledge_graph/test_schema_completeness.py::test_task_id_constraint_present
tests/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 L23
orchestrata_ultimate/knowledge_graph/portfolio add_project L54
orchestrata_ultimate/knowledge_graph/portfolio create_portfolio L40
tests/kernel/test_audit_logger_enforcement_proof.py::TestVolkLifecycleAuditEnforcement
tests/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 L85
orchestrata_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 L255
orchestrata_ultimate/knowledge_graph/interfaces IQueryEngine L125
orchestrata_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 L929
orchestrata_ultimate/kernel/pipeline_kg _init_context_injector L131
orchestrata_ultimate/kernel/pipeline_kg _kg_available_now L202
+16 more
tests/knowledge_graph/test_graph_context_injection.py::test_architect_has_extract
tests/knowledge_graph/test_graph_context_injection.py::test_concierge_has_extract
tests/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 L53
orchestrata_ultimate/knowledge_graph/query_engine _cache_get L419
orchestrata_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 L30
orchestrata_ultimate/knowledge_graph/code_parser _extract_import L256
orchestrata_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 L293
orchestrata_ultimate/knowledge_graph/code_parser parse_file L39
orchestrata_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 L880
orchestrata_ultimate/knowledge_graph/synchronizer _save_state L893
orchestrata_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 L79
orchestrata_ultimate/knowledge_graph/graph_node_mixins _execute L35
orchestrata_ultimate/knowledge_graph/graph_node_mixins create_class_node L76
+29 more
tests/knowledge_graph/test_kg_sync_edges.py::TestContainsEdges
tests/knowledge_graph/test_kg_sync_edges.py::TestDefinesEdges
tests/knowledge_graph/test_kg_sync_edges.py::TestNodeProperties
+1 more
REQ-008-022 Query logs by Volk alias orchestrata_ultimate/knowledge_graph/synchronizer FileSynchronizer L39
orchestrata_ultimate/knowledge_graph/synchronizer ensure_fresh L1000
tests/knowledge_graph/test_graph_context_injection.py::test_ensure_fresh_empty_dir
tests/knowledge_graph/test_graph_context_injection.py::test_ensure_fresh_nonexistent_dir
tests/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 L395
orchestrata_ultimate/kernel/pipeline_kg sync_decisions_to_kg L589
orchestrata_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 L111
orchestrata_ultimate/kernel/pipeline_kg _pre_task_sync L1011
orchestrata_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 L43
orchestrata_ultimate/knowledge_graph/anomaly_detector AnomalyDetector L77
orchestrata_ultimate/knowledge_graph/anomaly_detector AnomalyReport L65
+9 more
none
REQ-008-026 Support full-text log search orchestrata_ultimate/knowledge_graph/config SyncConfig L62
orchestrata_ultimate/knowledge_graph/file_watcher FileWatcher L30
orchestrata_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 L156
orchestrata_ultimate/knowledge_graph/temporal version_node L40
orchestrata_ultimate/knowledge_graph/types_nodes Node L19
none
REQ-008-028 Provide log visualization orchestrata_ultimate/knowledge_graph/history get_timeline L89
orchestrata_ultimate/knowledge_graph/interfaces get_state_at L114
orchestrata_ultimate/knowledge_graph/temporal get_state_at L87
none
REQ-008-029 Support log export for external analysis orchestrata_ultimate/knowledge_graph/interfaces ITemporalManager L110
orchestrata_ultimate/knowledge_graph/temporal TemporalManager L27
orchestrata_ultimate/knowledge_graph/versioning VersioningManager L49
+4 more
none
REQ-008-030 Generate audit reports from logs orchestrata_ultimate/knowledge_graph/history HistoryManager L30
orchestrata_ultimate/knowledge_graph/history get_change_log L67
orchestrata_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_registered
tests/agents/volks/test_base_memory_fold.py::test_call_llm_real_path_folds_recalled_memory_into_graph_context
tests/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 L467
orchestrata_ultimate/memory/hot_store retrieve L175
orchestrata_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_registered
tests/agents/volks/test_base_memory_fold.py::test_call_llm_real_path_folds_recalled_memory_into_graph_context
tests/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 L58
orchestrata_ultimate/memory/memory_engine MemoryEngine L47
orchestrata_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 L64
orchestrata_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 L160
orchestrata_ultimate/gateway/handlers/memory handle_store L76
orchestrata_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 L160
orchestrata_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 L76
orchestrata_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 L176
orchestrata_ultimate/gateway/handlers/memory handle_retrieve L96
orchestrata_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 L186
orchestrata_ultimate/gateway/handlers/memory handle_search L105
orchestrata_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 L186
orchestrata_ultimate/memory/hot_store _matches_scope L350
orchestrata_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 L186
orchestrata_ultimate/gateway/handlers/memory handle_search L105
orchestrata_ultimate/memory/memory_engine search L204
none
REQ-010-020 Implement backpressure mechanisms orchestrata_ultimate/core/protocols/memory summarize L216
orchestrata_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 L216
orchestrata_ultimate/memory/compressor ContextCompressor L20
none
REQ-010-023 Support sharding by Volk alias orchestrata_ultimate/core/protocols/memory MemorySummary L115
orchestrata_ultimate/memory/compressor ContextCompressor L20
none
REQ-010-024 Use consistent hashing for routing orchestrata_ultimate/memory/hot_store RedisMemoryStore L48
orchestrata_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 L263
orchestrata_ultimate/memory/hot_store store L133
none
REQ-010-028 Support autoscaling based on load orchestrata_ultimate/memory/cold_store GraphMemoryStore L54
orchestrata_ultimate/memory/cold_store store L145
none
REQ-010-029 Provide metrics for scaling decisions orchestrata_ultimate/memory/cold_store GraphMemoryStore L54
orchestrata_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