merge remote support

ecstore/src/disk/local.rs

@@ -18,16 +18,14 @@ use crate::{
     store_api::{FileInfo, RawFileInfo},
     utils,
 };
-use bytes::Bytes;
 use path_absolutize::Absolutize;
-use std::io::Read;
 use std::{
     fs::Metadata,
     path::{Path, PathBuf},
 };
-use time::{util, OffsetDateTime};
+use time::OffsetDateTime;
 use tokio::fs::{self, File};
-use tokio::io::{self, AsyncReadExt, AsyncWriteExt, ErrorKind};
+use tokio::io::{AsyncReadExt, AsyncWriteExt, ErrorKind};
 use tokio::sync::Mutex;
 use tracing::{debug, warn};
 use uuid::Uuid;
@@ -1343,12 +1341,12 @@ impl DiskAPI for LocalDisk {
     async fn delete_version(
         &self,
         volume: &str,
-        path: &str,
-        fi: FileInfo,
-        force_del_marker: bool,
-        opts: DeleteOptions,
+        _path: &str,
+        _fi: FileInfo,
+        _force_del_marker: bool,
+        _opts: DeleteOptions,
     ) -> Result<RawFileInfo> {
-        let volume_dir = self.get_bucket_path(&volume)?;
+        let _volume_dir = self.get_bucket_path(&volume)?;
 
         // self.read_all_data(bucket, volume_dir, path);
 

ecstore/src/disk/mod.rs

@@ -19,7 +19,7 @@ use crate::{
     file_meta::FileMeta,
     store_api::{FileInfo, RawFileInfo},
 };
-use bytes::Bytes;
+
 use endpoint::Endpoint;
 use protos::proto_gen::node_service::{node_service_client::NodeServiceClient, ReadAtRequest, WriteRequest};
 use serde::{Deserialize, Serialize};

ecstore/src/disk/os.rs

@@ -3,7 +3,6 @@ use std::{
     path::{Component, Path},
 };
 
-use futures::TryFutureExt;
 use tokio::fs;
 
 use crate::{

ecstore/src/disk/remote.rs

@@ -1,6 +1,5 @@
 use std::{path::PathBuf, sync::Arc, time::Duration};
 
-use bytes::Bytes;
 use futures::lock::Mutex;
 use protos::{
     node_service_time_out_client,