build(deps): bump object_store from 0.5.6 to 0.6.1 (#2745)

bindings/object_store/Cargo.toml

@@ -31,7 +31,7 @@ version.workspace = true
 async-trait = "0.1"
 bytes = "1"
 futures = "0.3"
-object_store = "0.5"
+object_store = "0.6"
 opendal.workspace = true
 tokio = "1"
 

bindings/object_store/src/lib.rs

@@ -26,6 +26,7 @@ use futures::stream::BoxStream;
 use futures::Stream;
 use futures::StreamExt;
 use object_store::path::Path;
+use object_store::GetOptions;
 use object_store::GetResult;
 use object_store::ListResult;
 use object_store::MultipartId;
@@ -87,6 +88,16 @@ impl ObjectStore for OpendalStore {
         })
     }
 
+    async fn get_opts(&self, location: &Path, _: GetOptions) -> Result<GetResult> {
+        let r = self
+            .inner
+            .reader(location.as_ref())
+            .await
+            .map_err(|err| format_object_store_error(err, location.as_ref()))?;
+
+        Ok(GetResult::Stream(Box::pin(OpendalReader { inner: r })))
+    }
+
     async fn get(&self, location: &Path) -> Result<GetResult> {
         let r = self
             .inner
@@ -118,6 +129,7 @@ impl ObjectStore for OpendalStore {
             location: location.clone(),
             last_modified: meta.last_modified().unwrap_or_default(),
             size: meta.content_length() as usize,
+            e_tag: None,
         })
     }
 
@@ -243,6 +255,7 @@ fn format_object_meta(path: &str, meta: &Metadata) -> ObjectMeta {
         location: path.into(),
         last_modified: meta.last_modified().unwrap_or_default(),
         size: meta.content_length() as usize,
+        e_tag: None,
     }
 }