Struct Database 

pub struct Database { /* private fields */ }

The main database object.

Implementations

impl Database

pub fn open_with_config(config: EmbeddedConfig) -> Result<Self>

構成付きでデータベースを開く（カラムナー機能を初期化）。

pub fn storage_mode(&self) -> StorageMode

現在のカラムナーストレージモードを返す。

pub fn write_columnar_segment( &self, table: &str, batch: RecordBatch, ) -> Result<u64>

カラムナーセグメントを書き込む。

pub fn read_columnar_segment( &self, table: &str, segment_id: u64, columns: Option<&[&str]>, ) -> Result<Vec<RecordBatch>>

カラムナーセグメントを読み取る（カラム名指定オプション付き）。

pub fn in_memory_usage(&self) -> Option<u64>

InMemory モード時のメモリ使用量を返す。Disk モードでは None。

pub fn open_in_memory_with_limit(limit: usize) -> Result<Self>

メモリ上限付きでインメモリ DB を開く。

pub fn resolve_table_id(&self, table: &str) -> Result<u32>

テーブル名から内部 ID を解決する。

pub fn flush_in_memory_segment_to_file( &self, table: &str, segment_id: u64, path: &Path, ) -> Result<()>

InMemory モードのセグメントをファイルへフラッシュする。

pub fn flush_in_memory_segment_to_kvs( &self, table: &str, segment_id: u64, ) -> Result<u64>

InMemory モードのセグメントを KVS へフラッシュする。

pub fn flush_in_memory_segment_to_alopex( &self, table: &str, segment_id: u64, writer: &mut AlopexFileWriter, ) -> Result<u32>

InMemory モードのセグメントを .alopex ファイルへフラッシュする。

impl Database

pub fn open(path: &Path) -> Result<Self>

Opens a database at the specified path.

pub fn new() -> Self

Creates a new, purely in-memory (transient) database.

pub fn open_in_memory() -> Result<Self>

Opens a database in in-memory mode with default options.

pub fn open_in_memory_with_options(opts: DatabaseOptions) -> Result<Self>

Opens a database in in-memory mode with the given options.

pub fn flush(&self) -> Result<()>

Flushes the current in-memory data to an SSTable on disk (beta).

pub fn memory_usage(&self) -> Option<MemoryStats>

Returns current memory usage statistics (in-memory KV only).

pub fn persist_to_disk(&self, wal_path: &Path) -> Result<()>

Persists the current in-memory database to disk atomically.

wal_path は「データディレクトリ」として扱う（file-mode）。

pub fn clone_to_memory(&self) -> Result<Self>

Creates a fully in-memory clone of the current database.

pub fn clear(&self) -> Result<()>

Clears all data while keeping the database usable.

pub fn set_memory_limit(&self, bytes: Option<usize>)

Updates the memory limit in bytes for the underlying in-memory store.

pub fn snapshot(&self) -> Vec<(Key, Vec<u8>)>

Returns a read-only snapshot of all key-value pairs.

pub fn create_hnsw_index(&self, name: &str, config: HnswConfig) -> Result<()>

HNSW インデックスを作成し、永続化する。

pub fn drop_hnsw_index(&self, name: &str) -> Result<()>

HNSW インデックスを削除する。

pub fn get_hnsw_stats(&self, name: &str) -> Result<HnswStats>

HNSW 統計情報を取得する。

pub fn compact_hnsw_index(&self, name: &str) -> Result<CompactionResult>

HNSW インデックスをコンパクションし、結果を返す。

pub fn search_hnsw( &self, name: &str, query: &[f32], k: usize, ef_search: Option<usize>, ) -> Result<(Vec<HnswSearchResult>, HnswSearchStats)>

HNSW インデックスに検索を行う。

pub fn create_blob_writer( &self, path: &Path, total_len: u64, chunk_size: Option<u32>, ) -> Result<LargeValueWriter>

Creates a chunked large value writer for opaque blobs (beta).

pub fn create_typed_writer( &self, path: &Path, type_id: u16, total_len: u64, chunk_size: Option<u32>, ) -> Result<LargeValueWriter>

Creates a chunked large value writer for typed payloads (beta).

pub fn open_large_value(&self, path: &Path) -> Result<LargeValueReader>

Opens a chunked large value reader (beta). Kind/type is read from the file header.

pub fn begin(&self, mode: TxnMode) -> Result<Transaction<'_>>

Begins a new transaction.

Trait Implementations

impl Default for Database

fn default() -> Self

Returns the “default value” for a type.