Skip to content

Compendium appendix d feature status

github-actions[bot] edited this page Sep 28, 2026 · 2 revisions

Navigation: Home > Pages

Appendix D: Feature Status Matrix

Version: 1.8.0
Stand: April 2026
Kategorie: Feature-Übersicht und Implementierungsstatus


Zweck dieses Appendix

Dieser Appendix bietet eine vollstÀndige, strukturierte Übersicht aller ThemisDB-Features mit aktuellem Implementierungsstatus, Dokumentationsverweisen und Roadmap-Planung. Dies dient als zentraler Referenzpunkt für:

  • Entwickler: Welche Features sind verfΓΌgbar? Wo ist der Code?
  • Architekten: Welche Capabilities hat ThemisDB? Was fehlt noch?
  • Projektmanager: Was ist Production-Ready? Was ist geplant?
  • Nutzer: Welche Funktionen kann ich nutzen?

Status-Definitionen

Symbol Status Bedeutung
βœ… Production-Ready VollstΓ€ndig implementiert, getestet (>85% Coverage), dokumentiert, performance-validated
🟒 MVP Complete KernfunktionalitÀt vorhanden, stabil, aber ggf. noch Optimierungen ausstehend
🟑 In Development Aktiv in Entwicklung, teilweise funktional, noch nicht production-grade
🟠 Design Phase Spezifikation vorhanden, Implementierung geplant
πŸ”΅ Planned Auf Roadmap, noch keine Spezifikation
βšͺ Backlog Idee/Anforderung dokumentiert, keine aktive Planung
πŸ”΄ Alpha FrΓΌhes Stadium, API kann sich Γ€ndern
❌ Not Planned Bewusst nicht im Scope

Zusammenfassung (v1.8.0, April 2026)

Bereich Status
Core Database Engine βœ… Production-Ready
Multi-Model (Relational/Graph/Vector/Document/TS) βœ… Production-Ready
ACID Transactions / MVCC / SAGA βœ… Production-Ready
Security & Compliance (GDPR/HIPAA/CCPA/PCI/SOC2) βœ… Production-Ready
Horizontal Scaling / Sharding βœ… Production-Ready
High Availability / Replication βœ… Production-Ready
LLM/RAG Integration (llama.cpp) βœ… Production-Ready
Full-Text + Vector Hybrid Search βœ… Production-Ready
Analytics (OLAP/CEP/Process Mining) βœ… Production-Ready
Observability (Prometheus/OTel/Grafana) βœ… Production-Ready
Voice Assistant 🟒 MVP Complete
Chimera Multi-DB Adapter πŸ”΄ Alpha
GPU Compute (CUDA/Vulkan/OpenCL) 🟒 MVP Complete
PostgreSQL Wire Protocol 🟒 MVP Complete

Overall Production-Ready: 40/46 modules (87%)


v1.8.0 Feature-Highlights

Authentication & Authorization (Β§21)

Feature Status Class Documentation
JWT Validator (scope enforcement) βœ… JWTValidator Β§21.1
OAuth2 PKCE βœ… OAuth2PKCEHandler Β§21.2
SAML 2.0 βœ… SAMLAuthenticator Β§21.3
WebAuthn / FIDO2 βœ… WebAuthnAuthenticator Β§21.4
LDAP / Active Directory βœ… LDAPAuthenticator Β§21.5
MFA (TOTP/SMS/Email) βœ… MFAManager Β§21.6
Session Management βœ… SessionManager Β§21.7
Password Policy Engine βœ… PasswordPolicyEngine Β§21.8
Federated OIDC βœ… FederatedOIDCProvider Β§21.9
GSSAPI / Kerberos βœ… GSSAPIAuthenticator Β§21.10

Module: src/auth/, include/auth/
Compendium: chapter_21_auth.md


Bi-Temporal & Time-Series (Β§9)

Feature Status Class Documentation
BiTemporalTable (valid + transaction time) βœ… BiTemporalTable Β§9.1
BiTemporal Join βœ… BiTemporalJoin Β§9.2
TemporalQueryEngine βœ… TemporalQueryEngine Β§9.3
SnapshotManager (PITR) βœ… SnapshotManager Β§9.4
Time-Travel Queries (AS OF TIMESTAMP) βœ… TimeTravelQuery Β§9.5
System-Versioned Tables βœ… SystemVersionedTable Β§9.6
Temporal Index Acceleration βœ… β€” Β§9.7

Module: src/temporal/, src/timeseries/, include/temporal/, include/timeseries/
Compendium: chapter_09_timeseries.md


Storage & Backup (Β§20)

Feature Status Class Documentation
RocksDB Storage Backend βœ… RocksDBStorage Β§20.1
MVCC / WAL βœ… MVCCEngine, WALWriter Β§20.2
BackupManager (PITR) βœ… BackupManager Β§20.3
RAID-equivalent Redundancy βœ… RaidManager Β§20.4
Tiered Storage (SSDβ†’HDDβ†’Cold) βœ… TieredStorageManager Β§20.5
NVMe-aware I/O βœ… NVMeDriver Β§20.6
Erasure Coding (Reed-Solomon) βœ… ErasureCoder Β§20.7
Object Storage Backend (S3/GCS/Azure) βœ… ObjectStorageBackend Β§20.8
2PC Distributed Storage Commit βœ… DistributedStorageCommit Β§20.9

Module: src/storage/, include/storage/
Compendium: chapter_08_storage_layer.md, chapter_20_backup.md


LLM Integration & Inference (Β§17)

Feature Status Class Documentation
llama.cpp Wrapper βœ… LlamaWrapper Β§17.1
GGUF Model Loader βœ… GGUFLoader Β§17.2
LoRA Adapter Support βœ… LoRAAdapter Β§17.3
QLoRA (Quantized LoRA) βœ… QLoRATrainer Β§17.4
Multi-GPU Training βœ… MultiGPUTrainer Β§17.5
Paged KV-Cache βœ… PagedKVCache Β§17.6
Continuous Batching βœ… ContinuousBatcher Β§17.7
Speculative Decoding βœ… SpeculativeDecoder Β§17.8
OpenAI-Compatible API βœ… OpenAICompatLayer Β§17.9
LoRA Router βœ… LoRARouter Β§17.10
Adapter Registry βœ… AdapterRegistry Β§17.11
Model Router βœ… ModelRouter Β§17.12
Prefix Caching βœ… PrefixCache Β§17.13
Grammar-Constrained Generation βœ… GrammarConstrainedSampler Β§17.14
RoPE Scaling βœ… RoPEScaling Β§17.15
Vision / Multi-Modal βœ… VisionEncoder Β§17.16
GPU Backend Auto-Detection βœ… AiHardwareDispatcher Β§17.17
LLM Benchmarking Framework βœ… LLMBenchmark Β§17.18
Feedback API βœ… FeedbackCollector Β§17.19
LLM-as-Judge βœ… LLMJudge Β§17.20

Module: src/llm/, src/llama_cpp/, include/llm/
Compendium: chapter_17_llm_integration.md


RAG β€” Retrieval-Augmented Generation (Β§17 continued)

Feature Status Class Documentation
Basic RAG Pipeline βœ… RAGPipeline Β§17.21
Agentic RAG (multi-step) βœ… AgenticRAG Β§17.22
Multi-Modal RAG βœ… MultiModalRAG Β§17.23
RAG Context Assembler βœ… RAGContextAssembler Β§17.24
Distributed RAG Evaluator βœ… DistributedRAGEvaluator Β§17.25
Hybrid Retrieval (BM25+Vector) βœ… HybridRetriever Β§17.26
Knowledge Graph RAG βœ… KGRAGPipeline Β§17.27
FLARE Retrieval-Callback Bridge βœ… KnowledgeGapDetector::setRetrievalCallback Β§17.30
Vector Search in RAG (HTTP) βœ… LLMApiHandler::setVectorIndex Β§17.30

Module: src/rag/, include/rag/, src/server/, include/server/
Compendium: chapter_17_llm_integration.md
Referenz: flare_retrieval_callback_bridge.md


Prompt Engineering (Β§17 continued)

Feature Status Class Documentation
PromptManager (RocksDB, lock-free) βœ… PromptManager Β§17.28
FeedbackCollector (10 types) βœ… FeedbackCollector Β§17.29
SelfImprovementOrchestrator βœ… SelfImprovementOrchestrator Β§17.30
TreeOfThoughtsBuilder βœ… TreeOfThoughtsBuilder Β§17.31
ProTeGi Optimizer βœ… ProTeGiOptimizer Β§17.32
DSPy Module βœ… DSPyModule Β§17.33
ContextWindowManager βœ… ContextWindowManager Β§17.34

Module: src/prompt_engineering/, include/prompt_engineering/
Compendium: chapter_17_llm_integration.md


Training & ML Pipeline (Β§16 ML)

Feature Status Class Documentation
TrainingPipeline βœ… TrainingPipeline Β§16-ML.1
IncrementalLoRATrainer βœ… IncrementalLoRATrainer Β§16-ML.2
AutoLabeler βœ… AutoLabeler Β§16-ML.3
LoRACheckpointManager βœ… LoRACheckpointManager Β§16-ML.4
ProvenanceTracker βœ… ProvenanceTracker Β§16-ML.5
Model Serving (ONNX) βœ… ModelServingEngine Β§16-ML.6

Module: src/training/, include/training/
Compendium: chapter_16_ml.md


Change Data Capture (Β§11)

Feature Status Class Documentation
Changefeed (row-level CDC) βœ… Changefeed Β§11.1
CDC Materialized Views βœ… CdcMaterializedView Β§11.2
CDC Admin API βœ… CdcAdmin Β§11.3
Consumer Group βœ… ConsumerGroup Β§11.4
Kafka Integration βœ… KafkaChangefeed Β§11.5
Avro / Protobuf Encoding βœ… AvroEncoder, ProtoEncoder Β§11.6

Module: src/cdc/, include/cdc/
Compendium: chapter_11_realtime.md


Update Propagation & Cluster Operations (Β§25)

Feature Status Class Documentation
ClusterUpdateManager βœ… ClusterUpdateManager Β§25.1
CanaryRollout βœ… CanaryRollout Β§25.2
HotReloadEngine βœ… HotReloadEngine Β§25.3
InPlaceSchemaMigrator βœ… InPlaceSchemaMigrator Β§25.4
BlueGreenDeployment βœ… BlueGreenDeployment Β§25.5
SIGHUP Config Hot-Reload βœ… ConfigHotReload Β§25.6

Module: src/updates/, src/config/, include/updates/, include/config/
Compendium: chapter_25_devops_infrastructure.md


Horizontal Scaling & Sharding (Β§16)

Feature Status Class Documentation
AdaptiveShardRouter βœ… AdaptiveShardRouter Β§16.1
Consistent Hash Sharding βœ… ConsistentHashSharding Β§16.2
Range Sharding βœ… RangeSharding Β§16.3
Cross-Shard Transactions βœ… CrossShardTransaction Β§16.4
Epoch Fencing βœ… EpochFencing Β§16.5
Data Migration / Rebalancing βœ… DataMigrator Β§16.6
GPU Erasure Coder (OpenCL) βœ… GpuErasureCoderOpenCL Β§16.7

Module: src/sharding/, include/sharding/
Compendium: chapter_16_sharding.md


Query Optimization (Β§34)

Feature Status Class Documentation
Adaptive Query Optimizer βœ… AdaptiveOptimizer Β§34.1
Adaptive Join (Hash/NL/Merge/Grace) βœ… AdaptiveJoin Β§34.2
Approximate Aggregator (HLL+TDigest) βœ… ApproximateAggregator Β§34.3
Materialized Views (Incremental) βœ… IncrementalMaterializedView Β§34.4
Parallel Query Execution βœ… ParallelExecutor Β§34.5
Partition Pruning βœ… PartitionPruner Β§34.6
Cost Model (System R) βœ… CostModel Β§34.7
Query Plan Cache βœ… QueryPlanCache Β§34.8
Early Filtering βœ… EarlyFilter Β§34.9

Module: src/query/, include/query/
Compendium: chapter_34_query_optimization.md


Index Management (Β§34 continued)

Feature Status Class Documentation
IndexManager βœ… IndexManager Β§34.10
Inverted Index (BM25) βœ… InvertedIndex Β§34.11
HNSW Vector Index βœ… HNSWIndex Β§34.12
Distributed Vector Index βœ… DistributedVectorIndex Β§34.13
Index Suggestion Engine βœ… IndexSuggestionEngine Β§34.14
B-Tree / B+Tree Index βœ… BTreeIndex Β§34.15
Spatial Index (R-Tree) βœ… RTreeIndex Β§34.16

Module: src/index/, include/index/
Compendium: chapter_34_query_optimization.md


Full-Text & Hybrid Search (Β§13)

Feature Status Class Documentation
HybridSearch (BM25+Vector, RRF k=60) βœ… HybridSearch Β§13.1
DistributedHybridSearch (mTLS) βœ… DistributedHybridSearch Β§13.2
SearchHighlighter βœ… SearchHighlighter Β§13.3
SearchResultStream (cursor) βœ… SearchResultStream Β§13.4
ConversationalSearch βœ… ConversationalSearch Β§13.5
FederatedSearch βœ… FederatedSearch Β§13.6
FacetedSearch βœ… FacetedSearch Β§13.7
LearningToRank βœ… LearningToRank Β§13.8
AutocompleteEngine βœ… AutocompleteEngine Β§13.9
MultiModalSearch βœ… MultiModalSearch Β§13.10

Module: src/search/, include/search/
Compendium: chapter_13_fulltext.md


Analytics (Β§15 / Β§29)

