daoxide 0.1.1

High-performance Rust library for DAOS (Distributed Asynchronous Object Storage)
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
35
36
37
38
39
40
41
42
43

//! Example: Minimal DAOS client using the facade API
//!
//! This example demonstrates connecting to DAOS and performing basic
//! key-value operations using the high-level facade API.
//!
//! # Running
//!
//! ```ignore
//! # Note: Requires a running DAOS environment
//!
//! cargo run --example minimal_client --features daos-rs/...
//! ```

use daoxide::prelude::*;

fn main() -> daoxide::Result<()> {
    // Connect to DAOS pool and container
    let client = DaosClient::builder()
        .pool_label("mypool")
        .container_label("mycontainer")
        .build()?;

    // Allocate a new object
    let oid = client.alloc_oid(
        ObjectType::KvHashed,
        ObjectClass::UNKNOWN,
        ObjectClassHints::NONE,
    )?;

    // Store a value
    client.put(oid, b"dkey1", b"akey1", b"hello world")?;

    // Retrieve the value
    let mut buffer = vec![0u8; 1024];
    client.get(oid, b"dkey1", b"akey1", &mut buffer[..11])?;

    println!("Retrieved: {:?}", String::from_utf8_lossy(&buffer[..11]));

    // Delete the key
    client.delete(oid, Some(b"dkey1"), None, Tx::none())?;

    Ok(())
}