shardd 0.3.0

Official Rust client for shardd — a globally distributed credit ledger with automatic regional failover.
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
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74

//! Run with:
//!   SHARDD_API_KEY=sk_live_... cargo run --example quickstart
//!
//! Creates a credit event, reads it back via list_events + get_balances,
//! then retries the same write to demonstrate idempotency.

use shardd::{Client, CreateEventOptions};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let api_key = std::env::var("SHARDD_API_KEY").expect("set SHARDD_API_KEY in your environment");
    let bucket = std::env::var("SHARDD_BUCKET").unwrap_or_else(|_| "demo".into());

    let client = Client::new(api_key)?;

    // 1. Credit 500 units to user:alice. Fresh UUID nonce — first-write
    //    path, server returns 201.
    let first = client
        .create_event(
            &bucket,
            "user:alice",
            500,
            CreateEventOptions {
                note: Some("sdk quickstart credit".into()),
                ..Default::default()
            },
        )
        .await?;
    println!(
        "credited: event={} balance={} deduplicated={}",
        first.event.event_id, first.balance, first.deduplicated
    );

    // 2. Same logical operation, same nonce — server returns the
    //    original event with deduplicated=true. Use this pattern for
    //    safe retries.
    let replay = client
        .create_event(
            &bucket,
            "user:alice",
            500,
            CreateEventOptions {
                note: Some("sdk quickstart credit".into()),
                idempotency_nonce: Some(first.event.idempotency_nonce.clone()),
                ..Default::default()
            },
        )
        .await?;
    println!(
        "retried:  event={} balance={} deduplicated={}",
        replay.event.event_id, replay.balance, replay.deduplicated
    );
    assert_eq!(first.event.event_id, replay.event.event_id);

    // 3. Read back the bucket.
    let balances = client.get_balances(&bucket).await?;
    for row in &balances.accounts {
        println!(
            "  {} = {} (available {})",
            row.account, row.balance, row.available_balance
        );
    }

    // 4. Inspect edge selection.
    let h = client.health(None).await?;
    println!(
        "pinned edge: {} (region {}, sync_gap {:?})",
        h.edge_id.as_deref().unwrap_or("?"),
        h.region.as_deref().unwrap_or("?"),
        h.sync_gap
    );

    Ok(())
}