Feature Status Class Documentation
OLAP Engine (CUBE/ROLLUP/GROUPING SETS) βœ… OLAPEngine Β§15.1
GPU OLAP Path βœ… GPUOLAPEngine Β§15.2
Window Functions βœ… WindowFunctionExecutor Β§15.3
CEP Engine (NFA, EPL) βœ… CEPEngine Β§15.4
Anomaly Detection (Isolation Forest) βœ… AnomalyDetector Β§15.5
Model Serving (ONNX) βœ… ModelServingEngine Β§15.6
Incremental Materialized Views βœ… IncrementalMatView Β§15.7
Process Mining (BPMN/EPK) βœ… ProcessAnalyzer Β§29.1
ExporterFactory (Arrow/Parquet) βœ… ExporterFactory Β§15.8
JoinExporter (PII-redacting) βœ… JoinExporter Β§15.9

Module: src/analytics/, include/analytics/
Compendium: chapter_15_analytics.md, chapter_29_analytics_process_mining.md


Security & Encryption (Β§36)

Feature Status Class Documentation
Row-Level Security (PERMISSIVE + RESTRICTIVE) βœ… RLSManager Β§36.1
Zero Trust Policy Enforcer βœ… ZeroTrustPolicyEnforcer Β§36.2
Field Encryption (AES-256-GCM) βœ… FieldEncryption Β§36.3
DEK/KEK/MasterKey Hierarchy βœ… KeyManager Β§36.4
HSM / Vault Integration βœ… VaultClient Β§36.5
AQL Injection Detection βœ… AQLInjectionDetector Β§36.6
Malware Scanner βœ… MalwareScanner Β§36.7
eIDAS Timestamping βœ… EiDASTimestamp Β§36.8
OCSP / CRL Revocation Check βœ… PluginSecurityVerifier Β§36.9
ArrowUserRegistrationPlugin βœ… ArrowUserRegistrationPlugin Β§36.10

Module: src/security/, include/security/
Compendium: chapter_36_security_hardening.md


Data Governance & Compliance (Β§40)

Feature Status Class Documentation
PolicyEngine (OPA-fallback) βœ… PolicyEngine Β§40.1
DataMasker (REDACT/HASH/TRUNCATE/TOKENIZE/ENCRYPT) βœ… DataMasker Β§40.2
DataLineageTracker (append-only) βœ… DataLineageTracker Β§40.3
CrossTenantPolicyInheritance βœ… CrossTenantPolicy Β§40.4
ComplianceReporter (GDPR/HIPAA/CCPA/PCI/SOC2/ISO27001) βœ… ComplianceReporter Β§40.5
PolicyManager hot-reload βœ… PolicyManager Β§40.6

Module: src/governance/, include/governance/
Compendium: chapter_40_data_governance_compliance.md


Transactions & Concurrency (MVCC / HLC)

Feature Status Class Documentation
BranchManager (Git-style branches) βœ… BranchManager mvccΒ§1
SnapshotManager (named tags, PITR) βœ… SnapshotManager mvccΒ§2
SAGA Distributed Orchestration βœ… SAGAOrchestrator mvccΒ§3
DeadlockPredictor (probability) βœ… DeadlockPredictor mvccΒ§4
DistributedTransactionManager (2PC) βœ… DistributedTransactionManager mvccΒ§5
GlobalTransactionManager (TrueTime) βœ… GlobalTransactionManager mvccΒ§6
Serializable Snapshot Isolation βœ… IsolationLevel::SerializableSnapshot mvccΒ§7
Savepoints βœ… Savepoint mvccΒ§8
Optimistic Concurrency Control βœ… OCCValidator mvccΒ§9
Bulk Transaction API βœ… BulkTransactionAPI mvccΒ§10

Module: src/transaction/, include/transaction/
Compendium: chapter_mvcc_hlc.md


High Availability & Replication (Β§18)

Feature Status Class Documentation
WALArchivalManager (Zstd+AES-256-GCM) βœ… WALArchivalManager Β§18.1
IArchivalBackend (S3/GCS/Azure) βœ… IArchivalBackend Β§18.2
Storage-Tier Lifecycle βœ… TierLifecycleManager Β§18.3
LogicalReplicationManager βœ… LogicalReplicationManager Β§18.4
FaultInjector (ChaosFramework) βœ… FaultInjector Β§18.5
ChaosScheduler βœ… ChaosScheduler Β§18.6
DisasterRecoveryManager (7-step) βœ… DisasterRecoveryManager Β§18.7
Auto Failover Manager βœ… AutoFailoverManager Β§18.8

Module: src/replication/, src/chaos/, src/failover/, include/replication/, include/chaos/, include/failover/
Compendium: chapter_18_ha.md


Observability & SRE (Β§38)

Feature Status Class Documentation
MetricsCollector (40+ Prometheus metrics) βœ… MetricsCollector Β§38.1
QueryProfiler (per-phase timing) βœ… QueryProfiler Β§38.2
StorageProfiler (write/read amplification) βœ… StorageProfiler Β§38.3
PerformanceAnalyzer (INFO/WARNING/CRITICAL) βœ… PerformanceAnalyzer Β§38.4
AlertingEngine (PagerDuty/Slack) βœ… AlertingEngine Β§38.5
Distributed Tracing (OpenTelemetry) βœ… β€” Β§38.6
Kubernetes Health Probes βœ… β€” Β§38.7
Grafana Dashboards (3 dashboards) βœ… β€” Β§38.8

Module: src/observability/, include/observability/
Compendium: chapter_38_observability_sre.md


Importers (Β§26)

Feature Status Class Documentation
PostgresImporter (FK-preservation) βœ… PostgresImporter Β§26.1
MongoImporter βœ… MongoImporter Β§26.2
MySQLImporter / MariaDB βœ… MySQLImporter Β§26.3
OracleImporter βœ… OracleImporter Β§26.4
SqliteImporter βœ… SqliteImporter Β§26.5
FlatFileImporter (CSV/TSV/Parquet) βœ… FlatFileImporter Β§26.6
KafkaImporter βœ… KafkaImporter Β§26.7
S3Importer βœ… S3Importer Β§26.8
SchemaInferenceEngine βœ… SchemaInferenceEngine Β§26.9
AuditedImporter βœ… AuditedImporter Β§26.10
IImporterPlugin API βœ… IImporterPlugin Β§26.11

Module: src/importers/, include/importers/
Compendium: chapter_26_migration_legacy.md


Ingestion (Β§11 continued)

Feature Status Class Documentation
IngestionBuilder (fluent API) βœ… IngestionBuilder Β§11.7
HuggingFace Source βœ… β€” Β§11.8
Filesystem / API / Kafka / S3 Sources βœ… β€” Β§11.9
CDC Source Connector βœ… β€” Β§11.10
Schema Validation + Quarantine βœ… β€” Β§11.11
Rate Limiting + Dry-Run βœ… β€” Β§11.12
Incremental Checkpoint βœ… β€” Β§11.13
Plugin API βœ… IIngestionPlugin Β§11.14

Module: src/ingestion/, include/ingestion/
Compendium: chapter_11_realtime.md


Exporters (Β§16 ML continued)

Feature Status Class Documentation
JsonlExporter (Alpaca/ShareGPT/ChatML) βœ… JsonlExporter Β§16.1
ParquetExporter βœ… ParquetExporter Β§16.2
ArrowIpcExporter (zero-copy) βœ… ArrowIpcExporter Β§16.3
HuggingFaceExporter (Hub upload) βœ… HuggingFaceExporter Β§16.4
StreamingExporter (cursor+progress) βœ… StreamingExporter Β§16.5
IncrementalExporter (delta+watermark) βœ… IncrementalExporter Β§16.6
AES-256-GCM Encryption + PII Redaction βœ… β€” Β§16.7

Module: src/exporters/, include/exporters/
Compendium: chapter_16_ml.md


Caching (Β§8 Storage)

Feature Status Class Documentation
AdaptiveQueryCache (L1/L2/L3) βœ… AdaptiveQueryCache Β§8.1
BoundedLRU + zstd/lz4 βœ… β€” Β§8.2
SemanticCache (cosine similarity) βœ… SemanticCache Β§8.3
GDPR invalidatePII() βœ… β€” Β§8.4
Tenant Isolation + Quotas βœ… β€” Β§8.5
Circuit Breaker (L3) βœ… β€” Β§8.6
Warmup / Snapshot Export βœ… β€” Β§8.7
PredictivePrefetcher (Markov-chain) βœ… PredictivePrefetcher Β§8.8

Module: src/cache/, include/cache/
Compendium: chapter_08_storage_layer.md


Network & Protocols (Β§31)

Feature Status Class Documentation
WireProtocolServer (port 8766, mTLS) βœ… WireProtocolServer Β§31.1
Wire Protocol V2 (RFC 7540 Β§6.3) βœ… WireProtocolV2 Β§31.2
QUIC Transport (port 8770, 0-RTT) βœ… QuicTransport Β§31.3
UDP Fast-Path (port 8769) βœ… UDPServer Β§31.4
gRPC (port 8771) βœ… GrpcServer Β§31.5
RaftLoadBalancer βœ… RaftLoadBalancer Β§31.6
UDP Bandwidth Management / QoS βœ… BandwidthManager Β§31.7
SCRAM-SHA-256 βœ… SCRAMAuthenticator Β§31.8
IPv6 Dual-Stack βœ… β€” Β§31.9

Module: src/network/, include/network/
Compendium: chapter_31_api_protocols.md


Content Management (Β§7)

Feature Status Class Documentation
ingestRawBlob (10-stage pipeline) βœ… ContentManager Β§7.1
PdfProcessor βœ… PdfProcessor Β§7.2
OfficeProcessor βœ… OfficeProcessor Β§7.3
HtmlProcessor / MarkdownProcessor βœ… HtmlProcessor Β§7.4
OcrProcessor βœ… OcrProcessor Β§7.5
DeduplicationChecker (pHash+MinHash) βœ… DeduplicationChecker Β§7.6
LanguageDetector βœ… LanguageDetector Β§7.7
ContentManagerLlm βœ… ContentManagerLlm Β§7.8

Module: src/content/, include/content/
Compendium: chapter_07_document.md


Scheduler & Retention (Β§8 Scheduler)

Feature Status Class Documentation
TaskScheduler (Cron/CDC/DAG/Retry) βœ… TaskScheduler Β§8.10
HybridRetentionManager (3-stage) βœ… HybridRetentionManager Β§8.11
DistributedTaskCoordinator βœ… DistributedTaskCoordinator Β§8.12
Dynamic Worker Scaling βœ… β€” Β§8.13

Module: src/scheduler/, include/scheduler/
Compendium: chapter_08_storage_layer.md


Graph Database (Β§6)

Feature Status Class Documentation
GraphQueryOptimizer (BFS/DFS/A*/Dijkstra) βœ… GraphQueryOptimizer Β§6.1
EMA Adaptive Cost Model βœ… β€” Β§6.2
Parallel Frontier Expansion βœ… β€” Β§6.3
Constrained Path Finding βœ… β€” Β§6.4
DistributedGraphManager βœ… DistributedGraphManager Β§6.5
EXPLAIN Endpoint βœ… β€” Β§6.6
Streaming Graph Results βœ… β€” Β§6.7
ScheduledGraphEdgeRefreshEngine βœ… ScheduledGraphEdgeRefreshEngine Β§6.11

Module: src/graph/, include/graph/
Compendium: chapter_06_graph.md


Voice Assistant (Β§17 Voice)

Feature Status Class Documentation
VoiceAssistant (STT+LLM+TTS) 🟒 VoiceAssistant §17.35
Wake-Word Detection 🟒 β€” Β§17.36
Meeting Protocol Generation 🟒 β€” Β§17.37
VoiceBiometricAuthenticator 🟒 VoiceBiometricAuthenticator §17.38
TelephonyBridge (SIP/WebRTC) 🟑 TelephonyBridge §17.39
Browser WebSocket Streaming 🟒 β€” Β§17.40
EmotionAnalyzer 🟑 EmotionAnalyzer §17.41
VoiceMacro 🟒 VoiceMacro §17.42

Module: src/voice/, src/whisper/, include/voice/
Compendium: chapter_17_llm_integration.md


Utilities (Β§utils)

Feature Status Class Documentation
UUID v7 (RFC 9562) βœ… generate_uuid_v7() utilsΒ§1
LZ4 Codec (safe+legacy API) βœ… LZ4Codec utilsΒ§2
Streaming ZSTD Compressor βœ… ZstdStreamCompressor utilsΒ§3
Streaming ZSTD Decompressor βœ… ZstdStreamDecompressor utilsΒ§4

Module: src/utils/, include/utils/


In Development / Planned (v1.9.0 β€” v2.0.0)

Feature Target Module Issue / PR
Chimera streaming result sets v1.9.0 chimera #4478
Chimera prepared statements v1.9.0 chimera #4478
ISO 27001 + HIPAA rule evaluators v1.9.0 governance #4484
Auth focused test targets v1.9.1 auth #4474
CDC replay/filter/batch-commit v2.0.0 cdc #4477
Query v2.0.0 port v2.0.0 query #4569
Storage v2.0.0 port v2.0.0 storage #4570
GPU traversal kernels (CUDA) v2.0.0 graph roadmap
Vulkan compute shaders (distance) v2.0.0 acceleration roadmap
Multi-GPU distributed training coord. v2.0.0 training roadmap
Token counting / context-window budget v2.0.0 prompt_engineering roadmap
OAuth 2.0 token refresh in connectors v1.9.x ingestion #2408

VollstÀndige Modul-Übersicht (v1.8.0)

