rust-integration-services 0.5.12

A modern, fast, and lightweight integration library written in Rust, designed for memory safety and stability.
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
31
32
33
34

use crate::s3::{s3_client::S3Client, s3_client_config::S3ClientConfig};

#[tokio::test]
async fn client_test() {
    tracing_subscriber::fmt().with_max_level(tracing::Level::INFO).init();
    let config = S3ClientConfig::new("http://127.0.0.1:9000")
    .access_key("minioadmin")
    .secret_key("minioadmin");
    let client = S3Client::new(config);

    let result = client.bucket("test").put_object_bytes("file_test.txt", "text").await;
    tracing::info!("{:?}", result);
    assert!(result.is_ok());

    let result = client.bucket("test").get_object("file_test.txt", "/tmp").await;
    tracing::info!("{:?}", result);
    assert!(result.is_ok());

    let result = client.bucket("test").get_object_bytes("file_test.txt").await;
    tracing::info!("{:?}", result);
    assert!(result.is_ok());

    let result = client.bucket("test").get_objects("/tmp").await;
    tracing::info!("{:?}", result);
    assert!(result.is_ok());

    let result = client.bucket("test").get_objects_with_regex("/tmp", "^file_test.*$").await;
    tracing::info!("{:?}", result);
    assert!(result.is_ok());

    let result = client.bucket("test").delete_object("file_test.txt").await;
    tracing::info!("{:?}", result);
    assert!(result.is_ok());
}