Website | Rust Doc | Blog | Community

Tonbo is an embedded database for serverless and edge runtimes. Your data is stored as Parquet on S3, coordination happens through a manifest, and compute stays fully stateless.

Serverless compute is stateless, but your data isn't. Tonbo bridges this gap:

• Async-first: The entire storage and query engine is fully async, built for serverless and edge environments.
• No server to manage: Data lives on S3, coordination via manifest, compute is stateless
• Arrow-native: Define rich data type, declarative schemas, query with zero-copy RecordBatch
• Runs anywhere: Tokio, WASM, edge runtimes, or as a storage engine for building your own data infrastructure.
• Open formats: Standard Parquet files readable by any tool

• Build serverless or edge applications that need a durable state layer without running a database.
• Store append-heavy or event-like data directly in S3 and query it with low overhead.
• Embed a lightweight MVCC + Parquet storage engine inside your own data infrastructure.
• Run workloads in WASM or Cloudflare Workers that require structured persistence.

use tonbo::{db::{AwsCreds, ObjectSpec, S3Spec}, prelude::*};

#[derive(Record)]
struct User {
    #[metadata(k = "tonbo.key", v = "true")]
    id: String,
    name: String,
    score: Option<i64>,
}

// Open on S3
let s3 = S3Spec::new("my-bucket", "data/users", AwsCreds::from_env()?);
let db = DbBuilder::from_schema(User::schema())?
    .object_store(ObjectSpec::s3(s3))?.open().await?;

// Insert
let users = vec![User { id: "u1".into(), name: "Alice".into(), score: Some(100) }];
let mut builders = User::new_builders(users.len());
builders.append_rows(users);
db.ingest(builders.finish().into_record_batch()).await?;

// Query
let filter = Predicate::gt(ColumnRef::new("score"), ScalarValue::from(80_i64));
let results = db.scan().filter(filter).collect().await?;

For local development, use .on_disk("/tmp/users")? instead. See examples/ for more.

cargo add [email protected] tokio

Or add to Cargo.toml:

[dependencies]
tonbo = "0.4.0-a0"
tokio = { version = "1", features = ["rt-multi-thread", "macros"] }

Run with cargo run --example <name>:

• 01_basic: Define schema, insert, and query in 30 lines
• 02_transaction: MVCC transactions with upsert, delete, and read-your-writes
• 02b_snapshot: Consistent point-in-time reads while writes continue
• 03_filter: Predicates: eq, gt, in, is_null, and, or, not
• 04_s3: Store Parquet files on S3/R2/MinIO with zero server config
• 05_scan_options: Projection pushdown reads only the columns you need
• 06_composite_key: Multi-column keys for time-series and partitioned data
• 07_streaming: Process millions of rows without loading into memory
• 08_nested_types: Deep struct nesting + Lists stored as Arrow StructArray
• 09_time_travel: Query historical snapshots via MVCC timestamps

Tonbo implements a merge-tree optimized for object storage: writes go to WAL → MemTable → Parquet SSTables, with MVCC for snapshot isolation and a manifest for coordination via compare-and-swap:

• Stateless compute: A worker only needs to read and update the manifest; no long-lived coordinator is required.
• Object storage CAS: The manifest is committed using compare-and-swap on S3, so any function can safely participate in commits.
• Immutable data: Data files are write-once Parquet SSTables, which matches the strengths of S3 and other object stores.

See docs/overview.md for the full design.

Install coverage tooling once:

rustup component add llvm-tools-preview
cargo install cargo-llvm-cov --version 0.6.12 --locked

Run coverage locally:

cargo llvm-cov --workspace --lcov --output-path lcov.info --summary

Generate an HTML report:

cargo llvm-cov --workspace --html

Tonbo is currently in alpha. APIs may change, and we're actively iterating based on feedback. We recommend starting with development and non-critical workloads before moving to production.

Storage

Schema & Query

Backends

Runtime

Integrations

Apache License 2.0. See LICENSE for details.