Modul Status Compendium-Kapitel
acceleration 🟒 MVP Complete §1.5
analytics βœ… Production-Ready Β§15, Β§29
api βœ… Production-Ready Β§32
aql βœ… Production-Ready Β§28, Β§32
auth βœ… Production-Ready Β§21
base βœ… Production-Ready Β§2
cache βœ… Production-Ready Β§8
cdc βœ… Production-Ready Β§11
chaos βœ… Production-Ready Β§18
chimera πŸ”΄ Alpha Β§37
config βœ… Production-Ready Β§25
content βœ… Production-Ready Β§7
core βœ… Production-Ready Β§2
ethics_ai βœ… Production-Ready Β§24
exporters βœ… Production-Ready Β§16-ML
failover βœ… Production-Ready Β§18
geo βœ… Production-Ready Β§14
governance βœ… Production-Ready Β§40
gpu βœ… Production-Ready Β§12
graph βœ… Production-Ready Β§6
importers βœ… Production-Ready Β§26
index βœ… Production-Ready Β§34
ingestion βœ… Production-Ready Β§11
llm βœ… Production-Ready Β§17
maintenance βœ… Production-Ready Β§30
metadata βœ… Production-Ready Β§35
network βœ… Production-Ready Β§31
observability βœ… Production-Ready Β§38
performance βœ… Production-Ready Β§20, Β§39
plugins βœ… Production-Ready Β§37
process βœ… Production-Ready Β§29
prompt_engineering βœ… Production-Ready Β§17
query βœ… Production-Ready Β§34
rag βœ… Production-Ready Β§17
replication βœ… Production-Ready Β§18
scheduler βœ… Production-Ready Β§8
search βœ… Production-Ready Β§13
security βœ… Production-Ready Β§36
server βœ… Production-Ready Β§31, Β§32
sharding βœ… Production-Ready Β§16
storage βœ… Production-Ready Β§8, Β§20
temporal βœ… Production-Ready Β§9
themis βœ… Production-Ready Β§2
timeseries βœ… Production-Ready Β§9
training βœ… Production-Ready Β§16-ML
transaction βœ… Production-Ready mvcc
updates βœ… Production-Ready Β§25
utils βœ… Production-Ready β€”
voice 🟒 MVP Complete §17

Gesamt: 46 Module
Production-Ready: 43 (93%)
MVP Complete: 2 (4%)
Alpha: 1 (2%)


Version History

Version Datum Highlights
v2.0.0 geplant GPU kernel API stabilisierung, API /v1/ als stable surface, CDC replay/filter
v1.9.x geplant Chimera streaming, Governance ISO 27001/HIPAA, Auth test targets
v1.8.0 Apr 2026 Wire Protocol V2, SSI, SAGA Engine, Versioned API Routing, PredictivePrefetcher, GpuErasureCoder, MySQL Importer, CEP deadlock fix, PolicyManager hot-reload
v1.7.0 Feb 2026 Core module migration to src/themis/, module loader refactor
v1.6.0 Jan 2026 WALArchival (Zstd+AES-256-GCM), LogicalReplication, UUID v7, LZ4/ZSTD codecs
v1.5.0 Dez 2025 Comprehensive multi-model: HA, Voice, advanced LLM, PostgreSQL Wire Protocol
v1.4.0-alpha Jan 2026 LLM integration, Performance optimierungen, HA, Monitoring (ursprΓΌngliche Alpha)

Zweck dieses Appendix

Dieser Appendix bietet eine vollstÀndige, strukturierte Übersicht aller ThemisDB-Features mit aktuellem Implementierungsstatus, Dokumentationsverweisen und Roadmap-Planung. Dies dient als zentraler Referenzpunkt für:

  • Entwickler: Welche Features sind verfΓΌgbar? Wo ist der Code?
  • Architekten: Welche Capabilities hat ThemisDB? Was fehlt noch?
  • Projektmanager: Was ist Production-Ready? Was ist geplant?
  • Nutzer: Welche Funktionen kann ich nutzen?

Status-Definitionen

Symbol Status Bedeutung
βœ… Production-Ready VollstΓ€ndig implementiert, getestet (>85% Coverage), dokumentiert, performance-validated
🟒 MVP Complete KernfunktionalitÀt vorhanden, stabil, aber ggf. noch Optimierungen ausstehend
🟑 In Development Aktiv in Entwicklung, teilweise funktional, noch nicht production-grade
🟠 Design Phase Spezifikation vorhanden, Implementierung geplant
πŸ”΅ Planned Auf Roadmap, noch keine Spezifikation
βšͺ Backlog Idee/Anforderung dokumentiert, keine aktive Planung
πŸ†• Alpha Neu in v1.4.0-alpha, noch nicht production-ready
❌ Not Planned Bewusst nicht im Scope

Zusammenfassung

Aktuelle Reife (Stand Feb 2026):

  • Core Database: βœ… Production-Ready (85%+ Test Coverage)
  • Multi-Model Support: βœ… Production-Ready (Relational, Graph, Vector, Document, Time-Series)
  • Security & Compliance: βœ… Production-Ready (DSGVO, BSI C5, Audit Logging)
  • Horizontal Scaling: βœ… Production-Ready (2/4/8-Node Clusters, 91% Efficiency)
  • High Availability: 🟒 MVP Complete (Hot Spare, WAL Replication, promoted from Alpha)
  • Voice Assistant: πŸ†• Beta (Whisper STT, Piper TTS, Meeting Protocols, Call Center Automation)
  • LLM/RAG Integration: 🟒 MVP Complete (8 Features: Prefix/Response Caching, Multi-GPU, Paged Attention, LoRA, Grammar-Constrained Generation, RoPE Scaling, Vision - promoted from Alpha)
  • Performance Optimizations: 🟒 MVP Complete (Flash Attention, Speculative Decoding, Continuous Batching)
  • PostgreSQL Wire Protocol: 🟑 In Development (COPY, LISTEN/NOTIFY, Binary Format, Pipeline Mode - see src/server/FUTURE_ENHANCEMENTS.md)
  • Enhanced Monitoring: βœ… Production-Ready (30+ Prometheus-Metriken fΓΌr LLM, HA, Performance)

v1.5.0-dev Feature-Highlights

LLM-Integration (Kapitel 17)

Feature Status Maturity Documentation Performance
Prefix Caching 🟒 MVP Complete Stable Chapter 17.12.1 75% cost savings
Response Caching 🟒 MVP Complete Stable Chapter 17.12.2 60-80% savings
Multi-GPU Support 🟒 MVP Complete Stable Chapter 17.12.3 4-8x throughput
Paged Attention 🟒 MVP Complete Stable Chapter 17.12.4 80% memory reduction
LoRA Support 🟒 MVP Complete Stable Chapter 17.12.5 99% less memory
Grammar-Constrained Generation 🟒 MVP Complete Stable Chapter 17.12.6 95-99% valid outputs
RoPE Scaling 🟒 MVP Complete Stable Chapter 17.12.7 4Kβ†’32K context
Vision Support 🟒 MVP Complete Stable Chapter 17.12.8 Multimodal AI

Roadmap:

  • Production-Ready (v1.6): Extended testing, performance tuning, production certification

Enterprise Features (Kapitel 10)

Feature Status Maturity Documentation Use Case
Voice Assistant 🟑 Beta Improving Chapter 10.7 Call Center, Meeting Protocols
Multi-Tenancy βœ… Production-Ready Stable Chapter 10.1 SaaS Applications
RBAC βœ… Production-Ready Stable Chapter 10.1 Enterprise Security
Audit Logging βœ… Production-Ready Stable Chapter 10.1 Compliance

Roadmap (Voice Assistant):

  • Production-Ready (v1.6): Enhanced language support, improved accuracy, production certification

Performance-Optimierungen (Kapitel 21)

Feature Status Maturity Documentation Performance
Flash Attention 🟒 MVP Complete Stable Chapter 20.9A.1 69% throughput, 37% memory
Speculative Decoding 🟑 In Development Experimental Chapter 20.9A.2 2-3x speedup (target)
Continuous Batching 🟒 MVP Complete Stable Chapter 20.9A.3 176% throughput

Roadmap:

  • Production-Ready (v1.6): Hardware compatibility testing, production deployment guides

High Availability (Kapitel 16)

Feature Status Maturity Documentation Performance
Hot Spare 🟒 MVP Complete Stable Chapter 16.10.1 <5s failover
WAL Replication 🟒 MVP Complete Stable Chapter 16.10.2 Zero data loss
Multi-SSD WAL πŸ†• Alpha Early Chapter 16.10.2 <10% write overhead
Replication Slots πŸ†• Alpha Early Chapter 16.10.2 Lag monitoring

Roadmap:

  • Beta (Feb 2026): Extended failover testing, disaster recovery
  • GA (Mar 2026): Production HA certification

Monitoring & Observability (Kapitel 19)

Feature Status Maturity Documentation Metrics Count
LLM Metrics πŸ†• Alpha Early Chapter 19.6A.1 15+ metrics
Performance Metrics πŸ†• Alpha Early Chapter 19.6A.2 10+ metrics
HA Metrics πŸ†• Alpha Early Chapter 19.6A.3 8+ metrics
Grafana Dashboards πŸ†• Alpha Early Chapter 19.6A 3 dashboards
Alerting Rules πŸ†• Alpha Early Chapter 19.6A.4 12+ rules

Roadmap:

  • Beta (Feb 2026): Dashboard refinement, extended alerting
  • GA (Mar 2026): Complete observability stack

PostgreSQL Wire Protocol (Kapitel 31)

Feature Status Maturity Documentation Performance
COPY Protocol πŸ†• Alpha Early Chapter 31.9A.1 250K rows/s
LISTEN/NOTIFY πŸ†• Alpha Early Chapter 31.9A.1 Real-time CDC
Binary Format πŸ†• Alpha Early Chapter 31.9A.2 80% size reduction
Pipeline Mode πŸ†• Alpha Early Chapter 31.9A.2 17x throughput
Prepared Stmt Cache πŸ†• Alpha Early Chapter 31.9A.2 50x speedup
Vector Type Mapping πŸ†• Alpha Early Chapter 31.9A.3 Native pgvector
JSONB Support πŸ†• Alpha Early Chapter 31.9A.3 Full compatibility

Roadmap:

  • Beta (Feb 2026): Extended client library testing
  • GA (Mar 2026): Full PostgreSQL compatibility certification

VollstΓ€ndige Feature-Matrix

VollstΓ€ndige Feature-Matrix siehe:

  • Admin Tools: feature_matrix.md
  • Features Overview: features_overview.md
  • Sharding Status: Chapter 16 (Horizontal Scaling)
  • Security Status: Chapter 10 (Section 10.2)
  • Query Optimization: Chapter 15 (Section 15.4)

Feature-Maturity-Levels

Alpha (v1.4.0-alpha)

Definition: Neue Features in frΓΌher Entwicklung, fΓΌr Feedback und Testing.

Charakteristiken:

  • βœ… KernfunktionalitΓ€t implementiert
  • βœ… Dokumentation vorhanden
  • ⚠️ Noch nicht production-ready
  • ⚠️ API kann sich Γ€ndern
  • ⚠️ Performance noch nicht final optimiert

Empfohlene Nutzung:

  • Development/Staging Environments
  • Feature Evaluation
  • Feedback und Bug Reports

Beta (geplant: Feb 2026)

Definition: Features sind stabil, werden fΓΌr Production vorbereitet.

Charakteristiken:

  • βœ… VollstΓ€ndig implementiert
  • βœ… >80% Test Coverage
  • βœ… Performance-validated
  • ⚠️ Noch unter intensivem Testing
  • ⚠️ Minor API changes mΓΆglich

Empfohlene Nutzung:

  • Pre-Production Testing
  • Pilot-Deployments
  • Performance Benchmarking

GA (General Availability - geplant: Mar 2026)

Definition: Production-ready, vollstΓ€ndig getestet und dokumentiert.

Charakteristiken:

  • βœ… Production-Ready
  • βœ… >85% Test Coverage
  • βœ… Performance-validated
  • βœ… Complete Documentation
  • βœ… Stable API
  • βœ… Long-term Support

Empfohlene Nutzung:

  • Production Deployments
  • Mission-Critical Workloads
  • Enterprise Applications

Implementierungsstatus v1.4.0-alpha

Gesamt-Übersicht

Kategorie Features Alpha Beta GA Geplant
LLM Integration 6 6 0 0 0
Performance 3 3 0 0 0
High Availability 4 4 0 0 0
Monitoring 5 5 0 0 0
PostgreSQL Protocol 7 7 0 0 0
Gesamt 25 25 0 0 0

Prozentsatz:

  • Alpha Features: 100% (25/25)
  • Production-Ready: 0% (Target: 100% by Mar 2026)

Implementierungsstatus v1.9.x (2026-04-12)

Die folgenden Komponenten wurden mit dem v1.9.x-Release (Commit 2026-04-12) in den Produktionscode aufgenommen:

Storage & Ingest

Feature Modul Status Tests Beschreibung
StreamingIngestManager storage/ βœ… GA SM-01..SM-10 Ring-Buffer-Ingest β‰₯ 1 M Events/s, OverflowPolicy BLOCK/DROP
TSStore::putBatch timeseries/ βœ… GA TB-01..TB-14 Zero-Copy Batch Write via std::span<const TSRow>
TsStreamCursor timeseries/ βœ… GA SC-01..SC-08 Lazy paginierter Iterator, page_size=4 096
TemporalCompressor LZ4 temporal/ βœ… GA TC-LZ4-01..TC-LZ4-05 LZ4-Block-Kompression im TemporalCompressor
STORAGE_COMPACTION Wiring maintenance/ βœ… GA β€” StorageCompactionHandler in maintenance_orchestrator_ registriert
MVCC_CLEANUP Wiring maintenance/ βœ… GA β€” MvccCleanupHandler mit 24 h Watermark registriert

Maintenance

Feature Modul Status Tests Beschreibung
DatabaseMaintenanceOrchestrator maintenance/ βœ… GA 40+ (OrchestratorTests) Zentraler Wartungskoordinator: CRUD, Cron, DAG, Window-Enforcement, Audit
MaintenanceScheduleStore maintenance/ βœ… GA β€” RocksDB-Persistenz fΓΌr Schedules (maint_sched::<id>)
StorageCompactionHandler maintenance/ βœ… GA β€” Kapselt CompactionManager::compactAll()
MvccCleanupHandler maintenance/ βœ… GA β€” Bereinigt MVCC-Versionen mit konfigurierbarem Watermark
DAG Task Dependencies maintenance/ βœ… GA β€” depends_on-Felder; topologische Sortierung via Kahn; Zykelerkennung
Maintenance Window Enforcement maintenance/ βœ… GA β€” Tasks außerhalb window_utc_hours β†’ SKIPPED
11 REST Endpoints maintenance/ βœ… GA β€” /api/v1/maintenance/schedules + /jobs + /status

