nano-hyperloglog 0.1.0

A Redis-compatible HyperLogLog service with pluggable storage backends
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

//! Example using file-based storage backend.

use hyperloglog::{HyperLogLog, storage::FileStorage, Storage};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // Create file storage in a temporary directory
    let storage_path = std::env::temp_dir().join("hll_example");
    let storage = FileStorage::new(&storage_path).await?;

    println!("Using file storage at: {}", storage_path.display());

    // Create and populate a HyperLogLog
    let mut hll = HyperLogLog::new(14)?;
    for i in 0..1000 {
        hll.add_str(&format!("user_{}", i));
    }

    let count_before = hll.count();
    println!("Created HLL with estimated count: {}", count_before);

    // Store it
    storage.store("daily_visitors", &hll).await?;
    println!("Stored HLL to disk");

    // Check if it exists
    let exists = storage.exists("daily_visitors").await?;
    println!("Key exists: {}", exists);

    // Load it back
    let loaded_hll = storage.load("daily_visitors").await?;
    let count_after = loaded_hll.count();

    println!("Loaded HLL with estimated count: {}", count_after);
    println!("Counts match: {}", count_before == count_after);

    // List all keys
    let keys = storage.list_keys().await?;
    println!("All keys in storage: {:?}", keys);

    // Clean up
    storage.delete("daily_visitors").await?;
    println!("Cleaned up storage");

    Ok(())
}