-
Notifications
You must be signed in to change notification settings - Fork 1
Module distributed knowledge Roadmap
Production distributed_knowledge runtime exists across capability exchange, federated coordination, cross-shard retrieval merge, feedback synchronization, and federated distillation integration surfaces.
Q3 2026 Status Update (2026-07-28):
- Core module implementation complete with 5 key federation surfaces
- Focused test infrastructure established: 58 unit tests covering all surfaces, aligned with actual production APIs
- Test targets follow module test pattern:
module_distributed_knowledge_test_<base>_focused(filenametest_<base>_focused.cpp→ stem stripped of_focused→ target appends_focused) - All test files compile against real header APIs (AdapterCapabilityAnnouncement, LoRAFederationCoordinator, FederatedRAGMerger, CrossShardFeedbackSync, FederatedDistillationCoordinator)
- Evidence gathering in progress for hardening priorities
- [~] hardening of timeout, partial-failure, and policy-edge semantics across federation paths (Target: Q3 2026)
- Test coverage added: ACA-01..ACA-10, LFC-01..LFC-12, FRM-01..FRM-12, CSS-01..CSS-12, FDC-01..FDC-12
- Implementation surfaces: adapter_capability_announcement, lora_federation_coordinator, federated_rag_merger, cross_shard_feedback_sync, federated_distillation_coordinator
- [~] benchmark stabilization for aggregation, merge, and feedback sync hot paths (Target: Q3 2026)
- Focused test infrastructure in place for regression tracking
- [~] diagnostics consistency improvements for federation incidents and degraded shard responses (Target: Q3 2026)
- Test coverage includes failure scenarios, partial failures, timeouts
- tighten deterministic merge behavior under multi-shard timeout permutations (Target: Q4 2026)
- expand regression coverage for replay/dedup and policy-gated sync scenarios (Target: Q4 2026)
- refine operator-facing visibility for federation rounds and rollback events (Target: Q4 2026)
- re-baseline p95/p99 envelopes for aggregation and merge under sustained load (Target: Q1 2027)
- extend benchmark depth for distillation and risk-gated federation workflows (Target: Q1 2027)
- harden long-running stability across mixed shard capability/topology states (Target: Q1 2027)
Note: Implementation phases (Phase 1-6) are orthogonal to test scenario layers (Layer A-D):
- Phases 1-6 describe module development phases: design, implementation, error handling, testing, performance, documentation.
- Layers A-D (in test files) describe federation workflow scenarios: domain routing (A), LoRA (B), RAG (C), RLAIF feedback (D).
- freeze capability/federation/merge/sync contracts for active major line (Delivered: Q3 2026)
- define explicit distributed failure taxonomy for timeout/policy/privacy classes (Delivered: Q3 2026)
- Contract header:
include/distributed_knowledge/distributed_knowledge_api_contract.h - Error codes: ENTITY_NOT_FOUND, FEDERATION_TIMEOUT, CONFLICT_UNRESOLVABLE, GRAPH_CORRUPTED, RETRIEVAL_LIMIT_EXCEEDED, TOMBSTONE_PROPAGATION_FAILED, CRDT_MERGE_TYPE_MISMATCH, INTERNAL_ERROR
- LWW resolveLww() helper with tie-break semantics
- Contract header:
- complete explicit documentation of merge conflict resolution strategies (Delivered: Q3 2026)
- Merge strategies documented: RRF, score-weighted, round-robin
- Conflict resolution semantics: duplicate doc_id handling, tie-breaking
- Timeout/failure handling: DK-OR-T contract (all shards timeout, partial failure)
- Deduplication contract: preserving order, handling duplicates
- Configuration validation: required fields and constraints
- API contract: § 8 "Merge Strategy and Conflict Resolution Contract"
- Reference:
include/distributed_knowledge/federated_rag_merger.hclass/method docs - Reference:
src/distributed_knowledge/federated_rag_merger.cppimplementation comments - Reference:
include/distributed_knowledge/distributed_knowledge_api_contract.h§ 8
- Batch 3: Consistency and Version Tracking Documentation (Delivered: Q3 2026)
- Consistency levels documented (strong, causal, eventual) for all operations
- Version ordering documented for round-based aggregation (gradients, distillation)
- Replication lag assumptions documented (federation, RAG, feedback)
- Stale-read intentionality documented with correctness justification
- API contract § 9 added: "Consistency and Version Semantics"
- Reference:
include/distributed_knowledge/distributed_knowledge_api_contract.h§ 9 - Reference: Updated method docs in lora_federation_coordinator.h/cpp
- Reference: Updated method docs in federated_distillation_coordinator.h/cpp
- Reference: Updated method docs in federated_rag_merger.h/cpp
- Reference: Updated method docs in cross_shard_feedback_sync.h/cpp
- complete hardening for aggregation, merge, and sync coordinator internals (Target: Q4 2026) —
MergeHardeningPolicy+DistillationBoundedPolicyadded to API contract; trust-gate ACA-TRUST-01..05 tests added 2026-08-24 - align distillation and feedback behavior to bounded runtime contracts (Target: Q4 2026) —
DistillationBoundedPolicywith FAIL_CLOSED enforcement wired intoFederatedDistillationCoordinatorviasetBoundedPolicy()2026-08-24; enforced inbroadcastToStudents()before any broadcast
- standardize fail-closed behavior for unsafe federation and trust-gate violations (Target: Q4 2026) —
IFederationTrustPolicy+AlwaysPermitTrustPolicy+DKErrorCode::TRUST_GATE_REJECTEDadded 2026-08-24 - unify diagnostics for timeout, dedup, and partial-shard merge failures (Target: Q4 2026) —
DistributedKnowledgeDiagnosticEmitter+DKDiagnosticEventmodel added;test_dk_diagnostics_focused.cpp(DKD-01..14) added 2026-08-24
- expand focused regressions for capability/routing and federation edge scenarios (Delivered: Q3 2026)
- extend deterministic fixture coverage for shard-response permutation matrixes (Delivered: Q3 2026)
- Test file:
tests/distributed_knowledge/test_dk_contract_hardening_focused.cpp - Test cases: DKC-01..DKC-16 (entity lifecycle, federation, retrieval, conflict resolution)
- kDKContractSeed = 42; all tests self-contained, no external I/O
- Test file:
- lock benchmark-backed release gates for federation and merge hot paths (Delivered: Q3 2026)
- validate p95/p99 and throughput behavior against release baselines (Delivered: Q3 2026)
- Benchmark file:
benchmarks/distributed_knowledge/bench_dk_release_gates.cpp - Gates: DKRG-01..DKRG-06 (insert ≥100k/s, neighbours ≤500µs, path ≤5ms, LWW ≤100µs, federation-union ≤5ms, serialization ≤100µs)
- kDKCanonicalSeed = 42; Repetitions(5)
- Benchmark file:
- core distributed_knowledge module docs aligned to source-verifiable behavior
- roadmap/future planning separated from historical changelog entries
- focused test infrastructure created (58 unit tests, 5 surface areas, Q3 2026)
- Phase 1-6 Wave 3B Category-D closure delivered (Q3 2026)
- Contract header, 16 focused tests (DKC-01..16), 6 release-gate benchmarks (DKRG-01..06)
- core distributed_knowledge surfaces documented and source-verified
- module-level security and failure behavior documented
- benchmark mapping documented in performance expectations
- focused test suite created for all module surfaces (ACA, LFC, FRM, CSS, FDC test families)
- remaining hardening tasks closed for timeout/policy/dedup edge paths
- release benchmark stabilization complete
Focused Test Infrastructure: Created 2026-07-28
Test files location: tests/distributed_knowledge/test_*_focused.cpp
Test coverage by module surface:
| Surface | Test File | Tests | Coverage |
|---|---|---|---|
| Adapter Capability Announcement | test_adapter_capability_announcement_focused.cpp | ACA-01..ACA-10 (10) | Gossip publish, domain types, multicast behavior |
| LoRA Federation Coordinator | test_lora_federation_coordinator_focused.cpp | LFC-01..LFC-12 (12) | Aggregation requests, state machine, timeout handling |
| Federated RAG Merger | test_federated_rag_merger_focused.cpp | FRM-01..FRM-12 (12) | Merge requests, dedup, partial failure, top-K truncation |
| Cross-Shard Feedback Sync | test_cross_shard_feedback_sync_focused.cpp | CSS-01..CSS-12 (12) | Feedback events, batching, dedup, replay detection, privacy filtering |
| Federated Distillation Coordinator | test_federated_distillation_coordinator_focused.cpp | FDC-01..FDC-12 (12) | Distillation requests, DP parameters, policy gates, privacy budgets |
Total Test Suite: 58 focused unit tests
Test registration pattern: module_distributed_knowledge_<stem>_focused
CTest tier: unit
Timeout: 120s
Labels: distributed_knowledge
Target status: Ready for build integration (test files complete, CMakeLists.txt configured per module pattern)
- behavior remains sensitive to shard availability, timeout configuration, and policy gates.
- selected partial-failure and replay-edge flows require continued hardening.
- benchmark coverage should continue expanding beyond current federation core paths.
No breaking distributed_knowledge contract planned. Any contract-breaking change requires migration notes and changelog entry before merge.
This module is a contributing module in the program-level Wave A → B → C → D execution model.
It does not own a primary wave deliverable but must remain release_critical-green throughout all waves
and must deliver Wave D operability improvements in Q1 2027.
See [[../../ROADMAP.md|ROADMAP]] for the full wave model and exit criteria.
- Deliver or validate distributed tracing, high-cardinality stress coverage, exporter reliability, and operator remediation hints as applicable to this module (Target: Q1 2027)
- Contribute to or validate long-duration soak test coverage for this module's primary paths (Target: Q1 2027)
- Ensure runbook coverage for operator-critical scenarios in this module (Target: Q1 2027)
-
release_criticalCI must remain green ondevelopthroughout all waves (Target: ongoing) - p95/p99 benchmarks must be refreshed on representative hardware before Wave D sign-off (Target: Q1 2027)
- No behavioral regression may be introduced into modules in Wave A/B/C scope from changes in this module.
- This module's distributed/acceleration paths fail closed (Target: Q1 2027)
- Benchmark-backed p95/p99 baselines exist on representative hardware (Target: Q1 2027)
- Operator-critical paths have diagnostics, alerts, and runbooks (Target: Q1 2027)
- Architecture-ACCESS-MODEL-IMPLEMENTATION-SUMMARY
- Architecture-ADR-003-pg-dump-sql-parser
- Architecture-BASEENTITY-PRINCIPLE
- Architecture-CACHE-STORAGE-INTEGRATION
- Architecture-CMAKE-ARCHITECTURE
- Architecture-CMAKE-FLAGS-REFERENCE
- Architecture-CMAKE-MODULAR-ARCHITECTURE
- Architecture-CONCERNS-ARCHITECTURE-DIAGRAM
- Architecture-CONCERNS-IMPLEMENTATION-SUMMARY
- Architecture-CONTENT-MODEL
- Architecture-COPILOT-THEMISDB-GRAPH-RAG-BACKEND-ARCHITECTURE
- Architecture-CRYPTO-AND-KEYS
- Architecture-FEATURE-FLAGS-REFERENCE
- Architecture-GPU-ARCHITECTURE-REVIEW-TEMPLATE
- Architecture-HTTP-SHUTDOWN-HARDENING
- Architecture-MIGRATION-GUIDE-CONCERNS
- Architecture-MIGRATION-GUIDE-v13-v14
- Architecture-MODULARIZATION-GUIDE
- Architecture-MODULAR-ARCHITECTURE-ROADMAP
- Architecture-MODULE-ARCHITECTURE-INDEX
- Architecture-P1D01-ISSMPLUGIN-DESIGN-REVIEW
- Architecture-P1-D01-ISSMPLUGIN-DESIGN-REVIEW
- Architecture-P1-D08-MAMBA-GOVERNANCE-CONTRACT
- Architecture-P1-P2-IMPLEMENTATION-COMPLETION-INDEX
- Architecture-PHASE0-COMPLETION-ASSESSMENT
- Architecture-PHASE3-QUERYENGINE-DI-ARCHITECTURE
- Architecture-PHASE4-INDEX-MANAGER-DI
- Architecture-POSTGRESQL-WIRE-PROTOCOL
- Architecture-QUERYENGINE-IMPLEMENTATION-GUIDE
- Architecture-QUERY-SCHEDULING
- Architecture-RAFT-CONSENSUS-DESIGN
- Architecture-README
- Architecture-README-SSM-HYBRID-IMPLEMENTATION
- Architecture-REFACTORING-SUMMARY
- Architecture-RESOURCE-POOLING
- Architecture-SOURCE-DIRECTORY-GUIDE
- Architecture-THEMIS-CORE-GUIDE
- Architecture-UNIFIED-ACCESS-MODEL
- Architecture-WAL-GRPC-MTLS-CONFIGURATION
- Architecture-WIRE-PROTOCOL-RETRY
- Architecture-boltzmann-observability-draft
- Architecture-experimental-logarithmic-vector-storage
- Architecture-llm-wiki-mvp-adr
- Architecture-rewrite-engine-architecture
- Architecture-rope-api-architecture
- Architecture-ssm-gguf-mamba-status
- Architecture-ssm-hybrid-analysis
- Architecture-ssm-hybrid-rollout-plan
- Architecture-ssm-plugin-interface-design-review
- Architecture-transaction-coordinators
- Architecture-wiki-secondary-index
- Architecture-wire-protocol
- Governance-DISABLED-STUB-POLICY
- Governance-DOCS-PR-POLICY
- Governance-GA-PROMOTION-SIGN-OFF
- Governance-GITHUB-MILESTONES-SETUP
- Governance-MATURITY-CLAIM-VERIFICATION-CHECKLIST
- Governance-MATURITY-EVIDENCE-REGISTRY
- Governance-MERGE-GATE-BOT-CONFIG
- Governance-MERGE-GATE-STATUS-LIVE
- Governance-PHASE3-ENFORCEMENT-RUNBOOK
- Governance-PHASE-1-CLOSURE-REPORT
- Governance-PHASE-CLOSURE-POLICY
- Governance-PHASE-DEPENDENCY-GRAPH
- Governance-PLUGIN-SUBMODULE-ROLLBACK
- Governance-PRODUCTION-READY-2026-DELIVERY-PLAN
- Governance-PR-VERSION-TARGETING
- Governance-PR-VERSION-TARGETING-BACKFILL
- Governance-QUERY-MODULE-STATUS
- Governance-README
- Governance-RELEASE-PROMOTION-GATE-POLICY
- Governance-RELEASE-VALIDATION-CHECKLIST
- Governance-SECURITY-MODULE-5671-EVIDENCE-SUMMARY
- Governance-SHARDING-P6-RESIDUAL-RISK-ACCEPTANCE
- Governance-SOURCECODE-COMPLIANCE-GOVERNANCE
- Governance-UPDATES-DEVELOPMENT-STATUS-SIGN-OFF
- Governance-WAVE-C-IMPLEMENTATION-COMPLETE
- Module-acceleration-Roadmap
- Module-access-model-Roadmap
- Module-ai-Roadmap
- Module-analytics-Roadmap
- Module-api-Roadmap
- Module-aql-Roadmap
- Module-auth-Roadmap
- Module-base-Roadmap
- Module-cache-Roadmap
- Module-cdc-Roadmap
- Module-chaos-Roadmap
- Module-chimera-Roadmap
- Module-config-Roadmap
- Module-content-Roadmap
- Module-core-Roadmap
- Module-distributed-knowledge-Roadmap
- Module-distributed-tensor-Roadmap
- Module-document-Roadmap
- Module-ethics-ai-Roadmap
- Module-evaluation-Roadmap
- Module-execution-Roadmap
- Module-exporters-Roadmap
- Module-failover-Roadmap
- Module-geo-Roadmap
- Module-governance-Roadmap
- Module-gpu-Roadmap
- Module-graph-Roadmap
- Module-image-analysis-Roadmap
- Module-importers-Roadmap
- Module-index-Roadmap
- Module-ingestion-Roadmap
- Module-llama-cpp-Roadmap
- Module-llm-Roadmap
- Module-llm-streaming-Roadmap
- Module-llm-wiki-Roadmap
- Module-maintenance-Roadmap
- Module-metadata-Roadmap
- Module-network-Roadmap
- Module-observability-Roadmap
- Module-onnx-clip-Roadmap
- Module-performance-Roadmap
- Module-plugins-Roadmap
- Module-process-Roadmap
- Module-projects-Roadmap
- Module-prompt-engineering-Roadmap
- Module-query-Roadmap
- Module-rag-Roadmap
- Module-replication-Roadmap
- Module-retrieval-Roadmap
- Module-rpc-grpc-Roadmap
- Module-scheduler-Roadmap
- Module-scraper-Roadmap
- Module-search-Roadmap
- Module-security-Roadmap
- Module-server-Roadmap
- Module-sharding-Roadmap
- Module-stable-diffusion-Roadmap
- Module-storage-Roadmap
- Module-temporal-Roadmap
- Module-tensor-Roadmap
- Module-themis-Roadmap
- Module-timeseries-Roadmap
- Module-toolbox-Roadmap
- Module-training-Roadmap
- Module-transaction-Roadmap
- Module-updates-Roadmap
- Module-user-storage-encrypted-Roadmap
- Module-utils-Roadmap
- Module-vector-search-Roadmap
- Module-voice-Roadmap
- Module-whisper-Roadmap