Analytics

Feature Modul Status Tests Beschreibung
ColumnarCache storage/ βœ… GA CC-01..CC-12 LRU-Eviction + PinGuard RAII, β‰₯ 10Γ— Speedup
IStreamingJoin / HashJoin analytics/ βœ… GA SJ-01..SJ-15 Equi-Join, Inner/LeftOuter, composite keys
IntervalJoin analytics/ βœ… GA SJ-01..SJ-15 Zeitbasierter Event-Join, LRU-Pruning

Performance & Netzwerk

Feature Modul Status Tests Beschreibung
LockFreeHistogram<T> performance/ βœ… GA LFH-01..LFH-12 Lock-free, ≀ 20 ns record(), Exponential+Linear
RequestCoalescer (Singleflight) cache/ βœ… GA RC-01..RC-14 Thundering-Herd-Schutz, fn() exakt einmal
IoUringBatchedSender network/ βœ… GA IUB-01..IUB-12 O(1) Syscalls/Runde, writev(2)-Fallback
LIRS shared_mutex Fix performance/ βœ… GA β€” TOCTOU-Race beseitigt; get() β†’ unique_lock
RCU g_rcu_reader_count Fix performance/ βœ… GA β€” readers_active() war immer false, jetzt korrekt

Geo-Modul (v1.x)

Feature Modul Status Tests Beschreibung
ST_BUFFER geo/ βœ… GA β€” CPU-exact + Boost; GPU-Fallback mit Audit-Log
ST_UNION / ST_DIFFERENCE geo/ βœ… GA β€” CPU-exact, Boost, GPU-fallback; AQL-Funktionen
CUDA Geo-Kernel geo/acceleration/ βœ… GA β€” Haversine-Distanz, Containment-Batch (CUDA + ROCm/HIP)
S2-Zell-Indizierung geo/ βœ… GA β€” Hierarchische S2-Zellen; cellForPoint(), coveringCells()
H3-Hexagonales Grid geo/ βœ… GA β€” Uber H3; geoToH3(), kRing(), compact()
TemporalSpatialQuery geo/ βœ… GA β€” Location-at-Time T; locationAtTime(), entitiesInBboxAtTime()
RasterGrid / sampleAt() geo/ βœ… GA β€” Elevation-Sampling mit bilinearer Interpolation
generateHeatmap() geo/ βœ… GA β€” Gaussian-KDE aus Punktwolke; konfigurierbare Bandbreite + AuflΓΆsung
Spatial JOIN geo/ βœ… GA β€” Alle Paare innerhalb Distanz (CUDA-optimiert)
ROCm/HIP-Backend geo/ βœ… GA β€” AMD GPU-UnterstΓΌtzung als CUDA-Alternative

AI / Acceleration

Feature Modul Status Tests Beschreibung
AiHardwareDispatcher acceleration/ βœ… GA AHD-01..AHD-30 NPU-PrioritΓ€tskette, INT4/W4A8, ONNX-EP-Fallback
GPUVectorIndex Oversubscription index/ βœ… GA 26 (GPUMemOversubTests) Partitions-basiertes VRAM-Paging; LRU/MRU/SEQUENTIAL Prefetch
GPUMemoryOversubscriptionManager index/ βœ… GA 26 (GPUMemOversubTests) Unified Memory (cudaMallocManaged/hipMallocManaged); CPU-Fallback
GPUUnifiedMemoryAllocator index/ βœ… GA β€” Transparente CUDA/HIP Unified Memory + CPU-Heap-Fallback
CUDAVectorBackend acceleration/ βœ… GA β€” HNSW on GPU; Batch-KNN; CUDA Graph Capture; buildHnswAnnIndex
MultiGPUVectorBackend acceleration/ βœ… GA β€” NCCL/RCCL Fan-out KNN; NVLink P2P; CPU-Fallback; bis zu N GPUs
GeoAccelerationBridge acceleration/ βœ… GA β€” CUDA/Vulkan Haversine + Point-in-Polygon; Backend-Dispatch
Vulkan Compute (non-NVIDIA) acceleration/ βœ… GA β€” SPIR-V Shaders: L2/Cosine/InnProd/TopK/Batch+Geo-Kernels
ROCm/HIP Backend (AMD) acceleration/ βœ… GA β€” ann_kernels.hip + geo_kernels.hip; non-HIP CPU-Fallback

Utils

Feature Modul Status Tests Beschreibung
UUID v7 (generate_uuid_v7) utils/ βœ… GA UV7-01..UV7-20 RFC 9562, 48-bit Timestamp, 18-bit Seq, MT19937-64
Streaming ZSTD (zstd_compress_stream) utils/ βœ… GA ZS-01..ZS-10 ZSTD_CStream/DStream, max_output_bytes DoS-Guard

Content-Modul (v1.x)

Feature Modul Status Tests Beschreibung
ContentManager::ingestRawBlob() content/ βœ… GA β€” Auto-MIME, 10-stufige Pipeline, Archive-Rekursion
PdfProcessor content/ βœ… GA β€” Text-Extraktion via poppler-cpp
OfficeProcessor (OOXML/ODF) content/ βœ… GA β€” DOCX/XLSX/PPTX/ODF via libzip+pugixml
OfficeProcessor (Legacy) content/ βœ… GA β€” DOC/XLS/PPT via LibreOffice-Headless-Fallback
HtmlProcessor content/ βœ… GA β€” Boilerplate-Entfernung
MarkdownProcessor content/ βœ… GA β€” Frontmatter-Parsing
SttProcessor / TtsProcessor content/ βœ… GA β€” Whisper-Transkription + TTS
OcrProcessor content/ βœ… GA β€” Tesseract OCR fΓΌr Bild-PDFs
DeduplicationChecker content/ βœ… GA β€” pHash (Bilder) + MinHash+LSH (Text); Jaccard-Schwellenwert
LanguageDetector content/ βœ… GA β€” Multi-Sprach-Erkennung mit Konfidenz
ContentManagerLlm content/ βœ… GA β€” Summary, Topics, Sentiment, Category via LLM

Scheduler-Modul (v1.5)

Feature Modul Status Tests Beschreibung
TaskScheduler scheduler/ βœ… GA β€” Cron/Interval/CDC/Manual/Webhook Trigger; 5/6-Feld, Timezone
DAG-Workflow-Engine scheduler/ βœ… GA β€” Topologische AusfΓΌhrung, paralleler Fan-Out, branch_condition
Retry-Policies scheduler/ βœ… GA β€” FIXED/EXPONENTIAL/LINEAR/JITTER/FIBONACCI
TaskScheduler Dynamic Scaling scheduler/ βœ… GA β€” Auto-Concurrency via Queue-Tiefe + enable_dynamic_scaling
TaskAuditManager scheduler/ βœ… GA β€” Durchsuchbares Audit-Log; GDPR-Modus
TaskAnomalyDetector scheduler/ βœ… GA β€” Anomalie-Erkennung ΓΌber Task-AusfΓΌhrungs-Metriken
Prometheus-Export (exportMetrics()) scheduler/ βœ… GA β€” Metriken-Text fΓΌr Scraping
HybridRetentionManager scheduler/ βœ… GA β€” 3-Stufen: Gorilla (0–7d), Varianz-Downsampling (7–365d), Tages-Aggregate (>365d)
DistributedTaskCoordinator scheduler/ βœ… GA β€” Leader-Election; One-Runner-Per-Cluster
ExternalSchedulerAdapter scheduler/ βœ… GA β€” Kubernetes CronJob + Apache Airflow Adapter

Analytics-Modul (v1.9)

Feature Modul Status Tests Beschreibung
OLAPEngine GPU-Pfad analytics/ βœ… GA β€” GPU-beschleunigt (threshold=10K rows); LRU Result Cache (TTL)
OLAPEngine CUBE/ROLLUP analytics/ βœ… GA β€” CUBE (alle Dimensionskombinationen), ROLLUP (Hierarchisch), GROUPING SETS
Window Functions analytics/ βœ… GA β€” ROW_NUMBER, SUM/AVG OVER, P50/P90/P99, ROWS/RANGE BETWEEN
CEPEngine (EPL Parser) analytics/ βœ… GA β€” NFA Pattern Matching; EPL CREATE RULE; WINDOW/GROUP BY/HAVING/ACTION
CEPEngine Event Types analytics/ βœ… GA β€” CDC (INSERT/UPDATE/DELETE), Graph, Query, System events; MPMC Ring Buffer
AnomalyDetector analytics/ βœ… GA β€” Isolation Forest; konfigurierbare Kontaminationsrate; Rolling Window
ModelServingEngine analytics/ βœ… GA β€” Online + Batch ONNX Inference; versioniertes Model Loading
Inkrementelle Materialized Views analytics/ βœ… GA β€” CDC-getrieben; Delta-Update ohne Full-Recompute

Search-Modul (v2.4)

Feature Modul Status Tests Beschreibung
HybridSearch search/ βœ… GA β€” BM25+Vector RRF (k=60); konfig. Gewichte; Partial-Result Stats
DistributedHybridSearch search/ βœ… GA β€” Cross-Shard RRF; mTLS; skip_failed_shards Degraded Mode
SearchHighlighter search/ βœ… GA β€” Term Highlighting <mark>; Best-Passage Snippet Extraktion
SearchResultStream search/ βœ… GA β€” Cursor-basierte Streaming-Pagination (total_k/page_size)
ConversationalSearch search/ βœ… GA β€” Multi-Turn Context Window (last N turns); automatische Query-Reformulation
FederatedSearch search/ βœ… GA β€” Tenant-isolierte Parallel-Suche mit per-Tenant Gewichtung
FacetedSearch search/ βœ… GA β€” Facettierte Suche ΓΌber kategorische + Bereichs-Felder
LearningToRank search/ βœ… GA β€” Listwise/Pairwise LTR; Feature-basiertes Re-Ranking
AutocompleteEngine search/ βœ… GA β€” Prefix-Trie Autocomplete; Fuzzy + Phonetik
MultiModalSearch search/ βœ… GA β€” Text + Bild + Audio Query Fusion

Ingestion-Modul (v1.5)

Feature Modul Status Tests Beschreibung
IngestionManager ingestion/ βœ… GA β€” Parallele Multi-Source-Orchestrierung; Thread-Pool; Prometheus-Metriken
IngestionBuilder ingestion/ βœ… GA β€” Fluent API (withKafkaSource/withApiSource/withHuggingFaceSource/...)
GenericApiConnector ingestion/ βœ… GA β€” Cursor/Offset-Pagination; OAuth 2.0; libcurl; Exponential Back-off
HuggingFaceConnector ingestion/ βœ… GA β€” Dataset-Split-Ingest; API-Token-Auth
ObjectStorageConnector ingestion/ βœ… GA β€” S3/GCS/Azure Blob; Prefix-Filter
KafkaConnector ingestion/ βœ… GA β€” Consumer-Group; Auto-Commit; Back-pressure
WebCrawlerConnector ingestion/ βœ… GA β€” Sitemap + Recursive Crawl; politeness_delay
CdcConnector (PostgreSQL) ingestion/ βœ… GA β€” Logical Replication Slot; WAL-basiertes CDC
DatabaseConnector (JDBC/ODBC) ingestion/ βœ… GA β€” Batch-Select + Cursor-basierte Pagination
Quarantine + Retry ingestion/ βœ… GA β€” Exponential Back-off; Dead-Letter nach max_retries
Incremental Checkpoint ingestion/ βœ… GA β€” Fortschritt persistiert; Re-Start ab letztem Checkpoint
Plugin API ingestion/ βœ… GA β€” ISourceConnector-Interface fΓΌr Third-Party Konnektoren

Importers-Modul (v2.1)

Feature Modul Status Tests Beschreibung
PostgresImporter v2.1 importers/ βœ… GA β€” FK-Preservation (ON DELETE/UPDATE, DEFERRABLE); CHECK/EXCLUDE/GENERATED Constraints
MongoImporter importers/ βœ… GA β€” BSONβ†’JSON; _id-Preservation
MySQLImporter importers/ βœ… GA β€” Batch-Import; Charset-Mapping
OracleImporter importers/ βœ… GA β€” DDL + Data Export
SqliteImporter importers/ βœ… GA β€” Lightweight; kein Server nΓΆtig
FlatFileImporter importers/ βœ… GA β€” CSV/TSV/Parquet; Auto-Type-Detection; Parquet-Kompression
KafkaImporter importers/ βœ… GA β€” Consumer-Group; Offset-Tracking
S3Importer importers/ βœ… GA β€” Prefix-Filter; Multipart-Download
IImporter::importDataStreaming() importers/ βœ… GA β€” Low-Memory Streaming; per-Row Callback; frΓΌhzeitiger Abbruch
SchemaInferenceEngine importers/ βœ… GA β€” Implicit FK Discovery; Semantic Type Detection; Cardinality Estimation
AuditedImporter importers/ βœ… GA β€” Audit-Trail fΓΌr jede importierte Zeile + Schema-Γ„nderung
IImporterPlugin API importers/ βœ… GA β€” Plugin-Interface fΓΌr Third-Party Importer

Implementierungsstatus β€” Plugins & Sharding

Plugins (v2.x)

Feature Modul Status Tests Beschreibung
WhisperPlugin v2.0 whisper/ βœ… GA 30 (WhisperPluginFocusedTests) IAudioBackend, WavAudioChunkReader, Strategy Pattern, Provenienz-Stempel
WavAudioChunkReader whisper/ βœ… GA im WhisperPlugin-Suite RIFF/WAV ohne libsndfile; 16-bit PCM + float32
SDPlugin v2.1 stable_diffusion/ βœ… GA 45 (SDPluginFocusedTests, A–O) Text2Img, Batch, Img2Img, SDPromptSanitizer, Provenienz
SDStubGenerator stable_diffusion/ βœ… GA im SDPlugin-Suite CI-Stub ohne Modell-Datei
SDPromptSanitizer stable_diffusion/ βœ… GA im SDPlugin-Suite Keyword-Blocklist, negative_prompt-Policy (SD-NP-01)

