minima-r2-sdk

Minimal Cloudflare R2 SDK for Rust.

Install

[dependencies]
minima-r2-sdk = "0.1"
tokio = { version = "1", features = ["rt-multi-thread", "macros"] }

Usage

use minima_r2_sdk::{R2Client, Credentials, PutObjectRequest, Bytes};

#[tokio::main]
async fn main() -> Result<(), minima_r2_sdk::Error> {
    let creds = Credentials::new("access_key", "secret_key");
    let client = R2Client::new("account_id", creds);

    // Upload
    client.put_object(PutObjectRequest {
        bucket: "my-bucket",
        key: "file.txt",
        body: Bytes::from("Hello R2!"),
        content_type: Some("text/plain"),
        metadata: None,
    }).await?;

    // Download
    let obj = client.get_object("my-bucket", "file.txt").await?;
    println!("{}", String::from_utf8_lossy(&obj.body));

    // List
    let list = client.list_objects_v2(minima_r2_sdk::ListObjectsV2Request {
        bucket: "my-bucket",
        prefix: Some("prefix/"),
        ..Default::default()
    }).await?;

    // Delete
    client.delete_object("my-bucket", "file.txt").await?;

    Ok(())
}

Credentials from Environment

// Reads R2_ACCESS_KEY_ID and R2_SECRET_ACCESS_KEY
let creds = Credentials::from_env()?;

Multipart Upload (>5MB files)

let upload = client.create_multipart_upload("bucket", "large.bin").await?;

let part = client.upload_part(UploadPartRequest {
    bucket: "bucket",
    key: "large.bin",
    upload_id: &upload.upload_id,
    part_number: 1,
    body: Bytes::from(data),
}).await?;

client.complete_multipart_upload(CompleteMultipartUploadRequest {
    bucket: "bucket",
    key: "large.bin",
    upload_id: &upload.upload_id,
    parts: vec![CompletedPart { part_number: 1, etag: part.etag }],
}).await?;

API

License

MIT