upgrade rust-toolchain version

Cargo.toml

@@ -26,7 +26,6 @@ tokio = { version = "1.28.2", features = ["full"] }
 serde = { version = "1", features = ["derive", "rc"] }
 serde_json = "1"
 bincode = "1.3.3"
-async-trait = "0.1.68"
 integer-encoding = "3.0.4"
 strum_macros = "0.24"
 ordered-float = "3.0"

rust-toolchain

@@ -1 +1 @@
-nightly-2023-09-29
+nightly-2023-10-13

src/lib.rs

@@ -5,6 +5,7 @@
 #![feature(iterator_try_collect)]
 #![feature(slice_pattern)]
 #![feature(bound_map)]
+#![feature(async_fn_in_trait)]
 extern crate core;
 pub mod binder;
 pub mod catalog;

src/storage/kip.rs

@@ -8,7 +8,6 @@ use crate::types::errors::TypeError;
 use crate::types::index::{Index, IndexMeta, IndexMetaRef};
 use crate::types::tuple::{Tuple, TupleId};
 use crate::types::value::ValueRef;
-use async_trait::async_trait;
 use kip_db::kernel::lsm::iterator::Iter as KipDBIter;
 use kip_db::kernel::lsm::mvcc::TransactionIter;
 use kip_db::kernel::lsm::storage::Config;
@@ -37,7 +36,6 @@ impl KipStorage {
     }
 }
 
-#[async_trait]
 impl Storage for KipStorage {
     type TransactionType = KipTransaction;
 
@@ -56,7 +54,6 @@ pub struct KipTransaction {
     cache: ShardingLruCache<String, TableCatalog>,
 }
 
-#[async_trait]
 impl Transaction for KipTransaction {
     type IterType<'a> = KipIter<'a>;
 

src/storage/mod.rs

@@ -8,25 +8,25 @@ use crate::storage::table_codec::TableCodec;
 use crate::types::errors::TypeError;
 use crate::types::index::{Index, IndexMetaRef};
 use crate::types::tuple::{Tuple, TupleId};
-use async_trait::async_trait;
 use kip_db::error::CacheError;
 use kip_db::kernel::lsm::mvcc;
 use kip_db::KernelError;
 use std::collections::VecDeque;
 use std::ops::SubAssign;
 
-#[async_trait]
+
 pub trait Storage: Sync + Send + Clone + 'static {
     type TransactionType: Transaction;
 
+    #[allow(async_fn_in_trait)]
     async fn transaction(&self) -> Result<Self::TransactionType, StorageError>;
 }
 
 /// Optional bounds of the reader, of the form (offset, limit).
 pub(crate) type Bounds = (Option<usize>, Option<usize>);
 type Projections = Vec<ScalarExpression>;
 
-#[async_trait]
+
 pub trait Transaction: Sync + Send + 'static {
     type IterType<'a>: Iter;
 
@@ -80,6 +80,7 @@ pub trait Transaction: Sync + Send + 'static {
 
     fn show_tables(&self) -> Result<Vec<String>, StorageError>;
 
+    #[allow(async_fn_in_trait)]
     async fn commit(self) -> Result<(), StorageError>;
 }