Network-Modul (v1.8)

Feature Modul Status Tests Beschreibung
WireProtocolServer network/ βœ… GA β€” Port 8766; dedizierted I/O+Worker-Pool; mTLS; SCRAM-SHA-256
WireProtocolServer WebSocket-Upgrade network/ βœ… GA β€” HTTP-Upgrade auf Port 8766; JSON Text-Frames (THEMIS_ENABLE_WEBSOCKET)
WireProtocolServer IPv6+Dual-Stack network/ βœ… GA β€” IPv6-Socket + ipv6_dual_stack fΓΌr IPv4-mapped Verbindungen
QuicTransport network/ βœ… GA β€” Port 8770; UDP+TLS 1.3; 0-RTT; kein HOL-Blocking
RaftLoadBalancer network/ βœ… GA β€” Raft In-Process-Konsensus; konsistentes Routing; Leader-Election
UDP Fast-Path network/ βœ… GA β€” Port 8769; latenzoptimierter Ingest-Pfad
gRPC Transport network/ βœ… GA β€” Port 8771; HTTP/2 Multiplexing

Security-Modul (v1.x)

Feature Modul Status Tests Beschreibung
RLSManager security/ βœ… GA β€” PostgreSQL-kompatible Row-Level Security; PERMISSIVE+RESTRICTIVE; JSON-Persistenz
ZeroTrustPolicyEnforcer security/ βœ… GA β€” Per-Request Identity + CIDR Whitelist/Blacklist; Composite Trust Score
FieldEncryption (AES-256-GCM) security/ βœ… GA β€” Field-Level Encryption; Key Rotation (90d); DEK/KEK/MasterKey Hierarchie
HSM Integration security/ βœ… GA β€” HashiCorp Vault; HSM-backed Key Storage
AQL Injection Detection security/ βœ… GA β€” Pattern-basierte Angriffserkennung in AQL-Queries
Malware Scanner (Plugin Manifests) security/ βœ… GA β€” Plugin-Manifest-Scan vor Activation
CMS/PKCS#7 + eIDAS Timestamping security/ βœ… GA β€” Digitale Signaturen; eIDAS-konformes Timestamping
Feature Modul Status Tests Beschreibung
EthicsEvaluator ethics_ai/ βœ… GA 28 (EthicsAiPluginFocusedTests) 5-Dimensions-Scoring (Quality/Consistency/Fairness/Alignment/Transparency)
PhilosophyLoader ethics_ai/ βœ… GA 7 (PhilosophyLoaderFocusedTests) YAML-Profilladung mit Cache und Validierung
EthicalDiscourseEngine ethics_ai/ βœ… GA 11 (DiscourseEngineFocusedTests) initializeDebate() + makeDecision()
ArgumentStore ethics_ai/ βœ… GA 18 (ArgumentStoreStandaloneFocusedTests) BaseEntity-Persistenz + Standalone-Modus
RAGContextEngine ethics_ai/ βœ… GA 13 (RAGContextEngineFocusedTests) 7 AQL-Abfragemuster
Ethics AI Integration ethics_ai/ βœ… GA 21 (EthicsAiIntegration) FullPipeline, ArgumentStoreRAG, RAGContextBuild

LLM Module β€” Produktionskomponenten (v1.0)

Feature Modul Status Tests Beschreibung
LlamaWrapper::generateVision() llm/ βœ… GA β€” Multi-Modal Inference via CLIP-VisionEncoder; LLaVA-Architektur
VisionEncoder llm/ βœ… GA β€” CLIP-GGUF-Modell; encodeImage() β†’ float-Embedding-Vektor
LlamaWrapper RoPE Scaling llm/ βœ… GA β€” LINEAR/NTK/YARN/DYNAMIC; 4Kβ†’32K Kontext-Extension
MultiLoRAManager::loadLoRA() llm/ βœ… GA β€” vLLM-Stil; dynamic load, INT8/INT4-Quantisierung via quantizeLoRA()
MultiLoRAManager Multi-GPU llm/ βœ… GA β€” ROUND_ROBIN/DATA_PARALLEL/MODEL_PARALLEL; GPUDirect P2P
ProductionValidator llm/testing/ βœ… GA β€” 72h-Stresstest, Lasttest, Performance-Regression
IntegrationTestSuite llm/testing/ βœ… GA β€” 14 Szenarien (Komponenten-, Multi-Modell-, Fehler-, Performance-Tests)
LlamaWrapper Output-Validierung llm/ βœ… GA β€” UTF-8-PrΓΌfung, min/max-LΓ€nge, KohΓ€renz-Score

Prompt-Engineering-Modul (v2.0)

Feature Modul Status Tests Beschreibung
PromptManager prompt_engineering/ βœ… GA β€” RocksDB-Persistenz; CRUD; TBB lock-free Hash-Map; YAML Bulk-Load
PromptManager::validateTemplate() prompt_engineering/ βœ… GA β€” SyntaxprΓΌfung + Warnungen; in createTemplate() integriert
PromptManager::buildMultiModalPrompt() prompt_engineering/ βœ… GA β€” Multi-Modal Prompts mit ImageDescription-BlΓΆcken
FeedbackCollector prompt_engineering/ βœ… GA β€” 10 Feedback-Typen; FNV-1a Audit-Checksum; Z-Score Outlier
Git-Γ€hnliche Versionskontrolle prompt_engineering/ βœ… GA β€” Branches, Commits, Diffs, Parent-Tracking
A/B Testing prompt_engineering/ βœ… GA β€” Welch-t-Test Signifikanztests; std::erfc-basierter Z-Score
SelfImprovementOrchestrator prompt_engineering/ βœ… GA β€” Auto-Optimierung bei Feedback-Verschlechterung; Hintergrund-Worker
TreeOfThoughtsBuilder prompt_engineering/ βœ… GA β€” Multi-Pfad-Reasoning (Beam Search, max_depth, beam_width)
ProTeGiOptimizer prompt_engineering/ βœ… GA β€” Textual-Gradient-Optimierung; population_size + iterations
DSPy-Modul (dspy_module.h) prompt_engineering/ βœ… GA β€” DSPy-kompatibler Prompt-Deklarations-Layer
ContextWindowManager prompt_engineering/ βœ… GA β€” Context-Window-Budget-Enforcement

Voice-Modul (v1.1)

Feature Modul Status Tests Beschreibung
VoiceAssistant voice/ βœ… GA β€” STT (Whisper) + LLM (LlamaWrapper) + TTS; Session-Management
Wake-Word-Detektion voice/ βœ… GA β€” "Hey Themis"; konfig. Wake-Words; Low-Latency Detection
VoiceBiometricAuthenticator voice/ βœ… GA β€” Sprecher-Enrollment + Verification; Confidence Score
TelephonyBridge (SIP/WebRTC) voice/ βœ… GA β€” Anruf-Aufzeichnung + Transkription; Sprecher-Diarisierung
Browser WebSocket Streaming voice/ βœ… GA β€” Real-Time Audio-Chunking; ws://server/voice/stream
Meeting-Protokoll-Generierung voice/ βœ… GA β€” Zusammenfassung + Action-Items + Key-Points via LLM
EmotionAnalyzer voice/ βœ… GA β€” Emotionserkennung aus Audio-Features
VoiceMacro voice/ βœ… GA β€” Konfigurierbare Sprach-Makros + Trigger-Patterns

RAG-Modul v2 (v2.x)

Feature Modul Status Tests Beschreibung
RAGJudge rag/ βœ… GA β€” 5-dimensionale Evaluierung (Faith/Rel/Compl/Coh/Ethics); FAST/BALANCED/THOROUGH
HybridRetriever rag/ βœ… GA β€” BM25+Vector RRF-Fusion (k=60); linear Fallback; Factory-Helfer
DocumentSplitter rag/ βœ… GA β€” FIXED/SENTENCE/SEMANTIC/RECURSIVE; chunk_size + overlap
BatchEvaluator rag/ βœ… GA β€” Parallele Massenevaluierung mit Worker-Threads + Futures
EvaluationCache rag/ βœ… GA β€” Thread-sicherer LRU-Cache mit TTL; Invalidierungs-Triggers
CalibrationManager rag/ βœ… GA β€” Temperature Scaling, Platt Scaling, Isotonic Regression; ECE/Brier
HallucinationDashboard rag/ βœ… GA β€” Rolling-Window Halluzinationsrate + Trend (IMPROVING/STABLE/DEGRADING)
StreamingRetriever rag/ βœ… GA β€” Inkrementelles Kontext-Window-Filling
KnowledgeGraphRetriever rag/ βœ… GA β€” Entity-Linking + Graph-augmentierte Retrieval
CrossEncoderReranker rag/ βœ… GA β€” Heuristischer Scorer + ONNX-Stub
ContinuousLearningOrchestrator rag/ βœ… GA β€” Bayesian Optimierung ΓΌber top_k/threshold via User-Feedback
RlaifTrainer rag/ βœ… GA β€” Constitutional AI / RLAIF Training Pipeline

Graph-Modul (v1.x)

Feature Modul Status Tests Beschreibung
GraphQueryOptimizer graph/ βœ… GA β€” Cost-Based Algo-Selektion (BFS/DFS/BiDir/A*/Dijkstra); Schema-aware
Constrained Path Finding graph/ βœ… GA β€” max_depth, required/forbidden vertices, timeout_ms
Adaptive Kostenmodell graph/ βœ… GA β€” EMA-basiertes Lernen aus AusfΓΌhrungsfeedback
Parallele Traversierung graph/ βœ… GA β€” Parallele BFS-Frontier-Expansion; fan_out_threshold
DistributedGraphManager graph/ βœ… GA β€” Shard-ΓΌbergreifende Graph-Queries; EXPLAIN-Endpunkt
Inkrementelle Graph-Queries graph/ βœ… GA β€” Live-Updates ohne Full-Recompute
Graph Query Result Streaming graph/ βœ… GA β€” Cursor-basierte Streaming-Pagination fΓΌr große Path-Sets
ScheduledGraphEdgeRefreshEngine graph/ βœ… GA test_scheduled_edge_refresh.cpp Semantischer Kanten-Refresh; Kosinus/Dot/Euklid; Temporal Decay; Centrality; ACID-Batch; ANN; CEP; Changefeed; Β§6.11

Chaos Engineering & Failover (v1.x)

Feature Modul Status Tests Beschreibung
FaultInjector chaos/ βœ… GA β€” NODE_FAILURE/NETWORK_PARTITION/LEADER_CRASH/DISK_FAILURE/RANDOM; zeitlich begrenzt
ChaosScheduler chaos/ βœ… GA β€” Zeitgesteuerte Fault-Injections; Expiry-Handling
DisasterRecoveryManager failover/ βœ… GA β€” DR-Plan-AusfΓΌhrung (7 Schritte); Step-Hooks; dry_run; Statistiken
Automatic Failover Queue failover/ βœ… GA β€” Worker-Loop; Epoch-Fencing; Catchup-Wait

Sharding / Paxos

Feature Modul Status Tests Beschreibung
Paxos WAL logAccept sharding/ βœ… GA β€” ACCEPT vor Quorum-Broadcast persistiert
Paxos WAL logCommit sharding/ βœ… GA β€” COMMIT in broadcastCommit() persistiert
recoverFromWAL() sharding/ βœ… GA β€” Snapshot + WAL-Replay; commit_index_ wird restauriert
Snapshot-Compaction sharding/ βœ… GA β€” shouldCreateSnapshot(ops) nach konfigurierbaren Operationen

Replikation (v1.6)

Feature Modul Status Tests Beschreibung
WALArchivalManager replication/ βœ… GA β€” Zstd + AES-256-GCM; S3/GCS/Azure via IArchivalBackend
Storage-Tier Lifecycle replication/ βœ… GA β€” standard β†’ cold β†’ glacier; konfigurierbare Alters-Schwellen
LogicalReplicationManager replication/ βœ… GA β€” Schema-aware Slots; Row-Filter, DDL-Streaming, Parallel Decoding
LogicalReplicationManager Cross-Version replication/ βœ… GA β€” Per-Change-Transformer + Cross-Version-Transforms
IArchivalBackend replication/ βœ… GA β€” Pluggable Backend-Interface fΓΌr WAL-Segment-Storage

Governance-Modul (v1.x)

Feature Modul Status Tests Beschreibung
PolicyEngine::evaluate() governance/ βœ… GA β€” YAML-Policy, RBAC/ABAC, CCPA-Opt-Out, Hot-Reload
PolicyEngine::simulateDecision() governance/ βœ… GA β€” Dry-Run ohne Audit-Eintrag; matched_rule + matched_profile
PolicyEngine::checkQueryPermission() governance/ βœ… GA β€” Decision + FieldMaskingPolicy fΓΌr DataMasker
PolicyEngine::checkInferencePermission() governance/ βœ… GA β€” LLM-Endpunkt Zugangskontrolle; OpenAI-style FehlerkΓΆrper
OpaAdapter governance/ βœ… GA β€” OPA (Open Policy Agent) Integration; nativer Fallback
DataMasker::maskFields() governance/ βœ… GA β€” REDACT/HASH/TRUNCATE/TOKENIZE/ENCRYPT; letzter In-Process-Schutz
DataLineageTracker governance/ βœ… GA β€” Append-only Provenienz; Prometheus-Counter; Audit-Log
ModelGovernancePolicy governance/ βœ… GA β€” KI/ML Training Data Lineage, Bias-Auditing, Export-Check
CrossTenantPolicyInheritance governance/ βœ… GA β€” Hierarchische Policy-Vererbung ΓΌber Tenants
ComplianceReporter governance/ βœ… GA β€” GDPR/HIPAA/CCPA/PCI-DSS/SOC 2/ISO 27001 Reports (JSON + PDF)

