fix(services/etcd): fill content length from list response

Author: Xuanwo

core/services/etcd/src/lister.rs

@@ -26,7 +26,7 @@ use opendal_core::*;
 pub struct EtcdLister {
     root: String,
     path: String,
-    iter: IntoIter<String>,
+    iter: IntoIter<(String, u64)>,
 }
 
 impl EtcdLister {
@@ -35,11 +35,7 @@ impl EtcdLister {
 
         // Get all keys with the specified prefix
         let mut client = core.conn().await?;
-        let get_options = Some(
-            etcd_client::GetOptions::new()
-                .with_prefix()
-                .with_keys_only(),
-        );
+        let get_options = Some(etcd_client::GetOptions::new().with_prefix());
         let resp = client
             .get(abs_path.as_str(), get_options)
             .await
@@ -52,7 +48,8 @@ impl EtcdLister {
                 Error::new(ErrorKind::Unexpected, "store key is not valid utf-8 string")
                     .set_source(err)
             })?;
-            keys.push(key);
+            let value_len = kv.value().len() as u64;
+            keys.push((key, value_len));
         }
 
         Ok(Self {
@@ -65,11 +62,15 @@ impl EtcdLister {
 
 impl oio::List for EtcdLister {
     async fn next(&mut self) -> Result<Option<Entry>> {
-        for key in self.iter.by_ref() {
+        for (key, value_len) in self.iter.by_ref() {
             if key.starts_with(&self.path) {
                 let path = build_rel_path(&self.root, &key);
+                let mut metadata = Metadata::new(EntryMode::from_path(&key));
+                if metadata.mode().is_file() {
+                    metadata.set_content_length(value_len);
+                }
 
-                let entry = Entry::new(&path, Metadata::new(EntryMode::from_path(&key)));
+                let entry = Entry::new(&path, metadata);
                 return Ok(Some(entry));
             }
         }