s3-wire 0.3.1

An async, streaming S3-compatible client for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

//! Upload a one-shot stream with an exact length and SHA-256 digest.

use std::error::Error;
use std::io;

use bytes::Bytes;
use futures_util::stream;
use s3_wire::{ByteStream, DeleteObjectRequest, ObjectKey, PutObjectRequest};
use sha2::{Digest as _, Sha256};

mod common;

#[tokio::main]
async fn main() -> Result<(), Box<dyn Error>> {
    let client = common::client_from_env()?;
    let key = ObjectKey::new("examples/one-shot.txt")?;
    let payload: &'static [u8] = b"one-shot streaming upload";
    let digest: [u8; 32] = Sha256::digest(payload).into();
    let body = stream::once(async move { Ok::<_, io::Error>(Bytes::from_static(payload)) });

    client
        .put_object(PutObjectRequest::new(
            key.clone(),
            ByteStream::from_stream(body, payload.len() as u64, digest),
        ))
        .await?;

    client.delete_object(DeleteObjectRequest::new(key)).await?;
    Ok(())
}