Transaction-Modul (v1.9)

Feature Modul Status Tests Beschreibung
BranchManager transaction/ βœ… GA β€” Git-Γ€hnliche Branches + 3-Way-Merge; from_tag/from_sequence
SnapshotManager transaction/ βœ… GA β€” Named Snapshots/Tags; PITR-Basis
SAGA Distributed transaction/ βœ… GA β€” Kompensationsaktionen fΓΌr Relational/Index/Graph/Vector; Distributed Orchestration
DeadlockPredictor transaction/ βœ… GA β€” Probability Scoring (0–1); Lock-Order-Empfehlung; Adaptive Timeout
DistributedTransactionManager (2PC) transaction/ βœ… GA β€” WAL-backed Coordinator; Parallel Prepare/Commit; Crash Recovery
GlobalTransactionManager (TrueTime) transaction/ βœ… GA β€” Multi-Region ACID; TrueTime-basiertes Commit-Timestamp
Transaction Savepoints transaction/ βœ… GA β€” createSavepoint/rollbackToSavepoint/releaseSavepoint
OCC Mode transaction/ βœ… GA β€” getEntityVersion/optimisticPut/optimisticErase; per-Entity Versions
Bulk Transaction API transaction/ βœ… GA β€” bulkPutEntities/bulkEraseEntities; kein Per-Row-Overhead
Transaction Explain transaction/ βœ… GA β€” explain(): Locks, Write-Set, MVCC-Version-Chain

Cache-Modul (v1.x)

Feature Modul Status Tests Beschreibung
AdaptiveQueryCache (L1/L2/L3) cache/ βœ… GA β€” BoundedLRU (L1) + zstd/lz4 (L2) + RocksDB (L3); Adaptive TTL
SemanticCache cache/ βœ… GA β€” SHA-256 Fingerprint + Cosine Similarity; semantische Γ„quivalenz
GDPR-aware Invalidation cache/ βœ… GA β€” invalidatePII() (Art. 17); UUID-basierte PII-VerknΓΌpfung
Tenant-Isolation + Quotas cache/ βœ… GA β€” per_tenant_max_bytes; cross-tenant Zugriff = nullopt
Circuit Breaker (L3) cache/ βœ… GA β€” CLOSED/OPEN/HALF_OPEN; cb_failure_threshold konfigurierbar
Cache Warmup cache/ βœ… GA β€” warmupFromLog()/exportSnapshot(); Bulk-Vorausladen
Rate Limiting cache/ βœ… GA β€” Token Bucket; max_requests_per_second konfigurierbar

Observability-Modul (v1.x)

Feature Modul Status Tests Beschreibung
MetricsCollector (Singleton) observability/ βœ… GA β€” Prometheus Text-Format; 40+ Metriken (Query/Cache/Shard/Security/System)
QueryProfiler observability/ βœ… GA β€” Per-Phase Timing (parse/optimize/execute); Index-Usage; Empfehlungen
StorageProfiler observability/ βœ… GA β€” RocksDB-Stats; Write/Read-Amplification; Cache Hit Rates
PerformanceAnalyzer observability/ βœ… GA β€” Automatische Issue-Erkennung; INFO/WARNING/CRITICAL; Empfehlungen
AlertingEngine (Alertmanager) observability/ βœ… GA β€” Rule-based Alerting; Alertmanager Integration; PagerDuty/Slack
Distributed Tracing observability/ βœ… GA β€” OpenTelemetry-kompatibel; Span-Kontext-Propagierung
Kubernetes Health Probes observability/ βœ… GA β€” /ready + /live Endpunkte

Exporters-Modul (v1.x)

Feature Modul Status Tests Beschreibung
JsonlExporter exporters/ βœ… GA β€” JSONL; Instruction-Tuning: Alpaca/ShareGPT/ChatML/OpenAI
ParquetExporter exporters/ βœ… GA β€” Parquet + konfigurierbare Arrow-Schema; Kompression
ArrowIpcExporter exporters/ βœ… GA β€” Zero-Copy Apache Arrow IPC Pipeline
HuggingFaceExporter exporters/ βœ… GA β€” HF Hub Direct Upload; dataset_info.json + README-Karte
StreamingExporter exporters/ βœ… GA β€” Cursor-basiertes Streaming; Fortschritts-Callback + ETA
IncrementalExporter exporters/ βœ… GA β€” Delta-Export mit Watermark + Checkpoint
AQL Predicate Filter exporters/ βœ… GA β€” AQL-basiertes Filtern bei Export
AES-256-GCM Export Encryption exporters/ βœ… GA β€” VerschlΓΌsselter Export; PolicyEngine-Authorization
PII Detection + Redaction exporters/ βœ… GA β€” Automatische PII-Erkennung + Redaktion vor Export

Implementierungsstatus β€” Process Module (v1.0)

Serialisierer & Import

Feature Modul Status Tests Beschreibung
BpmnSerializer::importXml() process/ βœ… GA BpmnSerializerTest Zustandsbasierter XML-Tokenizer; 10 MiB-Guard; bpmn:-Namespace-Strip; tolerant
BpmnSerializer::exportXml() process/ βœ… GA BpmnSerializerTest Volle BPMN 2.0-Fidelity; OMG-konforme Ausgabe
BpmnSerializer::importFile() process/ βœ… GA β€” Datei-I/O-Wrapper
BpmnSerializer::exportFromJson() process/ βœ… GA β€” Export aus normalisiertem JSON-Graph
EpkSerializer::importText() process/ βœ… GA EpkSerializerTest EPK-Text-Notation + JSON-Array-Format
EpkSerializer::exportText() process/ βœ… GA EpkSerializerTest Round-trip-fΓ€hig
EpkSerializer::exportJson() process/ βœ… GA EpkSerializerTest Strukturiertes JSON fΓΌr LLM-Kontext
VccVpbImporter process/ βœ… GA VccVpbImporterTest VCC-VPB YAML-Import

ProcessModelManager

Feature Modul Status Tests Beschreibung
importBpmn() process/ βœ… GA ProcessModuleTest BPMN 2.0 β†’ ProcessModelRecord; RocksDB proc:def:<id>
importEpk() process/ βœ… GA ProcessModuleTest EPK β†’ ProcessModelRecord
importVccVpb() process/ βœ… GA ProcessModuleTest VCC-VPB β†’ ProcessModelRecord
save()/get()/remove()/list() process/ βœ… GA ProcessModuleTest Versioniertes CRUD
deployToEngine() process/ βœ… GA ProcessModuleTest Registriert Modell mit ProcessGraphManager
exportBpmn()/exportEpk() process/ βœ… GA ProcessModuleTest RΓΌckexport in Originalformat
generateLlmDescriptor() process/ βœ… GA LlmDescriptorTest JSON-Schema fΓΌr LLM-System-Prompts

ProcessLinker

Feature Modul Status Tests Beschreibung
attachObject() process/ βœ… GA ProcessModuleTest 8 ProcessLinkType-Werte; node-scoped optional
detachObject() process/ βœ… GA ProcessModuleTest Hard-Delete (kein Tombstone)
getAttachments() / getNodeAttachments() process/ βœ… GA ProcessModuleTest Mit optionalem Typ-Filter
findInstancesWithObject() process/ βœ… GA ProcessModuleTest SekundΓ€rindex proc:obj_idx:
linkProcesses() / getLinks() process/ βœ… GA ProcessModuleTest Typisierte Prozess-zu-Prozess-Links
registerRequiredDocument() process/ βœ… GA ProcessModuleTest Pflichtdokumentregistrierung pro Modell-Knoten
getMissingDocuments() process/ βœ… GA ProcessModuleTest PrΓΌft welche Pflichtdokumente fehlen

ProcessGraphRag

Feature Modul Status Tests Beschreibung
retrieve() process/ βœ… GA ProcessGraphRagTest VollstΓ€ndiger Graph-RAG-Kontext; DE/EN
retrieveForNode() process/ βœ… GA ProcessGraphRagTest Knoten-scoped RAG
summarizeVerwaltungsvorgang() process/ βœ… GA ProcessGraphRagTest JSON-Zusammenfassung fΓΌr UI/API
checkCompliance() process/ βœ… GA ProcessGraphRagTest Compliance-Check (Dokumente, SLA, Status)
findSimilarCases() process/ βœ… GA ProcessGraphRagTest Cosine/Jaccard-Γ„hnlichkeit; konfigurierbarer Threshold
buildAdminProcessingPrompt() process/ βœ… GA ProcessGraphRagTest Verwaltungsspezifischer LLM-Prompt (DE)

LlmProcessDescriptor

Feature Modul Status Tests Beschreibung
generateDescriptor() process/ βœ… GA LlmDescriptorTest JSON-Schema mit nodes/edges/compliance/sla
generateSystemPrompt() process/ βœ… GA LlmDescriptorTest System-Prompt DE/EN
buildConformancePrompt() process/ βœ… GA LlmDescriptorTest Conformance-Checking-Prompt

Version History:

  • 1.4.0-alpha (2026-01-06): 25 neue Alpha-Features (LLM, Performance, HA, Monitoring, Protocol)
  • 1.3.0 (2025-12-30): Umfassendes Update mit allen Features bis Dez 2025

Implementierungsstatus β€” Training, CDC & Updates (2026-04-12)

Training-Modul (v1.5)

Feature Header Status Beschreibung
TrainingPipeline::run() training/training_pipeline.h βœ… GA 6-stufige End-to-End LoRA-Pipeline aus ThemisDB-Collections
IncrementalLoRATrainer::train() training/incremental_lora_trainer.h βœ… GA INITIAL/RESUME/CONTINUE-Modes, INT8/INT4 Quantisierung
IncrementalLoRATrainer::resumeFromCheckpoint() training/incremental_lora_trainer.h βœ… GA SHA-256-verifiziertes Laden, Auto-Rollback
AutoLabeler::label() training/auto_labeler.h βœ… GA LLM-Annotation + Keyword-Extraktion, Konfidenz-Filter
KnowledgeGraphEnricher training/knowledge_graph_enricher.h βœ… GA KG-Kontext je Sample aus ThemisDB-Graph
LoraDataSelection training/lora_data_selection.h βœ… GA Aktives Lernen / Uncertainty Sampling
LoRACheckpointManager::save()/resume() training/lora_checkpoint_manager.h βœ… GA Atomares Speichern, SHA-256, Auto-Rollback, JSON-Manifest
ProvenanceTracker::record() training/provenance_tracker.h βœ… GA Lineage-Graph fΓΌr Gewichts-Γ„nderungen
ModalityParser training/modality_parser.h βœ… GA Multimodale Input-Normalisierung (Text/Bild/Audio)
LoRAAdapterMerger training/lora_adapter_merger.h βœ… GA Mergen mehrerer LoRA-Adapter (gewichtete Linearkombination)

CDC-Modul (v1.x)

Feature Header Status Beschreibung
Changefeed::listEvents() cdc/changefeed.h βœ… GA Sequenz-basiert, Key-PrΓ€fix-Filter, Long-Polling
Changefeed::subscribe() cdc/changefeed.h βœ… GA Push-Subscription mit SubscriptionFilter + cancel()
Changefeed::compactByKey() cdc/changefeed.h βœ… GA Manuelle Kompaktierung, removed_count + bytes_freed
Changefeed::redactByKeyPrefix() cdc/changefeed.h βœ… GA GDPR-Redaktion im Event-Log
Changefeed::watermarks() cdc/changefeed.h βœ… GA min_seq, max_seq, consumer_lag
CdcMaterializedView cdc/cdc_materialized_view.h βœ… GA Live-Sync MV via Changefeed
CdcAdmin cdc/cdc_admin.h βœ… GA Feed-Verwaltung, Reset, Export
ConsumerGroup cdc/consumer_group.h βœ… GA Multi-Consumer-Offset-Management
CrossCollectionStream cdc/cross_collection_stream.h βœ… GA Joins ΓΌber mehrere Changefeeds

Updates-Modul (v1.x)

Feature Header Status Beschreibung
ClusterUpdateManager::update() updates/cluster_update_manager.h βœ… GA Rolling-Update mit DRAIN/APPLY/HEALTHCHECK/ROLLBACK
CanaryRollout::deploy()/promote()/rollback() updates/canary_rollout.h βœ… GA Prozentbasierter Canary, automatischer Rollback bei Error-Rate
HotReloadEngine::reloadConfig()/reloadPlugin() updates/hot_reload_engine.h βœ… GA Zero-Downtime Konfigurations- und Plugin-Reload
InPlaceSchemaMigrator::execute() updates/in_place_schema_migrator.h βœ… GA Online-Schema-Migration ohne Downtime
BlueGreenDeployment::cutover()/rollback() updates/blue_green_deployment.h βœ… GA Instant Traffic-Switch Blue↔Green
DeltaUpdateEngine updates/delta_update_engine.h βœ… GA Inkrementelle Patch-Anwendung auf Datenbankebene
DependencyResolver updates/dependency_resolver.h βœ… GA Update-Reihenfolge basierend auf AbhΓ€ngigkeitsgraph
ManifestDatabase updates/manifest_database.h βœ… GA Versionierter Software-Manifest-Store
CoordinatedUpdateManager updates/coordinated_update_manager.h βœ… GA Multi-Cluster koordinierte Updates mit Quorum-Fencing

Implementierungsstatus β€” Auth, BiTemporal, Storage, LLM-Infrastruktur (2026-04-13)

Auth-Modul C++ API (v1.x)

