Optimize ScyllaDB's batch writes

Author: ndr-ds

Cargo.lock

@@ -3,7 +3,7 @@
 
 use linera_views::{
     lru_caching::StorageCacheConfig,
-    scylla_db::{ScyllaDbStore, ScyllaDbStoreConfig},
+    scylla_db::{ScyllaDbClientConfig, ScyllaDbStore, ScyllaDbStoreConfig},
     store::{AdminKeyValueStore, CommonStoreConfig},
 };
 
@@ -64,7 +64,11 @@ impl ScyllaDbRunner {
             replication_factor: config.client.replication_factor,
         };
         let namespace = config.client.table.clone();
-        let store_config = ScyllaDbStoreConfig::new(config.client.uri.clone(), common_config);
+        let store_config = ScyllaDbStoreConfig::new(
+            config.client.uri.clone(),
+            common_config,
+            ScyllaDbClientConfig::default(),
+        );
         let store = ScyllaDbStore::connect(&store_config, &namespace).await?;
         Self::new(config, store).await
     }

examples/Cargo.lock

@@ -36,7 +36,7 @@ use {
 };
 #[cfg(feature = "scylladb")]
 use {
-    linera_views::scylla_db::{ScyllaDbStore, ScyllaDbStoreConfig},
+    linera_views::scylla_db::{ScyllaDbClientConfig, ScyllaDbStore, ScyllaDbStoreConfig},
     std::num::NonZeroU16,
     tracing::debug,
 };
@@ -418,7 +418,11 @@ impl StorageConfigNamespace {
             }
             #[cfg(feature = "scylladb")]
             StorageConfig::ScyllaDb { uri } => {
-                let config = ScyllaDbStoreConfig::new(uri.to_string(), common_config);
+                let config = ScyllaDbStoreConfig::new(
+                    uri.to_string(),
+                    common_config,
+                    ScyllaDbClientConfig::default(),
+                );
                 Ok(StoreConfig::ScyllaDb { config, namespace })
             }
             #[cfg(all(feature = "rocksdb", feature = "scylladb"))]
@@ -432,7 +436,11 @@ impl StorageConfigNamespace {
                     path_with_guard.clone(),
                     common_config.clone(),
                 );
-                let second_config = ScyllaDbStoreConfig::new(uri.to_string(), common_config);
+                let second_config = ScyllaDbStoreConfig::new(
+                    uri.to_string(),
+                    common_config,
+                    ScyllaDbClientConfig::default(),
+                );
                 let config = DualStoreConfig {
                     first_config,
                     second_config,

linera-indexer/lib/src/scylla_db.rs

@@ -46,6 +46,7 @@ linera-base.workspace = true
 linera-views-derive.workspace = true
 linera-witty.workspace = true
 linked-hash-map.workspace = true
+lru.workspace = true
 prometheus.workspace = true
 rand = { workspace = true, features = ["small_rng"] }
 rocksdb = { workspace = true, optional = true }