orchestrata_ultimate.orchestrator
Reference › orchestrata_ultimate › orchestrator
Orchestrator (U:Ox) - Governance and policy management engine
The orchestrator package is the Orchestrator volk (U:Ox): it parses intents, manages facts and decides what is allowed. Concierge is where a human intent enters; from there the package turns that intent into work for the volks, guarded by Prolog governance rules and recorded in Redis and the knowledge graph. The package narrative tells the story with diagrams; this page groups the module pages.
Intent pipeline. intent_broker is the front door and intent_broker_factory wires it. Free text goes through intent_normalizer, intent_classifier, intent_vocabulary and nlp; typed strings go through intent_parser and parameter_extractor. Each intent is then checked by intent_security and intent_validator, analysed by the impact subpackage, routed and dispatched by intent_router. Shared types are in intent_types, intent_enums and intent_results; state and telemetry in intent_lifecycle, intent_history, intent_metrics; reuse in intent_template, intent_workflow and ambiguity_resolver.
Pipeline execution. pipeline_router plans stages per work type, pipeline_runner runs them through Postman, with pipeline_escalation, verification_gate and artifact_store; pipeline_kernel bridges the gateway.
Governance and facts. engine evaluates policy over Prolog through prolog_worker; policy_registry versions policies; graph_audit records decisions; fact_manager, fact_store and fact_graph manage facts; orchestrator is the staffing facade.
Entry points are IntentBroker.process_text and process_intent, PipelineRunner.run, PipelineKernelClient.send_packet and UOxEngine.evaluate_policy. Start with intent_broker, then pipeline_runner and engine.
Curated narrative
The hand-written story of this package: orchestrata_ultimate.orchestrator.
42 modules, 15,904 lines of code.
Subpackages
| Package | Modules | LOC |
|---|---|---|
impact |
7 | 1,398 |
Modules
| Module | Summary | LOC |
|---|---|---|
__init__ |
Orchestrator (U:Ox) - Governance and policy management engine | 25 |
ambiguity_resolver |
Ambiguity detection and resolution for intents. | 261 |
artifact_store |
Orchestrator-side re-export of the canonical artifact store + ArtifactType enum. | 47 |
engine |
U:Ox governance engine with Prolog-based policy evaluation. | 751 |
fact_graph |
Graph operations for the fact store. | 213 |
fact_manager |
Fact lifecycle management for Orchestrata. | 485 |
fact_store |
Real fact storage using Redis and the graph. | 267 |
graph_audit |
Graph audit trail for Orchestrata. | 674 |
intent_broker |
Intent Broker — core orchestrator for the intent pipeline. | 475 |
intent_broker_factory |
Production factory for the SPEC-003 Intent Broker pipeline. | 126 |
intent_classifier |
Extensible NL intent classifier + workflow mapper + evaluator. | 690 |
intent_enums |
Intent validation outcome enums. | 21 |
intent_history |
Intent history with dual Redis+graph storage. | 424 |
intent_lifecycle |
Intent lifecycle state machine. | 250 |
intent_metrics |
Intent Metrics and Monitoring System. | 673 |
intent_normalizer |
Haiku normalization stage — clean the sentence BEFORE Prolog sees it. | 336 |
intent_parser |
Intent parsing for Orchestrata. | 378 |
intent_results |
Intent Broker result types. | 137 |
intent_router |
Intent routing and CXP dispatch. | 372 |
intent_security |
Intent security: authentication, authorization, injection prevention, rate limiting. | 376 |
intent_template |
Intent template system for reusable intent patterns. | 319 |
intent_types |
Intent Broker type system. | 375 |
intent_validator |
Prolog-based intent validation. | 306 |
intent_vocabulary |
Extensible NL intent vocabulary — keyword → category registries. | 573 |
intent_workflow |
Intent workflow engine for multi-step intent execution. | 494 |
nlp |
NLP processing for intent parsing. | 604 |
orchestrator |
Orchestrator (U:Ox) - Governance and policy management engine | 210 |
parameter_extractor |
Advanced parameter extraction from natural language. | 286 |
pipeline_escalation |
PipelineRunner escalation INTERRUPT mixin (W3.1 absorption, final piece). | 533 |
pipeline_kernel |
Pipeline Kernel Client — bridges Gateway → PipelineRunner. | 584 |
pipeline_router |
Pipeline router — maps work types to agent stage sequences. | 367 |
pipeline_runner |
PipelineRunner — executes dynamic agent stages through Postman routing. | 1371 |
policy_registry |
Policy registry for governance and compliance. | 408 |
prolog_worker |
Janus-swi Prolog worker for thread-safe, PARALLEL governance queries. | 339 |
verification_gate |
PipelineVerificationGate — production wiring for the verification subsystem. | 756 |
Dependency diagram
Truncated: showing 36 of 36 modules/subpackages (most connected first) and 10 of 13 outside packages.