Release v0.11.0
Bump to version 0.11.0 (#435)

* Bump to version 0.11.0

Signed-off-by: Xuanwo <github@xuanwo.io>

* Add presign in index

Signed-off-by: Xuanwo <github@xuanwo.io>
9 files changed
tree: 6f8532f8d10c6bea635a7b20cddbc87375972d68
  1. .github/
  2. benches/
  3. docs/
  4. examples/
  5. oli/
  6. src/
  7. testdata/
  8. tests/
  9. .env.example
  10. .gitignore
  11. .licenserc.yaml
  12. .taplo.toml
  13. book.toml
  14. Cargo.toml
  15. CHANGELOG.md
  16. CONTRIBUTING.md
  17. LICENSE
  18. README.md
  19. rust-toolchain.toml
  20. rustfmt.toml
README.md

OpenDAL   Build Status Latest Version

Open Data Access Layer that empowers everyone to access different storage services painless and efficiently


You may be looking for:

Services

  • azblob: Azure Storage Blob services.
  • fs: POSIX alike file system.
  • hdfs: Hadoop Distributed File System(HDFS).
  • http: HTTP read-only services.
  • memory: In memory backend.
  • s3: AWS S3 alike services.

Features

  • Access different storage system in the same way
  • Native decompress support
  • Native service-side encryption support
  • 100% documents covered
  • Behavior tests for all services

Quickstart

use anyhow::Result;
use futures::StreamExt;
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?;

    // Create object handler.
    let o: Object = op.object("test_file");

    // Write data info object;
    let _: () = o.write("Hello, World!").await?;

    // Read data from object;
    let bs: Vec<u8> = o.read().await?;

    // Read range from object;
    let bs: Vec<u8> = o.range_read(1..=11).await?;

    // 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();

    // Delete object.
    let _: () = 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?;
    }

    Ok(())
}

More examples could be found at Documentation.

Projects

  • databend: A modern Elasticity and Performance cloud data warehouse.

Contributing

Check out the CONTRIBUTING.md guide for more details on getting started with contributing to this project.

Getting help

Submit issues for bug report or asking questions in discussion.

License