Struct Transaction 

pub struct Transaction<'a> { /* private fields */ }

A database transaction.

Implementations

impl<'a> Transaction<'a>

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>>

カラムナーセグメントを読み取る（トランザクションコンテキスト利用）。

impl<'a> Transaction<'a>

pub fn get(&mut self, key: &[u8]) -> Result<Option<Vec<u8>>>

Retrieves the value for a given key.

pub fn put(&mut self, key: &[u8], value: &[u8]) -> Result<()>

Sets a value for a given key.

pub fn delete(&mut self, key: &[u8]) -> Result<()>

Deletes a key-value pair.

pub fn upsert_to_hnsw( &mut self, index_name: &str, key: &[u8], vector: &[f32], metadata: &[u8], ) -> Result<()>

HNSW にベクトルをステージング挿入/更新する。

pub fn delete_from_hnsw(&mut self, index_name: &str, key: &[u8]) -> Result<bool>

HNSW からキーをステージング削除する。

pub fn upsert_vector( &mut self, key: &[u8], metadata: &[u8], vector: &[f32], metric: Metric, ) -> Result<()>

Upserts a vector and metadata under the provided key after validating dimensions and metric.

A small internal index is maintained to enable scanning for similarity search.

pub fn search_similar( &mut self, query_vector: &[f32], metric: Metric, top_k: usize, filter_keys: Option<&[Key]>, ) -> Result<Vec<SearchResult>>

Executes a flat similarity search over stored vectors using the provided metric and query.

The optional filter_keys restricts the scan to the given keys; otherwise the full vector index is scanned. Results are sorted by descending score and truncated to top_k.

pub fn commit(self) -> Result<()>

Commits the transaction, applying all changes.

pub fn rollback(self) -> Result<()>

Rolls back the transaction, discarding all changes.

Trait Implementations

impl<'a> Drop for Transaction<'a>

fn drop(&mut self)

Executes the destructor for this type.