Hyperbee

A append-only B-tree running built on Hypercore. Compatible with the JavaScript version.

$ cargo add hyperbee

Usage

From the examples:

use hyperbee::Hyperbee;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let mut hb = Hyperbee::from_ram().await?;
    // Insert "world" with key "hello"
    hb.put(b"hello", Some(b"world")).await?;

    // Get the value for key "hello"
    let Some((_seq, Some(val)))  = hb.get(b"hello").await? else {
        panic!("could not get value");
    };
    assert_eq!(val, b"world");

    // Trying to get a non-exsitant key returns None
    let res = hb.get(b"no key here").await?;
    assert_eq!(res, None);

    // deleting a key returns `true` if it was present
    let res = hb.del(b"hello").await?;
    assert_eq!(res, true);
    Ok(())
}

Parity with JS Hyperbee

• full functional interoperability with JS Hyperbee files
• read, write, and delete operations
• in order key streaming like JS's createReadStream
• [] support gt, lt, etc bounds for key streaming
• [] accept compare-and-swap for put and del.
• [] support prefixed key operations like JS's sub
• [] one-to-one binary output

Future work

• [] Build FFI wrappers
• [] improved wire format
• [] configurable tree parameters

Development

Integration test data is generated by the the code in gen_test_data. Generate the test data with:

$ cd gen_test_data && yarn install && yarn node index.js && popd

Then you can run the tests with $ cargo test.