ream/storage/kv

Types

KV

pub type KV {
  KV(
    base_path: String,
    name: String,
    memtable_ranges: Map(Int, MemTableRange),
    active_value_file: Option(Int),
    values: Map(Int, ValueFile),
    memtables_loaded: Int,
    max_memtables_loaded: Int,
    max_memtable_size: Int,
    max_value_size: Int,
  )
}

Constructors

KV(
  base_path: String,
  name: String,
  memtable_ranges: Map(Int, MemTableRange),
  active_value_file: Option(Int),
  values: Map(Int, ValueFile),
  memtables_loaded: Int,
  max_memtables_loaded: Int,
  max_memtable_size: Int,
  max_value_size: Int,
)

KVInfo

</>

pub type KVInfo {
  KVInfo(
    base_path: String,
    name: String,
    values: Int,
    values_size_bytes: Int,
    memtables_total: Int,
    memtables_loaded: Int,
    memtables_loaded_size_bytes: Int,
    max_memtables_loaded: Int,
    max_memtable_size: Int,
    max_value_size: Int,
  )
}

Constructors

KVInfo(
  base_path: String,
  name: String,
  values: Int,
  values_size_bytes: Int,
  memtables_total: Int,
  memtables_loaded: Int,
  memtables_loaded_size_bytes: Int,
  max_memtables_loaded: Int,
  max_memtable_size: Int,
  max_value_size: Int,
)

MemTableRange

</>

pub type MemTableRange {
  MemTableRange(
    lower: Int,
    upper: Int,
    memtable: Option(MemTable),
  )
}

Constructors

MemTableRange(lower: Int, upper: Int, memtable: Option(MemTable))

Functions

close

</>

pub fn close(kv: KV) -> Result(Nil, Nil)

flush

</>

pub fn flush(kv: KV) -> Result(Nil, Nil)

get

</>

pub fn get(kv: KV, key: String) -> #(Result(BitString, Nil), KV)

info

</>

pub fn info(kv: KV) -> KVInfo

open

</>

pub fn open(path: String, name: String, max_memtables_loaded: Int, max_memtable_size: Int, max_value_size: Int) -> KV

set

</>

pub fn set(kv: KV, key: String, value: BitString) -> KV