Back to flin
flin

Le modèle de stockage EAVT

Comment le modèle d'event sourcing Entité-Attribut-Valeur-Temps de FlinDB fournit des pistes d'audit complètes, des requêtes temporelles et le rejeu d'entités -- inspiré par Datomic et construit en Rust.

Juste Thales Gnimavo & Claude | March 26, 2026 3 min flin
EN/ FR/ ES
flinflindbeavtstoragearchitecture

La plupart des bases de données stockent l'état courant. FlinDB stocke l'historique complet. Chaque sauvegarde, chaque mise à jour, chaque suppression est enregistrée comme un événement. L'état courant est dérivé du journal d'événements.

C'est le modèle EAVT : Entité-Attribut-Valeur-Temps. Chaque fait dans la base de données est un tuple indiquant quelle entité a changé, quel attribut a changé, quelle est la nouvelle valeur, et quand cela s'est produit.

L'enregistrement EAVT

rustpub struct EavtRecord {
    pub event_id: u64,
    pub timestamp: i64,
    pub version: u64,
    pub entity_type: String,
    pub entity_id: u64,
    pub operation: EventOperation,
    pub changes: Vec<FieldChange>,
    pub user_id: Option<u64>,
    pub reason: Option<String>,
    pub correlation_id: Option<String>,
}

pub struct FieldChange {
    pub field_name: String,
    pub old_value: Option<Value>,
    pub new_value: Option<Value>,
}

pub enum EventOperation {
    Created, Updated, Deleted, Destroyed, Restored,
}

Le journal d'événements

Le EventLog maintient tous les enregistrements EAVT avec plusieurs index pour des requêtes efficaces :

rustpub struct EventLog {
    entries: Vec<EavtRecord>,
    by_entity: HashMap<(String, u64), Vec<usize>>,
    by_timestamp: BTreeMap<i64, Vec<usize>>,
    next_event_id: u64,
}

Trois structures de données servent trois patterns d'accès : accès séquentiel pour le rejeu complet, recherche O(1) pour l'historique d'entité, et requêtes par plage pour le filtrage temporel.

Rejeu d'entité

La capacité la plus puissante du modèle EAVT est le rejeu d'entité -- reconstruire l'état d'une entité à n'importe quel moment en rejouant les événements :

rustpub fn replay_to(&self, entity_type: &str, id: u64, at: i64) -> Option<EntityInstance>

C'est ainsi que l'opérateur de requête temporelle de FLIN (@) fonctionne sous le capot. Quand un développeur écrit :

flinuser @ "2026-01-01"

ZeroCore appelle replay_to("User", user_id, timestamp_for("2026-01-01")).

La syntaxe Watch

La session 168 a aussi implémenté la syntaxe watch, qui permet au code FLIN de s'abonner aux changements d'entités. Le registre de watchers dans la VM se connecte au magasin d'événements -- quand un enregistrement EAVT est généré et correspond aux conditions d'un watcher, le callback du watcher est invoqué.

C'est ainsi que FlinDB fournit des abonnements en temps réel sans configuration WebSocket ni système de messagerie externe.

Pourquoi EAVT plutôt que le stockage traditionnel

Piste d'audit complète. Chaque changement est enregistré avec qui l'a fait, quand, et quelle était la valeur précédente.

Les requêtes temporelles sont gratuites. Demander « quel était l'état de cette entité le 15 janvier ? » est une opération de rejeu.

Le débogage est trivial. On peut interroger le journal d'événements et voir exactement ce qui a changé, quand et par qui.

Le modèle EAVT est le fondement architectural qui transforme « save user » d'une simple opération de données en un événement temporel, auditable et rejouable.


Ceci est la partie 10 de la série « How We Built FlinDB ».

Navigation de la série : - [063] Transactions and Continuous Backup - [064] Graph Queries and Semantic Search - [065] The EAVT Storage Model (vous êtes ici) - [066] Database Encryption and Configuration - [067] Tree Traversal and Integration Testing

Share this article:

Responses

Write a response
0/2000
Loading responses...

Related Articles

Thales & Claude deblo

Le prompt disait de l'annoncer. Le modèle ne l'a pas fait. Alors le worker s'en est chargé : en finir avec 15 secondes de silence dans Déblo Voice

Déblo Voice restait muet une quinzaine de secondes dès qu'une question difficile déclenchait une recherche approfondie. Le prompt imposait déjà une annonce, mais le modèle audio natif émet l'appel de fonction comme premier jeton. Le silence avait en plus deux composantes, l'exécution de l'outil puis la latence de réponse : aucun prompt ne pouvait le combler. Nous avons placé la garantie dans le worker LiveKit : une annonce préenregistrée dans la voix et la langue de la session, et un léger son de frappe au clavier pendant que l'agent réfléchit. Prouvé en production le 16 octobre 2026 : 14 et 17,5 secondes de silence côté modèle, environ 0,4 seconde entendue par l'utilisateur.

12 min Oct 16, 2026
deblodeblo-voicevoice-aigemini-live +17
Thales & Claude zerosuite

Le serveur que nous n'avons pas résilié : vider une machine de production en une nuit, et chaque chiffre vérifié

Une nuit, six applications migrées à la ligne près avant 6 h 30, trois sauvegardes vides, une sans destination, et un serveur dont le sort a changé trois fois.

19 min Oct 2, 2026
caspclaude-codeclaude-opus-5.5infrastructure +10
Thales & Claude zerosuite

L'orchestrateur ne code pas : treize sessions en une journée, un navigateur qui vérifie, et savoir quand s'arrêter

Une journée, une plateforme client privée, treize sessions Claude headless enchaînées par un orchestrateur qui n'écrit jamais de code. Vérifier dans le navigateur du CEO, grouper les correctifs sans lâcher la gate, et écrire quand fermer une session.

19 min Sep 30, 2026
caspclaude-codeclaude-opus-5.5multi-session +12