Struct rerun::dataframe::StorageEngine

pub struct StorageEngine {
    store: ChunkStoreHandle,
    cache: QueryCacheHandle,
}

Keeps track of handles towards a ChunkStore and its QueryCache.

A StorageEngine doesn’t add any feature on top of what ChunkStoreHandle and QueryCacheHandle already offer: the job of the StorageEngine is to leverage the type system in order to protect against deadlocks and race conditions at compile time.

The handles stored within will never be publicly accessible past construction.

The underlying ChunkStore and QueryCache can be accessed through one of the following methods:

• StorageEngine::read
• StorageEngine::read_arc
• StorageEngine::write
• StorageEngine::write_arc

Fields

store: ChunkStoreHandle

cache: QueryCacheHandle

Implementations

impl StorageEngine

pub unsafe fn new( store: ChunkStoreHandle, cache: QueryCacheHandle ) -> StorageEngine

Creates a new StorageEngine with the specified ChunkStore and QueryCache handles.

Safety

It is the responsibility of the caller to make sure that the given handles have not escaped anywhere else before constructing this type, otherwise the StorageEngine cannot make any safety guarantees.

impl StorageEngine

pub fn read(&self) -> StorageEngineReadGuard<'_>

pub fn try_read(&self) -> Option<StorageEngineReadGuard<'_>>

pub fn try_read_arc(&self) -> Option<StorageEngineArcReadGuard>

pub fn write(&self) -> StorageEngineWriteGuard<'_>

pub fn try_write(&self) -> Option<StorageEngineWriteGuard<'_>>

pub fn read_arc(&self) -> StorageEngineArcReadGuard

pub fn write_arc(&self) -> StorageEngineArcWriteGuard

pub fn try_write_arc(&self) -> Option<StorageEngineArcWriteGuard>

Trait Implementations

impl Clone for StorageEngine

fn clone(&self) -> StorageEngine

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl StorageEngineLike for StorageEngine

fn with<F, R>(&self, f: F) -> R

where F: FnOnce(&ChunkStore, &QueryCache) -> R,

fn try_with<F, R>(&self, f: F) -> Option<R>

where F: FnOnce(&ChunkStore, &QueryCache) -> R,