[incubator-opendal] 03/05: Add write can sink

[xu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

xuanwo pushed a commit to branch implement-sink-for-s3
in repository https://gitbox.apache.org/repos/asf/incubator-opendal.git

commit 350f10eb196e861b796f9a1cd7e1403a320374d7
Author: Xuanwo <gi...@xuanwo.io>
AuthorDate: Wed Jun 21 18:18:50 2023 +0800

    Add write can sink
    
    Signed-off-by: Xuanwo <gi...@xuanwo.io>
---
 core/src/services/s3/backend.rs | 1 +
 core/src/types/capability.rs    | 2 ++
 2 files changed, 3 insertions(+)

diff --git a/core/src/services/s3/backend.rs b/core/src/services/s3/backend.rs
index b5c780c50..cade3c53f 100644
--- a/core/src/services/s3/backend.rs
+++ b/core/src/services/s3/backend.rs
@@ -768,6 +768,7 @@ impl Accessor for S3Backend {
                 read_with_override_content_disposition: true,
 
                 write: true,
+                write_can_sink: true,
                 write_with_cache_control: true,
                 write_with_content_type: true,
                 write_without_content_length: true,
diff --git a/core/src/types/capability.rs b/core/src/types/capability.rs
index 1153a93f8..ba3ed57c5 100644
--- a/core/src/types/capability.rs
+++ b/core/src/types/capability.rs
@@ -74,6 +74,8 @@ pub struct Capability {
 
     /// If operator supports write natively, it will be true.
     pub write: bool,
+    /// If operator supports write by sink a stream into, it will be true.
+    pub write_can_sink: bool,
     /// If operator supports write with without content length, it will
     /// be true.
     ///