refactor: update fusio & use DynWrite in wal instead

.gitignore

@@ -2,3 +2,4 @@
 /.idea
 Cargo.lock
 db_path
+bindings/python/target

Cargo.toml

@@ -58,7 +58,7 @@ crc32fast = "1"
 crossbeam-skiplist = "0.1"
 datafusion = { version = "42", optional = true }
 flume = { version = "0.11", features = ["async"] }
-fusio = { package = "fusio", version = "0.3.1", features = [
+fusio = { package = "fusio", version = "0.3.3", features = [
     "aws",
     "dyn",
     "fs",

bindings/python/src/fs.rs

@@ -43,6 +43,7 @@ pub enum FsOptions {
         region: Option<String>,
         sign_payload: Option<bool>,
         checksum: Option<bool>,
+        endpoint: Option<String>,
     },
 }
 
@@ -56,12 +57,14 @@ impl From<FsOptions> for fusio_dispatch::FsOptions {
                 region,
                 sign_payload,
                 checksum,
+                endpoint,
             } => fusio_dispatch::FsOptions::S3 {
                 bucket,
                 credential: credential.map(fusio::remotes::aws::AwsCredential::from),
                 region,
                 sign_payload,
                 checksum,
+                endpoint,
             },
         }
     }

rust-toolchain.toml

@@ -1,3 +1,3 @@
 [toolchain]
-channel = "1.80.0"
+channel = "1.82"
 components = ["clippy", "rust-analyzer", "rustfmt"]

src/inmem/mutable.rs

@@ -5,7 +5,7 @@ use crossbeam_skiplist::{
     map::{Entry, Range},
     SkipMap,
 };
-use fusio::{buffered::BufWriter, dynamic::DynFile, DynFs};
+use fusio::{buffered::BufWriter, DynFs, DynWrite};
 use ulid::Ulid;
 
 use crate::{
@@ -37,7 +37,7 @@ where
     R: Record,
 {
     pub(crate) data: SkipMap<Timestamped<R::Key>, Option<R>>,
-    wal: Option<Mutex<WalFile<Box<dyn DynFile>, R>>>,
+    wal: Option<Mutex<WalFile<Box<dyn DynWrite>, R>>>,
     pub(crate) trigger: Arc<Box<dyn Trigger<R> + Send + Sync>>,
 }
 
@@ -61,7 +61,7 @@ where
                 )
                 .await?,
                 option.wal_buffer_size,
-            )) as Box<dyn DynFile>;
+            )) as Box<dyn DynWrite>;
 
             wal = Some(Mutex::new(WalFile::new(file, file_id)));
         };

src/wal/mod.rs

@@ -42,7 +42,7 @@ impl<F, R> WalFile<F, R> {
 
 impl<F, R> WalFile<F, R>
 where
-    F: Write + Unpin + Send,
+    F: Write + Send,
     R: Record,
 {
     pub(crate) async fn write<'r>(