Feature Header Status Beschreibung
JWTValidator::validate() auth/jwt_validator.h βœ… GA RS256/ES256/EdDSA, Blacklist, KID-Revokation
OAuthPKCEFlow::exchangeCode() auth/oauth_pkce_flow.h βœ… GA RFC 7636 PKCE, Authorization-Code-Flow
SAMLAuthenticator::validateResponse() auth/saml_authenticator.h βœ… GA SAML 2.0 SP, Attribut-Mapping, IdP-Zertifikat
WebAuthnAuthenticator::finishRegistration/Authentication() auth/webauthn_authenticator.h βœ… GA FIDO2/WebAuthn, PassKey-Support
LDAPAuthenticator::authenticate() auth/ldap_authenticator.h βœ… GA LDAPS, Connection-Pool, Group-Lookup
MFAAuthenticator::validateTOTP() auth/mfa_authenticator.h βœ… GA TOTP RFC 6238, Recovery Codes, Enrollment
SessionManager::validateAndRefresh() auth/session_manager.h βœ… GA Idle/Absolute-Timeout, Max-Sessions-Per-User
PasswordPolicy::validate() auth/password_policy.h βœ… GA Entropie-Scoring, HaveIBeenPwned-Check
FederatedIdentityManager::validateToken() auth/federated_identity_manager.h βœ… GA OIDC Multi-Realm, Token-Exchange
JwksValidator auth/jwks_validator.h βœ… GA JWKS-Endpoint, Auto-Refresh
JwtKeyRotationManager auth/jwt_key_rotation_manager.h βœ… GA Key-Rotation ohne Downtime
OidcProvider auth/oidc_provider.h βœ… GA OIDC Discovery, UserInfo-Endpoint
ApiKeyAuthenticator auth/api_key_authenticator.h βœ… GA Scoped API-Keys, Constant-Time-Vergleich
AuthRateLimiter auth/auth_rate_limiter.h βœ… GA Sliding-Window, Per-User/Per-IP
MtlsAuthenticator auth/mtls_authenticator.h βœ… GA Client-Zertifikat-Authentifizierung

Bi-Temporal-Modul (v1.x)

Feature Header Status Beschreibung
BiTemporalTable::insertWithValidTime() temporal/bi_temporal.h βœ… GA SQL:2011 Bi-Temporale EinfΓΌgung
BiTemporalTable::queryAsOf() temporal/bi_temporal.h βœ… GA AS OF Abfrage (System-Zeit + GΓΌltigkeits-Zeit)
BiTemporalTable::detectGaps() temporal/bi_temporal.h βœ… GA LΓΌcken-Erkennung im GΓΌltigkeits-Zeitraum
TemporalForeignKey::validate() temporal/bi_temporal.h βœ… GA Referentielle IntegritΓ€t ΓΌber ZeitrΓ€ume
BiTemporalJoin temporal/bitemporal_join.h βœ… GA SEQUENCED/NON_SEQUENCED/CURRENT Join
TemporalQueryEngine::execute() temporal/temporal_query_engine.h βœ… GA AS OF / FROM-TO / CONTAINED IN Abfragen
TemporalSnapshotManager temporal/snapshot_manager.h βœ… GA Snapshot-Handle fΓΌr PITR
SystemVersionedTable temporal/system_versioned_table.h βœ… GA Automatische System-Zeit-Verwaltung
IntervalTreeIndex temporal/interval_tree_index.h βœ… GA Effiziente Overlap-Suche
TemporalAggregator temporal/temporal_aggregator.h βœ… GA Zeitraum-aggregierte Aggregate (SUM/AVG/COUNT)

Storage/Backup-Modul C++ API (v1.x)

Feature Header Status Beschreibung
BackupManager::createFullBackup() storage/backup_manager.h βœ… GA Full Backup, AES-256-GCM, RAID-aware
BackupManager::createIncrementalBackup() storage/backup_manager.h βœ… GA Inkrementell seit letztem Backup
BackupManager::createDifferentialBackup() storage/backup_manager.h βœ… GA Differenziell seit letztem Full-Backup
BackupManager::restoreFromBackup() storage/backup_manager.h βœ… GA RAID-Shard-Rekonstruktion
BackupManager::archiveWAL() storage/backup_manager.h βœ… GA WAL-Archivierung fΓΌr PITR
PITRManager::restore() storage/pitr_manager.h βœ… GA Point-in-Time Recovery, Fortschritts-Callback
PITRManager::previewRestore() storage/pitr_manager.h βœ… GA Dry-Run ohne Γ„nderungen
TieredStorageManager::put()/get() storage/tiered_storage.h βœ… GA HOT/WARM/COLD transparent, Auto-Promotion
AdaptiveCompactionManager storage/adaptive_compaction.h βœ… GA Write/Read-Amplification-basierte Strategie
BlobStorageManager storage/blob_storage_manager.h βœ… GA Multi-Backend (FS/GCS/S3), Zero-Copy
ErasureCodingBackend storage/erasure_coding_backend.h βœ… GA Reed-Solomon, konfigurierbare ParitΓ€t

LLM-Infrastruktur (v1.x)

Feature Header Status Beschreibung
PagedKVCache::store()/sharePrefix() llm/paged_kv_cache.h βœ… GA vLLM Paged Attention, Prefix-Sharing
ContinuousBatchScheduler::step() llm/continuous_batch_scheduler.h βœ… GA Continuous Batching, Preemption, Priority
SpeculativeDecoder::decode() llm/speculative_decoder.h βœ… GA Draft-Model, 5-Token-Lookahead, Acceptance-Threshold
OpenAICompatAdapter llm/openai_compat_adapter.h βœ… GA /v1/chat/completions + Streaming
LoRARouter::route() llm/lora_router.h βœ… GA A/B-Testing, Canary-Rollout, Fallback
AdapterRegistry::registerAdapter() llm/adapter_registry.h βœ… GA Versionierter Adapter-Store, Provenance
ModelRouter::route() llm/model_router.h βœ… GA Rule-based Routing (Kontext/Tenant/Custom)
AdapterLoadBalancer llm/adapter_load_balancer.h βœ… GA GPU-Placement, JIT-Eviction, Migration
AdapterDeploymentManager llm/adapter_deployment_manager.h βœ… GA Blue/Green, Canary fΓΌr Adapter
LlamaResourceManager llm/llama_resource_manager.h βœ… GA llama.cpp Ressourcen-Lifecycle
GpuMemoryManager llm/gpu_memory_manager.h βœ… GA VRAM-Budget, OOM-Safe-Fail
EmbeddedLLM llm/embedded_llm.h βœ… GA In-Process LLM ohne Server

Implementierungsstatus β€” RAG Advanced, Sharding C++ API, Query/Index Engine (2026-04-13)

RAG-Modul v2 β€” Erweiterte Pipeline-Komponenten

Feature Header Status Beschreibung
AgenticRAG::run() rag/agentic_rag.h βœ… GA Iterativer Retrieve-then-Reason Agent (max_iterations, quality_threshold, cancel)
AgenticRAGFactory rag/agentic_rag.h βœ… GA Factory fΓΌr Standard- und Custom-Konfigurationen
MultiStepRAGOrchestrator::run() rag/multi_step_rag.h βœ… GA Decompose-then-Retrieve (max_steps, LLM-Decomposition, MergeStrategy)
MultiModalRAG::query() rag/multimodal_rag.h βœ… GA TEXT/IMAGE/TABLE/CODE/AUDIO; OCR-Support
RAGContextAssembler::assemble() rag/rag_context_assembler.h βœ… GA Token-Budget-Management, Dedup, Ordering
DistributedRAGEvaluator::evaluate() rag/distributed_rag_evaluator.h βœ… GA Parallele Multi-Judge-Evaluierung, Quorum, AggregationStrategy
DistributedEvaluatorFactory rag/distributed_rag_evaluator.h βœ… GA Builder fΓΌr Distributed-Judge-Cluster

Sharding-Modul C++ API (v1.x)

Feature Header Status Beschreibung
AdaptiveShardRouter::route() sharding/adaptive_shard_router.h βœ… GA Lernender Router mit Exploration/Exploitation, Feedback-Loop
ConsistentHashRing::getShardForKey() sharding/consistent_hash.h βœ… GA Virtueller Knoten-Ring, 150 vNodes/Shard, getNShardsForKey
CrossShardTransaction::commit() sharding/cross_shard_transaction.h βœ… GA 2PC + WAL, IsolationLevel SERIALIZABLE/SNAPSHOT/READ_COMMITTED
EpochFencingManager::checkFence() sharding/epoch_fencing.h βœ… GA Stale-Leader-Schutz, Lease-Management, advanceEpoch
HotShardSplitPolicy sharding/auto_rebalancer.h βœ… GA ML-prΓ€diktive Shard-Aufteilung, QPS-Threshold
DataMigrator::migrate() sharding/data_migrator.h βœ… GA Live-Migration mit Dual-Write, Verifikation, Rate-Limiting
AutoRecoveryManager sharding/auto_recovery_manager.h βœ… GA Automatische Shard-Recovery nach Ausfall
GossipConfigManager sharding/gossip_config_manager.h βœ… GA Gossip-basierte Konfigurationsverteilung

Query Engine C++ API (v1.x)

Feature Header Status Beschreibung
AdaptiveQueryStats::recordExecution() query/adaptive_optimizer.h βœ… GA Query-Statistiken akkumulieren, KardinalitΓ€tsfehler erkennen
AdaptivePlanSelector::selectPlan() query/adaptive_optimizer.h βœ… GA KEEP/SWITCH/PARALLEL_TEST basierend auf Feedback
DistributedQueryCostModel query/adaptive_optimizer.h βœ… GA Cross-Shard-Join-Kosten, Partition Pruning
MultiIndexOptimizer query/adaptive_optimizer.h βœ… GA Optimale Index-Kombination fΓΌr komplexe PrΓ€dikate
AdaptiveJoin::executeJoin() query/adaptive_join.h βœ… GA HASH/SORT_MERGE/INDEX/NESTED_LOOP/GRACE_HASH, Runtime-Wahl
ApproximateCountDistinct (HyperLogLog) query/approximate_aggregator.h βœ… GA Β±2 % Fehler, merge fΓΌr verteilte Aggregation
ApproximatePercentile (T-Digest) query/approximate_aggregator.h βœ… GA p50/p95/p99, merge-fΓ€hig

Index-Modul C++ API (v1.x)

Feature Header Status Beschreibung
IndexManager index/index_manager.h βœ… GA Koordiniert Vector/Secondary/Graph-IndexManager
InvertedIndex::search() index/inverted_index.h βœ… GA BM25, Stemming, Stopwords, RocksDB-backed
AdvancedVectorIndex index/advanced_vector_index.h βœ… GA AUTO-Type (HNSW/IVF/SQ/PQ), WorkloadType-aware
DistributedVectorIndex index/distributed_vector_index.h βœ… GA Scatter-Gather K-NN, ConsistentHash, Replikation
BinaryQuantizer index/binary_quantizer.h βœ… GA 1-bit Quantisierung, FAISS-Integration
IndexSuggestionEngine::recommend() index/adaptive_index.h βœ… GA Auto-Empfehlung basierend auf Query-Patterns + SelektivitΓ€t
QueryPatternTracker index/adaptive_index.h βœ… GA Scan-Latenz, Rows-scanned, Cache-Miss aufzeichnen
SelectivityAnalyzer index/adaptive_index.h βœ… GA Distinct-Values, Histogramm, SelektivitΓ€ts-Score

Implementierungsstatus β€” Server/API, Metadata, Performance, Plugins, UserStorage (2026-04-13 session 4)

Server/API-Modul (v1.x)

Feature Header Status Beschreibung
APIGateway::registerHandler() server/api_gateway.h βœ… GA Einheitlicher HTTP-Einstiegspunkt; Route-Registrierung, Load-Shedding, Deprecation-Header
AdaptiveRateLimiter::allowRequest() server/adaptive_rate_limiter.h βœ… GA Feedback-basiertes Rate-Limiting, Burst-Toleranz, Overload-Threshold
AuthMiddleware::authenticate() server/auth_middleware.h βœ… GA JWT/GSSAPI/API-Key/USB-Token; Scope-PrΓΌfung
DistributedGateway / ConsistentHashRing server/distributed_gateway.h βœ… GA Cluster-Routing, Circuit-Breaker, Failover, 200 vNodes
AsyncJobApiHandler / AsyncJobRegistry server/async_job_api_handler.h βœ… GA Async-Job-Queue (PENDING/RUNNING/COMPLETED/FAILED), prune()
GrpcApiServer::start() api/grpc_server.h βœ… GA gRPC Port 8771, TLS, max-message-size, registerService
GraphQLSchemaBuilder::build() api/graphql_schema_builder.h βœ… GA Type/Query/Mutation-Registrierung, Schema-Validierung
IWebSocketFrameCallback api/websocket_handler.h βœ… GA WebSocket-Frame-Callbacks (Text/Binary/Ping/Close), CloseCode

Metadata/Schema-Modul (v1.x)

Feature Header Status Beschreibung
SchemaManager::createTable() metadata/schema_manager.h βœ… GA Tabellen/Relationships/Indexes; AdaptiveTTL-Konfiguration
InformationSchema::getTables() metadata/information_schema.h βœ… GA SQL-kompatible IS: tables/columns/statistics/referential_constraints
SchemaVersionManager::persistChange() metadata/schema_version_manager.h βœ… GA WAL-backed Migrations; rollback; AuditLog-Integration
DistributedMetadataCatalog::publishSchema() metadata/distributed_catalog.h βœ… GA Cluster-weite Schema-Verteilung via Consensus
SchemaConsistencyChecker::check() metadata/schema_consistency_checker.h βœ… GA Schema↔Daten-Konsistenz; Auto-Repair; dry_run
IndexRecommender metadata/index_recommender.h βœ… GA Empfiehlt Indexes basierend auf Query-Statistiken
SchemaAuditLog metadata/schema_audit_log.h βœ… GA Append-only Schema-Γ„nderungsprotokoll
ERDiagramExporter metadata/er_diagram_exporter.h βœ… GA ER-Diagramm-Export (Mermaid/PlantUML)

Performance-Internals (v1.x)

