feat(cluster): carry an LSN-versioned read-set on the Calvin TxClass

Add versioned_reads to TxClass so a transaction's point/predicate read
observations, each stamped with the responding shard's write-LSN
watermark, travel on the replicated Calvin transaction for future
commit-time optimistic-concurrency validation. The field is additive
(map-encoded with a default) so TxClass bytes already on the sequencer
Raft log decode unchanged.

Carrying that read identity over the wire requires KeyRepr — row
identity within a collection — to be Send + Sync and shared across
planes rather than owned by the nodedb crate's Control-Plane types, so
it moves to nodedb-types alongside the other plane-neutral wire types.
Call sites across nodedb, nodedb-cluster, and nodedb-cluster-tests
update to the new import path and threaded constructor argument.

Author: farhan-syah

nodedb-cluster-tests/tests/calvin_3node_normal.rs

@@ -21,7 +21,7 @@ use std::time::Duration;
 
 use nodedb_cluster::calvin::{
     sequencer::{SequencerConfig, new_inbox},
-    types::{EngineKeySet, ReadWriteSet, SequencedTxn, SortedVec, TxClass},
+    types::{EngineKeySet, ReadWriteSet, SequencedTxn, SortedVec, TxClass, VersionedReadSet},
 };
 use nodedb_types::{
     TenantId,
@@ -68,6 +68,7 @@ fn make_multishard_txclass() -> (TxClass, u32, u32) {
         vec![],
         TenantId::new(1),
         None,
+        VersionedReadSet::default(),
     )
     .expect("valid TxClass");
     (tx, va, vb)

nodedb-cluster-tests/tests/calvin_3node_shard_failover.rs

@@ -45,7 +45,7 @@ use std::time::Duration;
 
 use nodedb_cluster::calvin::{
     sequencer::{SequencerConfig, new_inbox},
-    types::{EngineKeySet, ReadWriteSet, SequencedTxn, SortedVec, TxClass},
+    types::{EngineKeySet, ReadWriteSet, SequencedTxn, SortedVec, TxClass, VersionedReadSet},
 };
 use nodedb_types::{
     TenantId,
@@ -91,6 +91,7 @@ fn make_txclass(surr_a: u32, surr_b: u32) -> TxClass {
         vec![],
         TenantId::new(1),
         None,
+        VersionedReadSet::default(),
     )
     .expect("valid TxClass")
 }

nodedb-cluster-tests/tests/calvin_e2e_ollp.rs

@@ -39,7 +39,7 @@ use std::time::Duration;
 
 use nodedb_cluster::calvin::{
     sequencer::{SequencerConfig, new_inbox},
-    types::{EngineKeySet, ReadWriteSet, SequencedTxn, SortedVec, TxClass},
+    types::{EngineKeySet, ReadWriteSet, SequencedTxn, SortedVec, TxClass, VersionedReadSet},
 };
 use nodedb_types::{
     TenantId,
@@ -101,6 +101,7 @@ fn make_ollp_tx_class(
         vec![],
         TenantId::new(1),
         None,
+        VersionedReadSet::default(),
     )
     .expect("valid multi-vshard OLLP TxClass")
 }

nodedb-cluster-tests/tests/calvin_e2e_pgwire.rs

@@ -22,7 +22,7 @@ use std::time::Duration;
 
 use nodedb_cluster::calvin::{
     sequencer::{SequencerConfig, new_inbox},
-    types::{EngineKeySet, ReadWriteSet, SequencedTxn, SortedVec, TxClass},
+    types::{EngineKeySet, ReadWriteSet, SequencedTxn, SortedVec, TxClass, VersionedReadSet},
 };
 use nodedb_types::{
     TenantId,
@@ -74,6 +74,7 @@ fn make_multi_vshard_insert(col_a: &str, col_b: &str) -> TxClass {
         vec![],
         TenantId::new(1),
         None,
+        VersionedReadSet::default(),
     )
     .expect("valid TxClass for multi-vshard INSERT")
 }

nodedb-cluster-tests/tests/calvin_sequencer_failover.rs

@@ -15,7 +15,7 @@ use std::time::Duration;
 
 use nodedb_cluster::calvin::{
     sequencer::{SequencerConfig, new_inbox},
-    types::{EngineKeySet, ReadWriteSet, SortedVec, TxClass},
+    types::{EngineKeySet, ReadWriteSet, SortedVec, TxClass, VersionedReadSet},
 };
 use nodedb_types::{
     TenantId,
@@ -58,6 +58,7 @@ fn make_txclass(surr_a: u32, surr_b: u32) -> TxClass {
         vec![],
         TenantId::new(1),
         None,
+        VersionedReadSet::default(),
     )
     .expect("valid TxClass")
 }

nodedb-cluster-tests/tests/calvin_sequencer_starvation.rs

@@ -23,7 +23,9 @@ use std::time::{Duration, Instant};
 use nodedb_cluster::calvin::sequencer::config::SequencerConfig;
 use nodedb_cluster::calvin::sequencer::inbox::{Inbox, new_inbox};
 use nodedb_cluster::calvin::sequencer::validator::validate_batch;
-use nodedb_cluster::calvin::types::{EngineKeySet, ReadWriteSet, SortedVec, TxClass};
+use nodedb_cluster::calvin::types::{
+    EngineKeySet, ReadWriteSet, SortedVec, TxClass, VersionedReadSet,
+};
 use nodedb_types::{
     TenantId,
     id::{DatabaseId, VShardId},
@@ -67,6 +69,7 @@ fn make_conflicting_tx(col_a: &str, col_b: &str, unique_surr: u32, tenant: u64)
         vec![unique_surr as u8],
         TenantId::new(tenant),
         None,
+        VersionedReadSet::default(),
     )
     .expect("valid TxClass")
 }

nodedb-cluster/src/calvin/sequencer/entry.rs

@@ -89,6 +89,7 @@ mod tests {
             vec![0xAB],
             TenantId::new(1),
             None,
+            crate::calvin::types::VersionedReadSet::default(),
         )
         .expect("valid TxClass");
 

nodedb-cluster/src/calvin/sequencer/inbox.rs

@@ -395,6 +395,7 @@ mod tests {
             vec![],
             TenantId::new(tenant),
             None,
+            crate::calvin::types::VersionedReadSet::default(),
         )
         .expect("valid TxClass")
     }

nodedb-cluster/src/calvin/sequencer/service.rs

@@ -305,6 +305,7 @@ mod tests {
             vec![surr_a as u8],
             TenantId::new(1),
             None,
+            crate::calvin::types::VersionedReadSet::default(),
         )
         .expect("valid TxClass")
     }

nodedb-cluster/src/calvin/sequencer/state_machine.rs

@@ -365,6 +365,7 @@ mod tests {
             vec![],
             TenantId::new(1),
             None,
+            crate::calvin::types::VersionedReadSet::default(),
         )
         .expect("valid TxClass");
         (tx_class, real_va, real_vb)