Disable the WAL and drop the writer. Does not delete the WAL file.

Enable the WAL with an explicit path. Idempotent: if called twice with the same path, the second call is a no-op.

Replay all durable WAL entries into storage. Returns the count of entries successfully applied. Requires the WAL to be enabled. The WAL writer is tem

Insert a vector into the index, associated with the given row_id.

Write `rows` to `path` using `columns` as the schema. All rows must have the same arity as `columns`.

Append a row at the given LSN. Returns the row's position within the memtable (stable until freeze/drain).

Append a frame AND fsync it in a single locked section. This is the concurrency-safe path and the one production callers must use. The naive compositi

Allocate a string into the arena. Returns an ArenaStr reference.

Fast table lookup: acquires outer read lock briefly, clones the Arc, releases. The caller then works with the per-table lock independently.

Format to text representation (for wire protocol).

Collect all entries into a Vec. Convenience for recovery.

Append an operation and return the assigned LSN. Does NOT fsync. Call `flush_sync` to make writes durable. LSN assignment is done INSIDE the writer l

Resolve a column reference to an index into the joined row.

Resolve an ArenaVec to &[f32].

Internal: execute a SELECT and return raw ArenaValue rows + column metadata.

Parse SQL and return a JSON summary of statement types.

Find a column by name. Case-sensitive.

Fully qualified table name.

Shared append + fsync path. Returns the assigned LSN on success, or None if the WAL is disabled (making this a no-op for callers). Goes through `appe

Evaluate constant expression to i64 (for LIMIT/OFFSET).

Read all entries from the configured WAL file. Used for recovery. Returns an empty vec if WAL is disabled or the file doesn't exist.

Mark a row as deleted. Storage stays allocated until flush.

Extract function name from FuncCall node.

Convert back to storage Value (allocates Arc/Vec on heap). Used at boundaries: arena → wire protocol, arena → storage.

Append an Insert entry. No-op when WAL is disabled. Fsyncs before returning so the write is durable.

Compare two rows by SortKey list for ordering.

Parse vector literal string "[1.0, 2.0, ...]" to Value::Vector.

Search for K nearest neighbors. Returns (distance, row_id) sorted ascending.

Get the type OID for a column index in a JoinContext.

Evaluate constant expressions (literals, simple operations).

DML bridge: evaluate WHERE clause on Value rows using a shared arena.

Extract operator name from protobuf nodes.

Flush any pending writes and fsync to disk. This is the durability boundary: on success, every frame appended since the last successful flush_sync is

Hash with arena context (for GROUP BY keys).

Unchecked, non-logging insert used ONLY by recovery replay. Writes the row and also updates unique/PK indexes so that post-recovery constraint checks

Open or create a WAL file at `path`. Existing content is preserved (appended to); `next_lsn` starts at 1 unless `starting_lsn` is set by the caller af

Roll the writer's state back to the last durable boundary. Used by both `append` + `flush_sync` and `append_sync` on any I/O failure so a later succes

Allocate a vector (f32 slice) into the arena.

Deduplicate rows when DISTINCT is present.

Convert a slice of storage rows to arena rows.

Append a Delete entry keyed by the full row values.

Boot the WAL subsystem from environment variables. Extracted from `on_load` so cargo tests can exercise the same path the NIF loader takes, since `on_

Validate NOT NULL constraints on inserted/updated row.

Register an empty storage slot for a new table. Returns Err if a slot already exists at `schema.name` instead of silently replacing it — a duplicate c

Drain all rows and reset the memtable. Used by flush after the caller has successfully written a segment file. Returns only live rows; tombstones are

Evaluate RETURNING clause expressions for affected rows.

Execute FROM clause node and return joined rows with JoinContext.

Strict less-than comparison for zone map tracking. Only defined for the ordered scalar types; Vector/Bytea/Null return false.

Overwrite the frame_len header of the Nth frame (0-indexed) with `value`. Walks the preceding frames using their on-disk lengths so the seek lands on

Parse a sequence name that may be schema-qualified.

Read all rows by reconstructing the row-oriented view. Useful for full-table scans and tests. For production SELECTs, prefer `read_column` to scan onl

Iterate live (non-tombstoned) rows in insertion order.

Zero-copy scan: runs callback with borrowed rows, avoids cloning.

Replace a row's values in place at the given LSN. The row must not already be tombstoned.

Add a row's values to all applicable indexes.