README
- ::addPersistentDB::add
- ::checkpointPersistentDB::checkpoint
- ::compactPersistentDB::compact
- ::count_filteredPersistentDB::count_filtered
- ::deserializePersistentDB::deserialize
- ::dimPersistentDB::dim
- ::findPersistentDB::find
- ::from_snapshotPersistentDB::from_snapshot
- ::getPersistentDB::get
- ::hasPersistentDB::has
- ::in_memoryPersistentDB::in_memory
- ::in_memory_bruteforcePersistentDB::in_memory_bruteforce
- ::in_memory_hnswPersistentDB::in_memory_hnsw
- ::in_memory_ivfPersistentDB::in_memory_ivf
- ::initPersistentDB::init
- ::metricPersistentDB::metric
- ::raw_sizePersistentDB::raw_size
- ::removePersistentDB::remove
- ::scrollPersistentDB::scroll
- ::scroll_filteredPersistentDB::scroll_filtered
- ::searchPersistentDB::search
- ::search_with_exprPersistentDB::search_with_expr
- ::search_with_filterPersistentDB::search_with_filter
- ::serialize_snapshotPersistentDB::serialize_snapshot
- ::sizePersistentDB::size
- ::storePersistentDB::store
- ::strategyPersistentDB::strategy
- ::trainPersistentDB::train
- ::update_attrsPersistentDB::update_attrs
- ::upsertPersistentDB::upsert
- ::wal_byte_sizePersistentDB::wal_byte_size
- ::wal_record_countPersistentDB::wal_record_count
- ::addVectorDB::add
- ::compactVectorDB::compact
- ::count_filteredVectorDB::count_filtered
- ::deserializeVectorDB::deserialize
- ::dimVectorDB::dim
- ::export_jsonlVectorDB::export_jsonl
- ::findVectorDB::find
- ::from_storeVectorDB::from_store
- ::getVectorDB::get
- ::hasVectorDB::has
- ::metricVectorDB::metric
- ::newVectorDB::new
- ::raw_sizeVectorDB::raw_size
- ::removeVectorDB::remove
- ::scrollVectorDB::scroll
- ::scroll_filteredVectorDB::scroll_filtered
- ::searchVectorDB::search
- ::search_with_exprVectorDB::search_with_expr
- ::serializeVectorDB::serialize
- ::sizeVectorDB::size
- ::storeVectorDB::store
- ::strategyVectorDB::strategy
- ::trainVectorDB::train
- ::update_attrsVectorDB::update_attrs
- ::upsertVectorDB::upsert
- ::with_dimVectorDB::with_dim
- ::with_hnswVectorDB::with_hnsw
- ::with_ivfVectorDB::with_ivf
V
empty_attrs

#core/store

CoreStore provides contiguous vector storage with id-to-index mapping.

#Features

Compact storage: vectors stored in flat Array[Double] with strided access
Automatic normalization for cosine metric
O(1) compaction on remove via swap-with-last
Id-to-index mapping for fast lookups

#Usage

let store = CoreStore::new(128, @types.Cosine, capacity=1024)

// Add vector
store.add(id, vector, attrs)

// Get vector at index
let (vec, attrs) = store.get_at(idx)

// Remove by id
store.remove(id)

CoreStore

source

pub struct CoreStore {
  dim : Int
  metric : @trkbt10/vcdb/core/types.Metric
Metric
  ids : Array[@trkbt10/vcdb/core/types.VectorId
VectorId]
  data : Array[Double]
  attrs : Array[@trkbt10/vcdb/core/types.Attrs
Attrs]
  pos : Map[@trkbt10/vcdb/core/types.VectorId
VectorId, Int]
  capacity : Int
  count : Int
}

CoreStore: contiguous vector storage + id mapping. Provides a compact foundation for both bruteforce and approximate search. Normalizes vectors for cosine metric, maintains id->index mapping, and supports O(1) compaction on remove.

CoreStore::add_or_update

source

fn CoreStore::add_or_update(self : CoreStore, id : @trkbt10/vcdb/core/types.VectorId
VectorId, vector : Array[Double], attrs : @trkbt10/vcdb/core/types.Attrs
Attrs, upsert? : Bool) -> (Int, Bool)

Add or update a vector. Returns (index, created). If upsert is false and id exists, raises error.

CoreStore::capacity

source

fn CoreStore::capacity(self : CoreStore) -> Int

Get the current capacity

CoreStore::deserialize

source

fn CoreStore::deserialize(data : Bytes) -> CoreStore

Deserialize CoreStore from bytes

CoreStore::ensure_capacity

source

fn CoreStore::ensure_capacity(self : CoreStore, extra : Int) -> Bool

Ensure capacity for additional elements

CoreStore::get

source

fn CoreStore::get(self : CoreStore, id : @trkbt10/vcdb/core/types.VectorId
VectorId) -> @trkbt10/vcdb/core/types.VectorRecord
VectorRecord?

Get vector and attrs by id

CoreStore::get_by_index

source

fn CoreStore::get_by_index(self : CoreStore, index : Int) -> @trkbt10/vcdb/core/types.VectorRecord
VectorRecord

Get vector and attrs by index

CoreStore::get_index

source

fn CoreStore::get_index(self : CoreStore, id : @trkbt10/vcdb/core/types.VectorId
VectorId) -> Int?

Get index for an id

CoreStore::has

source

fn CoreStore::has(self : CoreStore, id : @trkbt10/vcdb/core/types.VectorId
VectorId) -> Bool

Check if an id exists in the store

CoreStore::id_at

source

fn CoreStore::id_at(self : CoreStore, index : Int) -> @trkbt10/vcdb/core/types.VectorId
VectorId?

Get vector ID by index.

CoreStore::new

source

fn CoreStore::new(dim : Int, metric : @trkbt10/vcdb/core/types.Metric
Metric, capacity? : Int) -> CoreStore

Create a new CoreStore

CoreStore::normalize_query

source

fn CoreStore::normalize_query(self : CoreStore, q : Array[Double]) -> Array[Double]

Normalize query vector for cosine metric

CoreStore::remove_by_id

source

fn CoreStore::remove_by_id(self : CoreStore, id : @trkbt10/vcdb/core/types.VectorId
VectorId) -> MoveInfo?

Remove a vector by id. Returns move info if compaction occurred.

CoreStore::serialize

source

fn CoreStore::serialize(self : CoreStore) -> Bytes

Serialize CoreStore to bytes

CoreStore::shrink_to_fit

source

fn CoreStore::shrink_to_fit(self : CoreStore) -> Unit

Shrink backing arrays to fit current count

CoreStore::size

source

fn CoreStore::size(self : CoreStore) -> Int

Get the current size (number of vectors)

CoreStore::update_attrs

source

fn CoreStore::update_attrs(self : CoreStore, id : @trkbt10/vcdb/core/types.VectorId
VectorId, attrs : @trkbt10/vcdb/core/types.Attrs
Attrs) -> Bool

Update only attrs for an id. Returns true if updated.

MoveInfo

source

pub struct MoveInfo {
  moved_id : @trkbt10/vcdb/core/types.VectorId
VectorId?
  moved_from : Int?
  moved_to : Int?
} derive(@moonbitlang/core/debug.Debug
Debug)