Feature Header Status Beschreibung
AdaptiveQueryCompiler::compile() performance/adaptive_query_compiler.h βœ… GA JIT-Γ€hnliche Query-Kompilierung; Hot-Query-Cache
IntelligentPrefetcher::predict_next() performance/intelligent_prefetcher.h βœ… GA ML-basiertes Prefetching (SEQUENTIAL/STRIDED/RANDOM/POINTER_CHASE); Hardware-Prefetch
WorkloadPredictor::forecast() performance/workload_predictor.h βœ… GA LSTM/EMA Lastvorhersage; ScaleDirection (UP/DOWN/STABLE); Replikationsempfehlung
HardwareAccelerator::execute() performance/hardware_accelerator.h βœ… GA CPU/CUDA/OpenCL/NPU/FPGA Dispatch; OperatorType-Auswahl
LockFreeRingBuffer<T> performance/lockfree_metrics_buffer.h βœ… GA SPSC Lock-Free FIFO; tryPush/tryPop; dropped_count
WorkloadPredictor::getScaleRecommendation() performance/workload_predictor.h βœ… GA Konkrete Replikations-Empfehlung mit Konfidenz
WorkloadAdaptiveOptimizer::classify_workload() performance/workload_adaptive_optimizer.h βœ… GA Heuristische Klassifikation (OLTP/OLAP/MIXED/GRAPH/VECTOR/TIMESERIES); 512-Query Rolling Window
WorkloadAdaptiveOptimizer::get_strategy() performance/workload_adaptive_optimizer.h βœ… GA Per-Workload-Strategie: JIT, Thread-Pool, Cache-MB, Join-Algorithmus, Index-Typ; Predictive Scaling
WorkloadAdaptiveOptimizer::enable_auto_adapt() performance/workload_adaptive_optimizer.h βœ… GA Hintergrund-Adaptionsloop (konfigurierbares Intervall); AdaptationCallback

Plugin-System (v1.x)

Feature Header Status Beschreibung
PluginManager::loadPlugin() plugins/plugin_manager.h βœ… GA Signatur-Verifikation, Hot-Reload, PluginReloadPhase-Callbacks
WasmHostAPI plugins/wasm_host_api.h βœ… GA WASM-Plugins (Wasmtime/Wasmer/Wasm3); Host-Function-ABI
PluginHealthMonitor::start() plugins/plugin_health_monitor.h βœ… GA Auto-Disable + Recovery; MonitoringEvent-Callbacks; Health-Score
SignedPluginRepository plugins/signed_plugin_repository.h βœ… GA OCI-Registry-Integration fΓΌr signierte Plugin-Pakete
SelfHealingPlugin plugins/self_healing_plugin.h βœ… GA Automatische Neustart-Logik bei Crash
PluginDependencyResolver plugins/plugin_dependency_resolver.h βœ… GA Topologische Sortierung + Zyklenerkennung fΓΌr Plugin-Deps

User Storage Encrypted (v1.x)

Feature Header Status Beschreibung
MultiLevelEncryptedStorage::mount() user_storage_encrypted/multi_level_storage.hpp βœ… GA FUSE-basierter Multi-Level-VerschlΓΌsselungsspeicher; SecurityLevel LOW/MEDIUM/HIGH
KeyRotationScheduler::scheduleRotation() user_storage_encrypted/key_rotation_scheduler.hpp βœ… GA Geplante + manuelle SchlΓΌsselrotation; IRotationStore-Persistenz
GocryptfsBackend::mount() user_storage_encrypted/gocryptfs_backend.hpp βœ… GA Gocryptfs FUSE-Backend; mount/unmount/isMounted
Argon2idKeyDerivationService::deriveKey() user_storage_encrypted/key_derivation_service.hpp βœ… GA Argon2id KDF (OWASP-Empfehlung); memory/iterations/parallelism
reconcileStaleMounts() user_storage_encrypted/multi_level_storage.hpp βœ… GA AufrΓ€umen verwaister FUSE-Mounts beim Systemstart

Implementierungsstatus β€” Geo Extended, Timeseries Internals, AQL Advanced, Scheduler (2026-04-13 session 5)

Geo-Modul Erweiterungen (v2.x)

Feature Header Status Beschreibung
GeoRTree::bulkLoad() / queryBBox() / queryKNN() geo/geo_rtree.h βœ… GA R*-Tree Spatial Index; Bulk-Load, BBox-Query, K-NN
SpatialJoinIterator::advance() geo/spatial_join.h βœ… GA Lazy Iterator; INTERSECTS/WITHIN_DISTANCE/CONTAINS/OVERLAPS
TileServer::getTile() geo/tile_server.h βœ… GA Mapbox Vector Tiles (MVT/Protobuf); Layer-Config; Geometrie-Vereinfachung
geoDbscan() / geoKMeans() geo/geo_clustering.h βœ… GA DBSCAN (eps_m, min_points) + K-Means (k, max_iter); Noise-Points
RasterGrid::sample() / generateHeatmap() geo/raster.h βœ… GA Bilinear-Sampling, Gaussian-Heatmap, normalize

Timeseries-Internals (v1.9.x)

Feature Header Status Beschreibung
TimeSeriesStore::put() / query() / aggregate() timeseries/timeseries.h βœ… GA Core-KV-Store; Range-Query + Window-Aggregation
Hypertable::insertBatch() / compressChunk() timeseries/hypertable.h βœ… GA Auto-Partitionierung nach Zeit; Gorilla+Zstd Chunk-Kompression
ContinuousAggWatermarkStore / DistributedAggregateCoordinator timeseries/continuous_agg.h βœ… GA Inkrementelle Materialisierung; Rollup-Hierarchien; Watermark
BitWriter / BitReader (Gorilla) timeseries/gorilla.h βœ… GA Delta-of-Delta Timestamp + XOR Value Encoding
DownsamplingPipeline::addPolicy() timeseries/downsampling.h βœ… GA Mehrstufiges Downsampling; AggFunc-Auswahl; Retention
RetentionManager::startAsync() timeseries/retention.h βœ… GA Soft+Hard Delete; StagedDeletion; Audit-Trail
TsStreamCursor::nextBatch() timeseries/ts_stream_cursor.h βœ… GA Batch-Streaming-Iterator ΓΌber Zeitreihen
PrometheusRemoteWriteHandler::handle() timeseries/prometheus_remote_write.h βœ… GA Prometheus Remote-Write-Endpoint; Grafana-kompatibles Remote-Read

AQL Advanced API (v1.x)

Feature Header Status Beschreibung
AQLQueryBuilder::from() / build() aql/aql_query_builder.h βœ… GA Fluent Builder; FROM/FILTER/SORT/LIMIT/JOIN/SELECT
AQLQueryValidator::validate() aql/aql_query_validator.h βœ… GA Syntaktisch + semantisch; ERROR/WARNING/INFO; Line/Column
AQLOptimizerAdvisor::analyze() aql/aql_optimizer_advisor.h βœ… GA Index-Empfehlungen; Rewrite-VorschlΓ€ge; estimated_speedup
AQLConversationContext::ask() aql/aql_conversation_context.h βœ… GA Multi-Turn NLβ†’AQL; Schema-Kontext; Auto-Correct
AQLMigrationAssistant::migrate() aql/aql_migration_assistant.h βœ… GA SQLβ†’AQL Migrationshilfe; BLOCKING/WARNING Issues
AQLAgent::run() aql/aql_agent.h βœ… GA LLM-gesteuerter DB-Agent; Tool-Registrierung; Reasoning-Steps

Scheduler-Internals (v1.x)

Feature Header Status Beschreibung
TaskScheduler::addTask() scheduler/task_scheduler.h βœ… GA CRON/INTERVAL/CDC/MANUAL/WEBHOOK; 5/6-Feld, Timezone, CDC-Trigger
DistributedTaskCoordinator::start() scheduler/distributed_task_coordinator.h βœ… GA Leader-Election; One-Runner-Per-Cluster; LeaderChange-Callback
TaskAnomalyDetector::analyzeTask() scheduler/task_anomaly_detector.h βœ… GA Frequenz/Pattern/Resource/Failure-Rate-Erkennung; Callback
TaskAuditManager::query() / exportTo() scheduler/task_audit_manager.h βœ… GA VollstΓ€ndiger Audit-Trail; JSON/CSV/Parquet-Export; 90-Tage-Retention
HybridRetentionManager::startAsync() scheduler/hybrid_retention_manager.h βœ… GA 3-Stufen: Gorilla (0–7d) + Downsampling (7–365d) + Tages-Agg (>365d)

Implementierungsstatus β€” LLM Advanced AI, Replication, Content Module, Acceleration (2026-04-13 session 6)

LLM Advanced AI (v2.x)

Feature Header Status Beschreibung
AiOrchestrator::run() llm/ai_orchestrator.h βœ… GA Multi-Mode Pipeline: RAG/AGENTIC/CRITIQUE; ModeSpec, BudgetSpec, SafetySpec, JudgeSpec
AsyncInferenceEngine::submitAsync() llm/async_inference_engine.h βœ… GA Streaming Token-Callback; DROP_OLDEST/BLOCK Backpressure; Dedup-Cache
InferenceEngineEnhanced llm/inference_engine_enhanced.h βœ… GA Multi-Model LB (ROUND_ROBIN/LEAST_LOADED/FASTEST); Circuit Breaker; ModelResourceQuota
InlineTrainingEngine::stepAsync() llm/inline_training_engine.h βœ… GA On-the-Fly LoRA Fine-Tuning; AdamW/LION Optimizer; Cosine LR Scheduler
ConstitutionalReasoningEngine::reason() llm/constitutional_reasoning_engine.h βœ… GA Prinzipienbasiert; max_revision_rounds; hard_block; HHH-Prinzipien
EthicsAwareConfidenceDetector::evaluate() llm/ethics_aware_confidence_detector.h βœ… GA Bias-Kategorien; Token-Konfidenz; Ethics + Uncertainty Combined Score

Replication Multi-Master & CRDT (v1.x)

Feature Header Status Beschreibung
ReplicationManager::addReplica() replication/replication_manager.h βœ… GA PRIMARY/SECONDARY/ARBITER; SYNC/ASYNC/SEMI_SYNC; Lag-Monitoring
VectorClock::happensBefore() / isConcurrent() replication/multi_master_replication.h βœ… GA Kausalordnung; NebenlΓ€ufigkeitserkennung; merge()
HybridLogicalClock::now() replication/multi_master_replication.h βœ… GA Wall + Logical Timestamp; TrueTime-Γ€hnlich
ConflictResolver::resolve() replication/multi_master_replication.h βœ… GA LWW/FWW/MERGE/CUSTOM; CONCURRENT_WRITE/DELETE_UPDATE/SCHEMA_CONFLICT
GrowOnlyCounter / PNCounter / MVRegister (CRDT) replication/crdt_types.h βœ… GA Kommutative CRDT-Merge; G-Counter, PN-Counter, Multi-Value Register
ReplicationSlot::advance() / drop() replication/replication_slot.h βœ… GA Persistent WAL-Slots; LSN-Fortschritt; PAUSE/RESUME

Content-Modul (v1.x)

Feature Header Status Beschreibung
ContentManager::ingestRawBlob() Pipeline 10 Stages content/content_manager.h βœ… GA MIME-Auto, Malware-Scan, pHash-Dedup, OCR, Chunking, Embed, LLM-Tagging
EmbeddingPipeline::embed() content/embedding_pipeline.h βœ… GA Batch-Embedding; normalize; Failure-Callback; Device-Auswahl
AsyncIngestionWorker::enqueue() content/async_ingestion_worker.h βœ… GA 4 Worker-Threads; QUEUED/RUNNING/FAILED/RETRYING; Priority-Queue
ContentSecurity::scan() content/content_security.h βœ… GA Malware/ZIP-Bomb/Abuse; sanitize_error_messages; block_on_malware
IContentProcessor Plugin-Interface content/content_processor.h βœ… GA Eigene MIME-Typen; ExtractionResult (text/language/geo_data/media_data)
ContentPolicy MIME-Whitelist/Blacklist content/content_policy.h βœ… GA allowed_mime_types; enable_deduplication; ocr_enabled; isAllowed()

Acceleration-Internals (v1.x)

Feature Header Status Beschreibung
ComputeBackend::executeSimilarityKernel() acceleration/compute_backend.h βœ… GA FP32/FP16/BF16/INT8/INT4; CUDA/HIP/Vulkan/OpenCL/DirectX; Health-Status
ANNKernelFallbackDispatcher::search() acceleration/kernel_fallback_dispatcher.h βœ… GA Fallback-Kette CUDAβ†’HIPβ†’Vulkanβ†’CPU; RetryPolicy; backend_used
GeoKernelFallbackDispatcher::computeDistancesBatch() acceleration/kernel_fallback_dispatcher.h βœ… GA Haversine/Vincenty Batch; GPU-Fallback auf CPU
VecKnnPipeline::search() / searchBatch() acceleration/vec_knn.h βœ… GA IVF nprobe + HNSW ef_search; Distance-Cache; AQL-Filter
DeviceManager::getDevices() acceleration/device_manager.h βœ… GA Multi-GPU-Inventar; VRAM/Compute-Units; hasGPU(); logDeviceInfo()
CudaBuffer<T> / VulkanBuffer<T> RAII acceleration/raii/cuda_raii.h βœ… GA Automatische GPU-Speicherfreigabe; upload/download

ThemisDB 1.9.0-beta Β· Home Β· Module-Index Β· GitHub Β· Issues

ThemisDB Wiki

🏠 Overview

πŸ“š Compendium

πŸš€ Getting Started

πŸ“– Tutorials

πŸ“— User Guide

βš™οΈ Operations & Security

πŸ“Ÿ Ops Runbooks

πŸ—οΈ Architecture

πŸ“ ADRs

πŸ”§ Contributing

πŸ“‹ Governance

πŸ” Audit

🧩 Plugins

πŸ”Œ Adapters

πŸ’‘ Examples

πŸ“¦ Client SDKs

πŸŽ“ Training

πŸ› οΈ Tools

πŸ€– Developer LLM Wiki

Clone this wiki locally