Struct LSMTree 

pub struct LSMTree<K, V> { /* private fields */ }

LSMTree manages a tree of layers to provide a key/value store. Each layer contains deltas on the preceding layer. The top layer is an in-memory mutable layer. Layers can be compacted to form a new combined layer.

Implementations

impl<'tree, K: MergeableKey, V: Value> LSMTree<K, V>

pub fn new( merge_fn: MergeFn<K, V>, cache: Option<Box<dyn ObjectCache<K, V>>>, ) -> Self

Creates a new empty tree.

pub async fn open( merge_fn: MergeFn<K, V>, handles: impl IntoIterator<Item = impl LayerObject + 'static>, cache: Option<Box<dyn ObjectCache<K, V>>>, ) -> Result<Self, Error>

Opens an existing tree from the provided handles to the layer objects.

pub fn set_layers(&self, layers: Vec<Arc<dyn Layer<K, V>>>)

Replaces the immutable layers.

pub async fn append_layers( &self, store: &Arc<ObjectStore>, object_ids: impl IntoIterator<Item = u64>, crypt: Option<Arc<dyn Crypt>>, ) -> Result<u64, Error>

Opens layers for object_ids from store and appends them to the end of the tree (i.e. as base layers). This is supposed to be used after replay when we are opening a tree and we have discovered the base layers.

Returns the sum of the sizes in bytes of all appended layers.

pub fn append_open_layers(&self, layers: Vec<Arc<dyn Layer<K, V>>>)

Appends already-opened layers to the end of the tree.

pub fn reset_immutable_layers(&self)

Resets the immutable layers.

pub fn seal(&self)

Seals the current mutable layer and creates a new one.

pub fn reset(&self)

Resets the tree to an empty state.

pub fn clear_cache(&self)

Clears all in-memory caches (object cache and persistent layer chunk caches) for this tree.

pub fn cache_len(&self) -> usize

pub fn report_compaction_metrics( &self, bytes_written: u64, duration: Duration, layer_count: usize, )

pub fn compaction_bytes_written(&self) -> u64

pub fn empty_layer_set(&self) -> LayerSet<K, V>

Returns an empty layer-set for this tree.

pub fn add_all_layers_to_layer_set(&self, layer_set: &mut LayerSet<K, V>)

Adds all the layers (including the mutable layer) to layer_set.

pub fn layer_set(&self) -> LayerSet<K, V>

Returns a clone of the current set of layers (including the mutable layer), after which one can get an iterator.

pub fn immutable_layer_set(&self) -> LayerSet<K, V>

Returns the current set of immutable layers after which one can get an iterator (for e.g. compacting). Since these layers are immutable, getting an iterator should not block anything else.

pub fn insert(&self, item: Item<K, V>) -> Result<(), Error>

Inserts an item into the mutable layer. Returns error if item already exists.

pub fn replace_or_insert(&self, item: Item<K, V>)

Replaces or inserts an item into the mutable layer.

pub fn merge_into(&self, item: Item<K, V>, lower_bound: &K)

Merges the given item into the mutable layer.

pub async fn find_map<R, F>( &self, search_key: &K, f: F, ) -> Result<Option<R>, Error>

where K: Eq, F: FnOnce(ItemRef<'_, K, V>) -> R,

Searches for an exact match for the given key, applying f to the found ItemRef. If the item does not exist or has a value equal to Value::DELETED_MARKER, returns Ok(None).

Range keys (FuzzyHash::is_range_key) are not supported.

pub fn find( &self, search_key: &K, ) -> impl Future<Output = Result<Option<Item<K, V>>, Error>> + Send

where K: Eq,

Searches for an exact match for the given key. If the item does not exist or has a value equal to Value::DELETED_MARKER, returns Ok(None).

Range keys (FuzzyHash::is_range_key) are not supported.

pub fn find_value( &self, search_key: &K, ) -> impl Future<Output = Result<Option<V>, Error>> + Send

where K: Eq,

Searches for an exact match for the given key, returning only the value. If the item does not exist or has a value equal to Value::DELETED_MARKER, returns Ok(None).

Range keys (FuzzyHash::is_range_key) are not supported.

pub async fn exists(&self, search_key: &K) -> Result<bool, Error>

where K: Eq,

Returns true if an exact match exists for the given key and is not deleted.

Range keys (FuzzyHash::is_range_key) are not supported.

pub fn mutable_layer(&self) -> Arc<SkipListLayer<K, V>>

pub fn set_mutation_callback(&self, mutation_callback: MutationCallback<K, V>)

Sets a mutation callback which is a callback that is triggered whenever any mutations are applied to the tree. This might be useful for tests that want to record the precise sequence of mutations that are applied to the tree.

pub fn get_earliest_version(&self) -> Version

Returns the earliest version used by a layer in the tree.

pub fn new_mutable_layer() -> Arc<SkipListLayer<K, V>>

Returns a new mutable layer.

pub fn set_mutable_layer(&self, layer: Arc<SkipListLayer<K, V>>)

Replaces the mutable layer.

pub fn record_inspect_data(&self, root: &Node)

Records inspect data for the LSM tree into node. Called lazily when inspect is queried.