Bump to version 0.12 (#518)

* Bump to version 0.12

Signed-off-by: Xuanwo <[email protected]>

* Update oay and oli

Signed-off-by: Xuanwo <[email protected]>

* Add link to rfc

Signed-off-by: Xuanwo <[email protected]>

Signed-off-by: Xuanwo <[email protected]>

Author: Xuanwo

CHANGELOG.md

@@ -5,6 +5,24 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/)
 and this project adheres to [Semantic Versioning](https://semver.org/).
 
+## [v0.12.0] - 2022-08-12
+
+### Added
+
+- RFC-0501: New Builder (#501)
+- feat: Implement RFC-0501 New Builder (#510)
+
+### Changed
+
+- feat: Use isahc to replace hyper (#471)
+- refactor: make parse http error code public (#511)
+- refactor: Extrace new http error APIs (#515)
+- refactor: Simplify the error response parse logic (#516)
+
+### Removed
+
+- refactor: Remove deprecated struct Metadata (#503)
+
 ## [v0.11.4] - 2022-08-02
 
 ### Added
@@ -531,6 +549,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/).
 
 Hello, OpenDAL!
 
+[v0.12.0]: https://github.com/datafuselabs/opendal/compare/v0.11.4...v0.12.0
 [v0.11.4]: https://github.com/datafuselabs/opendal/compare/v0.11.3...v0.11.4
 [v0.11.3]: https://github.com/datafuselabs/opendal/compare/v0.11.2...v0.11.3
 [v0.11.2]: https://github.com/datafuselabs/opendal/compare/v0.11.1...v0.11.2

Cargo.toml

@@ -9,7 +9,7 @@ keywords = ["storage", "data", "s3", "fs", "azblob"]
 license = "Apache-2.0"
 name = "opendal"
 repository = "https://github.com/datafuselabs/opendal"
-version = "0.11.4"
+version = "0.12.0"
 
 [package.metadata.docs.rs]
 all-features = true

README.md

@@ -30,6 +30,7 @@ You may be looking for:
 - Access different storage system in the same way
 - Native decompress support
 - Native service-side encryption support
+- Powerful [`Layer`](https://docs.rs/opendal/latest/opendal/trait.Layer.html)
 - **100%** documents covered
 - Behavior tests for all services
 
@@ -38,45 +39,52 @@ You may be looking for:
 ```rust
 use anyhow::Result;
 use futures::StreamExt;
+use futures::TryStreamExt;
+use opendal::DirEntry;
+use opendal::DirStreamer;
+use opendal::Object;
+use opendal::ObjectMetadata;
 use opendal::ObjectMode;
 use opendal::Operator;
-use opendal::Metadata;
-use opendal::Object;
-use opendal::ObjectStreamer;
 use opendal::Scheme;
 
 #[tokio::main]
 async fn main() -> Result<()> {
-    // Init Operator from env.
-    let op = Operator::from_env(Scheme::S3).await?;
+    // Init Operator
+    let op = Operator::from_env(Scheme::Fs)?;
 
     // Create object handler.
-    let o: Object = op.object("test_file");
+    let o = op.object("test_file");
 
     // Write data info object;
-    let _: () = o.write("Hello, World!").await?;
+    o.write("Hello, World!").await?;
 
     // Read data from object;
-    let bs: Vec<u8> = o.read().await?;
+    let bs = o.read().await?;
 
     // Read range from object;
-    let bs: Vec<u8> = o.range_read(1..=11).await?;
+    let bs = o.range_read(1..=11).await?;
+
+    // Get object's path
+    let name = o.name();
+    let path = o.path();
 
-    // Get object's Metadata
-    let meta: Metadata = o.metadata().await?;
-    let path: &str = meta.path();
-    let mode: ObjectMode = meta.mode();
-    let length: u64 = meta.content_length();
-    let content_md5: Option<String> = meta.content_md5();
+    // Fetch more meta about object.
+    let meta = o.metadata().await?;
+    let mode = meta.mode();
+    let length = meta.content_length();
+    let content_md5 = meta.content_md5();
+    let etag = meta.etag();
 
     // Delete object.
-    let _: () = o.delete().await?;
+    o.delete().await?;
 
     // List dir object.
-    let o: Object = op.object("test_dir/");
-    let mut obs: ObjectStreamer = o.list().await?;
-    while let Some(entry) = obs.next().await {
-        let entry: Object = entry?;
+    let o = op.object("test_dir/");
+    let mut ds = o.list().await?;
+    while let Some(entry) = ds.try_next().await? {
+        let path = entry.path();
+        let mode = entry.mode();
     }
 
     Ok(())

docs/upgrade.md

@@ -2,6 +2,38 @@
 
 This document intends to record upgrade and migrate procedures while OpenDAL meets breaking changes.
 
+## Upgraded to v0.12
+
+OpenDAL introduces breaking changes for services initiation.
+
+Since v0.12, `Operator::new` will accept `impl Accessor + 'static` instead of `Arc<dyn Accessor>`:
+
+```rust
+impl Operator {
+    pub fn new(accessor: impl Accessor + 'static) -> Self { .. }
+}
+```
+
+Every service's `Builder` now have a `build()` API which can be run without async:
+
+```rust
+let mut builder = fs::Builder::default();
+let op: Operator = Operator::new(builder.build()?);
+```
+
+Along with these changes, `Operator::from_iter` and `Operator::from_env` now is a blocking API too.
+
+For more information about this change, please refer to [RFC-0501: New Builder](https://opendal.databend.rs/rfcs/0501-new-builder.html).
+
+The following APIs have been deprecated:
+
+- All services `Builder::finish()` (replaced by `Builder::build()`)
+- All services `Backend::build()` (replace by `Builder::default()`)
+
+The following APIs have been removed:
+
+- public struct `Metadata` (deprecated in v0.8, replaced by `ObjectMetadata`)
+
 ## Upgraded to v0.8
 
 OpenDAL introduces a breaking change of `list` related operations in v0.8.

oay/Cargo.lock

@@ -8,7 +8,7 @@ keywords = ["storage", "data", "s3", "fs", "azblob"]
 license = "Apache-2.0"
 name = "oay"
 repository = "https://github.com/datafuselabs/opendal"
-version = "0.11.4"
+version = "0.12.0"
 
 [dependencies]
 actix-web = "4.1"
@@ -17,7 +17,7 @@ clap = { version = "3.2", features = ["cargo"] }
 env_logger = "0.9"
 futures = "0.3"
 log = "0.4"
-opendal = "0.11.4"
+opendal = "0.12.0"
 tokio = { version = "1.20", features = ["rt-multi-thread", "macros"] }
 
 # Please comment the following patch while releasing.

oay/Cargo.toml

@@ -8,14 +8,14 @@ keywords = ["storage", "data", "s3", "fs", "azblob"]
 license = "Apache-2.0"
 name = "oli"
 repository = "https://github.com/datafuselabs/opendal"
-version = "0.11.4"
+version = "0.12.0"
 
 [dependencies]
 anyhow = "1.0"
 clap = { version = "3.2", features = ["cargo"] }
 env_logger = "0.9"
 log = "0.4"
-opendal = "0.11.4"
+opendal = "0.12.0"
 
 # Please comment the following patch while releasing.
 [patch.crates-io]

oli/Cargo.lock

@@ -31,12 +31,15 @@
 //! - `retry`: Enable operator retry support.
 //! - `services-hdfs`: Enable hdfs service support.
 //! - `services-http`: Enable http service support.
+//! - `rustls`: Use rustls instead openssl for https connection
+//! - `serde`: Implement serde::{Serialize,Deserialize} for ObjectMetadata.
 //!
 //! # Example
 //!
 //! ```no_run
 //! use anyhow::Result;
 //! use futures::StreamExt;
+//! use futures::TryStreamExt;
 //! use opendal::DirEntry;
 //! use opendal::DirStreamer;
 //! use opendal::Object;
@@ -48,37 +51,40 @@
 //! #[tokio::main]
 //! async fn main() -> Result<()> {
 //!     // Init Operator
-//!     let op = Operator::from_env(Scheme::S3)?;
+//!     let op = Operator::from_env(Scheme::Fs)?;
 //!
 //!     // Create object handler.
-//!     let o: Object = op.object("test_file");
+//!     let o = op.object("test_file");
 //!
 //!     // Write data info object;
-//!     let _: () = o.write("Hello, World!").await?;
+//!     o.write("Hello, World!").await?;
 //!
 //!     // Read data from object;
-//!     let bs: Vec<u8> = o.read().await?;
+//!     let bs = o.read().await?;
 //!
 //!     // Read range from object;
-//!     let bs: Vec<u8> = o.range_read(1..=11).await?;
+//!     let bs = o.range_read(1..=11).await?;
 //!
-//!     // Get object's Metadata
-//!     let name: &str = o.name();
-//!     let path: &str = o.path();
-//!     let meta: ObjectMetadata = o.metadata().await?;
-//!     let mode: ObjectMode = meta.mode();
-//!     let length: u64 = meta.content_length();
-//!     let content_md5: Option<&str> = meta.content_md5();
-//!     let etag: Option<&str> = meta.etag();
+//!     // Get object's path
+//!     let name = o.name();
+//!     let path = o.path();
+//!
+//!     // Fetch more meta about object.
+//!     let meta = o.metadata().await?;
+//!     let mode = meta.mode();
+//!     let length = meta.content_length();
+//!     let content_md5 = meta.content_md5();
+//!     let etag = meta.etag();
 //!
 //!     // Delete object.
-//!     let _: () = o.delete().await?;
+//!     o.delete().await?;
 //!
 //!     // List dir object.
-//!     let o: Object = op.object("test_dir/");
-//!     let mut obs: DirStreamer = o.list().await?;
-//!     while let Some(entry) = obs.next().await {
-//!         let entry: DirEntry = entry?;
+//!     let o = op.object("test_dir/");
+//!     let mut ds = o.list().await?;
+//!     while let Some(entry) = ds.try_next().await? {
+//!         let path = entry.path();
+//!         let mode = entry.mode();
 //!     }
 //!
 //!     Ok(())