Kova — moteur d'exécution persistante pour agents IA
Moteur d'agents WAL-First écrit en Rust, reprise automatique après crash, ordonnancement en 3μs
Qu’est-ce que Kova ?
Kova est l’infrastructure d’agents IA au cœur de Lurus : un moteur d’exécution persistante haute performance construit en Rust, qui résout la question de savoir comment un agent peut s’exécuter de manière fiable sur de longues durées, restaurer son état après un crash et coordonner des workflows complexes. Les frameworks traditionnels (LangChain, CrewAI) s’exécutent en mémoire et perdent leur état dès que le processus se termine ; Kova adopte une architecture orientée WAL (Write-Ahead Log)WALWrite-Ahead Log (journal d'écriture anticipée). Tout changement d'état est d'abord écrit dans le journal puis exécuté, garantissant une reprise après crash à partir du journal.En savoir plus →, où chaque étape d’exécution est enregistrée de façon persistante, ce qui permet, même après un crash, de reprendre précisément au point d’interruption — sans rappeler le LLM, sans perdre la progression et sans générer de coûts supplémentaires.
Indicateurs clés
docs/benchmark-report.md), débit de 315K ops/s, zéro dépendance à un service externe.Pourquoi choisir Kova
Persistance WAL-First, ordonnancement à la microseconde, déploiement sans dépendance, quatre modes d’intégration.
Reprise après crash via WAL
Journal en écriture anticipée à chaque étape + vérification CRC32 ; rejeu depuis le point d’interruption après un crash, sans rappeler le LLM
Latence d’ordonnancement de 3μs
Pipeline complet FIFO à 3.17μs (benchmark Criterion), débit de 315K ops/s
Zéro dépendance externe
Aucun besoin de Redis / Postgres ; un simple fichier WAL local suffit à fonctionner
Quatre modes d’intégration
Rust SDK / gRPC / REST / MCP, modularité sur un workspace de 21 crates
Persistance WAL-First
Toute modification d’état écrit d’abord dans le WAL avant exécution ; en cas de crash, le rejeu s’effectue depuis le WAL :
Décision de l’agent — le moteur détermine l’action suivante
Écriture WAL (CRC32) — enregistrement persistant + somme de contrôle contre la corruption
Exécution — appel réel de l’outil / du LLM
Confirmation de l’achèvement — l’étape est marquée comme aboutie ; en cas de crash, les étapes non confirmées sont automatiquement rejouées
La vérification CRC32 protège contre la corruption ; un tampon circulaire en puissance de 2 (Power-of-2) exploite efficacement le stockage ; l’ordre de verrouillage Buffer → Queue → Txn est strictement garanti pour éliminer tout interblocage.
Orchestration d’agents
| Mode | Description | Cas d’usage |
|---|---|---|
| Agent unique | Exécution autonome d’une tâche | Automatisation simple |
| Workflow | Exécution ordonnée en plusieurs étapes | Pipelines de données, processus d’approbation |
| Intelligence collective (Swarm) | Collaboration autonome entre plusieurs agents | Recherche complexe, simulation multi-rôles |
Écosystème d’outils et multi-modèle
Outils intégrés (fichiers / HTTP / base de données / Shell), MCPMCPModel Context Protocol (protocole de contexte des modèles). Standard ouvert permettant aux agents IA d'appeler des outils et sources de données externes de façon unifiée.En savoir plus → (connexion à n’importe quel service d’outils compatible MCP, voir le catalogue d’intégrations), A2AA2AProtocole Agent-to-Agent, qui permet à plusieurs agents de communiquer directement, de déléguer des tâches et d'échanger des informations. (communication directe et délégation de tâches entre agents), outils personnalisés (extensions en Rust ou via API REST).
Accès, via l'API Lurus, à tous les principaux LLM (DeepSeek au quotidien / GPT-4o pour le raisonnement / Claude pour les textes longs / Gemini pour le multimodal), avec basculement dynamique selon la tâche à l’exécution.
Aperçu de l’architecture
Intégration REST/SDK/gRPC/MCP · ordonnancement par Kova Core · persistance et reprise via WAL.
Kova REST API (Axum: 35+ endpoints, WebSocket)
→ Kova Core: Agent Engine(单/多 Agent) + Workflow(有序编排)
→ WAL + Ring Buffer(持久化状态管理 CRC32)
子 crate: kova-llm / kova-tools / kova-mcpKova est un workspace de 21 crates Rust, 178 284 lignes de code, plus de 1 565 tests (concurrence loom / proptest / chaos) + 4 cibles de fuzzing. Actuellement en pré-version v0.2.0 (en route vers la 1.0.0-beta.1), avec des lints stricts pleinement activés (#[deny(clippy::unwrap_used, clippy::panic, missing_docs)]).
Cas d’usage adaptés
| Cas d’usage | Atout de Kova |
|---|---|
| Agents s’exécutant sur de longues durées | Persistance WAL, reprise automatique après crash |
| Workflows complexes | Orchestration multi-étapes, branches conditionnelles, exécution parallèle |
| Collaboration multi-agents | Mode Swarm, communication directe entre agents |
| Déploiement en entreprise | Performance de Rust, faible consommation de ressources, sans pauses GC |
| Intégration d’outils MCP | Prise en charge native du Model Context Protocol |
| Contextes sensibles à la sécurité | Chiffrement optionnel (SM4/AES), vérification d’intégrité HMAC du WAL |
Prise en main par rôle
Comparaison avec d’autres frameworks d’agents
| Capacité | LangChain | CrewAI | AutoGen | Kova |
|---|---|---|---|---|
| Langage | Python | Python | Python | Rust |
| Persistance d’état | Aucune (externe requise) | Aucune | Aucune | WAL-First |
| Reprise après crash | Aucune | Aucune | Aucune | Reprise automatique |
| Performance | Moyenne | Moyenne | Moyenne | Très élevée |
| Efficacité mémoire | Faible | Faible | Faible | Très élevée |
| Prise en charge MCP | Tierce | Aucune | Aucune | Native |
| Protocole A2A | Aucun | Aucun | Aucun | Natif |
| Capacités de chiffrement | Aucune | Aucune | Aucune | SM4-GCM / ChaCha20 |
| Multi-protocole | Aucun | Aucun | Aucun | Quatre modes d’intégration : Rust SDK / gRPC / REST / MCP |
| Forme de déploiement | Processus Python | Processus Python | Processus Python | Binaire unique / conteneur / bibliothèque embarquée |