Distributed
Key-Value
Storage

use rustkvd_client::{KVClient};

async fn main() -> Result<()> {
    let mut client = KVClient::connect("http://127.0.0.1:7001").await?;

    match client.get("greeting").await? {
        Some(value) => {
            println!("value: {}", String::from_utf8_lossy(&value));
        }
        None => println!("key not found"),
    }
    Ok(())
}

use rustkvd_client::{KVClient};
use futures::StreamExt;

async fn main() -> Result<()> {
    let mut client = KVClient::connect("http://127.0.0.1:7001").await?;

    // Server-streaming watch — yields on every change
    let mut stream = client.watch("config:flags").await?;

    while let Some(event) = stream.next().await {
        let ev = event?;
        println!("[{}] {} → {:?}", ev.event_type, ev.key, ev.value);
    }
    Ok(())
}

use rustkvd_client::{KVClient};

async fn main() -> Result<()> {
    let mut client = KVClient::connect("http://127.0.0.1:7001").await?;

    // Scan a key range with limit
    let pairs = client
        .scan("user:", "user:~", 100)
        .await?;

    for pair in pairs {
        println!("{} → {}",
            pair.key,
            String::from_utf8_lossy(&pair.value));
    }
    Ok(())
}

use rustkvd_client::{KVClient};

async fn main() -> Result<()> {
    let mut client = KVClient::connect("http://127.0.0.1:7001").await?;

    // Delete a key (writes a tombstone into LSM)
    client.delete("session:abc").await?;

    println!("✓ Deleted");
    Ok(())
}