add append for oss

Signed-off-by: suyanhanx <suyanhanx@gmail.com>
apache · May 23, 2023 · 46a765b · 46a765b
1 parent d0498cc
commit 46a765b
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 2 deletions.
diff --git a/core/src/services/oss/appender.rs b/core/src/services/oss/appender.rs
@@ -39,7 +39,6 @@ pub struct OssAppender {
 }
 
 impl OssAppender {
-    #[allow(dead_code)]
     pub fn new(core: Arc<OssCore>, path: &str, op: OpAppend) -> Self {
         Self {
             core,

diff --git a/core/src/services/oss/backend.rs b/core/src/services/oss/backend.rs
@@ -30,6 +30,7 @@ use reqsign::AliyunConfig;
 use reqsign::AliyunLoader;
 use reqsign::AliyunOssSigner;
 
+use super::appender::OssAppender;
 use super::core::*;
 use super::error::parse_error;
 use super::pager::OssPager;
@@ -441,7 +442,7 @@ impl Accessor for OssBackend {
     type BlockingReader = ();
     type Writer = OssWriter;
     type BlockingWriter = ();
-    type Appender = ();
+    type Appender = OssAppender;
     type Pager = OssPager;
     type BlockingPager = ();
 
@@ -538,6 +539,13 @@ impl Accessor for OssBackend {
         ))
     }
 
+    async fn append(&self, path: &str, args: OpAppend) -> Result<(RpAppend, Self::Appender)> {
+        Ok((
+            RpAppend::default(),
+            OssAppender::new(self.core.clone(), path, args),
+        ))
+    }
+
     async fn copy(&self, from: &str, to: &str, _args: OpCopy) -> Result<RpCopy> {
         let resp = self.core.oss_copy_object(from, to).await?;
         let status = resp.status();