feat: update

Author: eastspire

frameworks/Rust/hyperlane/Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "hyperlane_techempower"
-version = "0.0.1"
+version = "0.1.0"
 edition = "2024"
 authors = ["ltpp-universe <[email protected]>"] 
 license = "MIT"
@@ -18,7 +18,7 @@ exclude = [
 ]
 
 [dependencies]
-hyperlane = "4.94.0"
+hyperlane = "4.96.0"
 rand = "0.9.1"
 serde = "1.0.219"
 sqlx = { version = "0.8.5", features = ["runtime-tokio", "postgres"] }

frameworks/Rust/hyperlane/Cargo.toml

@@ -8,7 +8,7 @@ pub fn get_db_connection() -> &'static DbPoolConnection {
 pub async fn create_database() {
     let db_pool: &DbPoolConnection = get_db_connection();
     let _ = query(&format!("CREATE DATABASE {};", DATABASE_NAME))
-        .execute(&db_pool)
+        .execute(db_pool)
         .await;
 }
 
@@ -21,23 +21,23 @@ pub async fn create_table() {
         );",
         TABLE_NAME_WORLD
     ))
-    .execute(&db_pool)
+    .execute(db_pool)
     .await;
     let _ = query(&format!(
         "CREATE TABLE IF NOT EXISTS {} (
             id SERIAL PRIMARY KEY, message VARCHAR NOT NULL
         );",
         TABLE_NAME_FORTUNE
     ))
-    .execute(&db_pool)
+    .execute(db_pool)
     .await;
 }
 
 #[cfg(feature = "dev")]
 pub async fn insert_records() {
     let db_pool: &DbPoolConnection = get_db_connection();
     let row: PgRow = query(&format!("SELECT COUNT(*) FROM {}", TABLE_NAME_WORLD))
-        .fetch_one(&db_pool)
+        .fetch_one(db_pool)
         .await
         .unwrap();
     let count: i64 = row.get(0);
@@ -56,7 +56,7 @@ pub async fn insert_records() {
         TABLE_NAME_WORLD,
         values.join(",")
     );
-    let _ = query(&sql).execute(&db_pool).await;
+    let _ = query(&sql).execute(db_pool).await;
     let mut values: Vec<String> = Vec::new();
     for _ in 0..missing_count {
         let random_number: i32 = get_random_id();
@@ -67,7 +67,7 @@ pub async fn insert_records() {
         TABLE_NAME_FORTUNE,
         values.join(",")
     );
-    let _ = query(&sql).execute(&db_pool).await;
+    let _ = query(&sql).execute(db_pool).await;
 }
 
 pub async fn init_cache() -> Vec<QueryRow> {

frameworks/Rust/hyperlane/src/db.rs

@@ -18,6 +18,7 @@ pub(crate) use hyperlane::{
     serde::*,
     serde_json::{Value, json},
     tokio::{
+        runtime::{Builder, Runtime},
         spawn,
         sync::{AcquireError, OwnedSemaphorePermit, Semaphore},
         task::JoinHandle,

frameworks/Rust/hyperlane/src/main.rs

@@ -1,12 +1,11 @@
 use crate::*;
-use tokio::runtime::{Builder, Runtime};
 
 fn runtime() -> Runtime {
     Builder::new_multi_thread()
         .worker_threads(get_thread_count())
         .thread_stack_size(1_048_576)
-        .max_blocking_threads(10240)
-        .max_io_events_per_tick(10240)
+        .max_blocking_threads(1024000)
+        .max_io_events_per_tick(1024000)
         .enable_all()
         .build()
         .unwrap()