Skip to main content

MetaFile

Struct MetaFile 

Source
pub struct MetaFile { /* private fields */ }
Expand description

§Safety

entries must be declared before mmap so that Rust’s field drop order (declaration order) drops all FilterRefs before the mmap is unmapped. Reordering these fields would be unsound.

Implementations§

Source§

impl MetaFile

Source

pub fn open(db_path: &Path, sequence_number: u32) -> Result<Self>

Opens a meta file at the given path. Memory maps the entire file and eagerly deserializes all AMQF filters as zero-copy [qfilter::FilterRef]s that borrow from the mmap.

Source

pub fn clear_cache(&mut self)

Source

pub fn prepare_sst_cache(&self)

Source

pub fn sequence_number(&self) -> u32

Source

pub fn family(&self) -> u32

Source

pub fn entries(&self) -> &[MetaEntry]

Source

pub fn entry(&self, index: u32) -> &MetaEntry

Source

pub fn amqf_data(&self) -> &[u8]

Source

pub fn deserialize_used_key_hashes_amqf(&self) -> Result<Option<FilterRef<'_>>>

Source

pub fn retain_entries(&mut self, predicate: impl FnMut(u32) -> bool) -> bool

Source

pub fn obsolete_entries(&self) -> &[u32]

Source

pub fn has_active_entries(&self) -> bool

Source

pub fn obsolete_sst_files(&self) -> &[u32]

Source

pub fn lookup<K: QueryKey, const FIND_ALL: bool>( &self, key_family: u32, key_hash: u64, key: &K, key_block_cache: &BlockCache, value_block_cache: &BlockCache, ) -> Result<MetaLookupResult>

Looks up a key in this meta file.

If FIND_ALL is false, returns after finding the first match. If FIND_ALL is true, returns all entries with the same key from all SST files (useful for keyspaces where keys are hashes and collisions are possible).

Source

pub fn batch_lookup<K: QueryKey>( &self, key_family: u32, keys: &[K], cells: &mut [(u64, usize, Option<LookupValue>)], empty_cells: &mut usize, key_block_cache: &BlockCache, value_block_cache: &BlockCache, ) -> Result<MetaBatchLookupResult>

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

§

impl<T> Instrument for T

§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more
§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<T> WithSubscriber for T

§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a [WithDispatch] wrapper. Read more
§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more