orchestrata_ultimate.cxp
Reference › orchestrata_ultimate › cxp
Cross-agent eXchange Protocol (CXP) Implementation.
The cxp package implements the Cross-agent eXchange Protocol (Spec 004), the structured way Orchestrata's volks pass work to each other. The packet model itself lives in core.packet; this package supplies everything around it. Its narrative is cxp.
Parts, by role:
- Vocabulary: constants, types, exceptions, interfaces, version and version_compat.
- Packet handling: headers, payload, priority, deterministic_ids, validator, schema, and the serializers json_serializer, binary_serializer and serializer.
- Routing and delivery: router, dispatcher, delivery_status, work_status, prolog_bridge for governance, and the legacy handler.
- Conversations and adapters: threads, thread_store, postman_adapter and session_adapter.
- Transport: transport (the factory), direct_cxp_adapter and direct_transport (the cxpt transport), servicer and reply_router (the service core), proto_codec with the proto messages, endpoint_config, and the standalone ws_client and ws_server.
Flow: a sender builds a packet, which is validated, routed by CXPRouter (with Prolog governance when a bridge is present) and delivered by CXPDispatcher, while trackers hold delivery and work state. Across processes, transport.create_cxp_client returns a DirectCXPClient that sends packets to a DirectCXPServer, which hands them to CXPServicer and the configured packet handler; replies go to per-consumer queues. The gateway server is the main client. Start reading at transport for the wire side or router for the logic.
Curated narrative
The hand-written story of this package: orchestrata_ultimate.cxp.
37 modules, 9,628 lines of code.
Subpackages
| Package | Modules | LOC |
|---|---|---|
proto |
2 | 103 |
Modules
| Module | Summary | LOC |
|---|---|---|
__init__ |
Cross-agent eXchange Protocol (CXP) Implementation. | 288 |
binary_serializer |
CXP Binary Serializer. | 244 |
constants |
CXP Protocol Constants. | 84 |
delivery_status |
CXP Delivery Status Tracking. | 243 |
deterministic_ids |
Deterministic CXP packet ID generation using UUID v5. | 60 |
direct_cxp_adapter |
The CXP transport: cxpt direct transport over the shared servicer. | 564 |
direct_transport |
Async wrapper over the cxpt free-threaded direct transport. |
441 |
dispatcher |
CXP Packet Dispatcher. | 257 |
endpoint_config |
Single source of truth for CXP gRPC endpoint configuration. | 127 |
exceptions |
CXP Protocol Exceptions. | 323 |
handler |
CXP Handler - Processes CXP packets. | 86 |
headers |
CXP Header Management. | 518 |
interfaces |
CXP Protocol Interfaces. | 325 |
json_serializer |
CXP JSON Serializer. | 325 |
payload |
CXP Payload Manager. | 533 |
postman_adapter |
CXP Postman Adapter. | 338 |
priority |
CXP Priority Handling. | 171 |
prolog_bridge |
CXP Prolog Bridge. | 683 |
proto_codec |
CXP packet <-> protobuf codec, and the CXP client configuration. | 166 |
reply_router |
Per-consumer reply routing for the CXP servicer (SPEC-001 US-002). | 349 |
router |
CXP Packet Router. | 245 |
schema |
CXP JSON Schema Definitions. | 342 |
serializer |
CXP Serializer - Serializes and deserializes CXP packets. | 80 |
servicer |
Transport-neutral CXP service core. | 551 |
session_adapter |
CXP Session Adapter. | 214 |
thread_store |
CXP Thread Store — Persistence layer for thread data. | 109 |
threads |
CXP Thread Manager — Conversation thread management. | 317 |
transport |
CXP transport construction. | 139 |
types |
CXP Protocol Type Definitions. | 184 |
validator |
CXP Validator - Validates CXP packets. | 257 |
version |
CXP Protocol Versioning — Spec 004, Section US-010. | 145 |
version_compat |
CXP Version Compatibility Checking. | 114 |
work_status |
CXP Work Status Tracking per Spec 004 Section US-005. | 242 |
ws_client |
WebSocket Client for CXP Protocol. | 225 |
ws_server |
WebSocket Server for CXP Protocol. | 236 |