Struct MemQuadStorage 

pub struct MemQuadStorage { /* private fields */ }

A memory-based quad storage.

Implementations

impl MemQuadStorage

pub fn new( object_id_mapping: Arc<MemObjectIdMapping>, batch_size: usize, ) -> MemQuadStorage

Creates a new MemQuadStorage with the given object_id_mapping.

pub async fn snapshot(&self) -> MemQuadStorageSnapshot

Creates a snapshot of this storage.

Trait Implementations

impl QuadStorage for MemQuadStorage

fn encoding(&self) -> QuadStorageEncoding

Returns the quad storage encoding.

fn object_id_mapping(&self) -> Option<Arc<dyn ObjectIdMapping>>

Returns a reference to the used ObjectIdMapping.

fn planners<'life0, 'life1, 'async_trait>( &'life0 self, _context: &'life1 RdfFusionContextView, ) -> Pin<Box<dyn Future<Output = Vec<Arc<dyn ExtensionPlanner + Send + Sync>>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemQuadStorage: 'async_trait,

Returns a list of planners that support planning logical nodes requiring access to the storage layer.

fn extend<'life0, 'async_trait>( &'life0 self, quads: Vec<Quad>, ) -> Pin<Box<dyn Future<Output = Result<usize, StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, MemQuadStorage: 'async_trait,

Loads the given quads into the storage.

fn remove<'life0, 'life1, 'async_trait>( &'life0 self, quad: QuadRef<'life1>, ) -> Pin<Box<dyn Future<Output = Result<bool, StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemQuadStorage: 'async_trait,

Removes the given quad from the storage.

fn insert_named_graph<'a, 'life0, 'async_trait>( &'life0 self, graph_name: NamedOrBlankNodeRef<'a>, ) -> Pin<Box<dyn Future<Output = Result<bool, StorageError>> + Send + 'async_trait>>

where 'a: 'async_trait, 'life0: 'async_trait, MemQuadStorage: 'async_trait,

Creates an empty named graph in the storage.

fn named_graphs<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<NamedOrBlankNode>, StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, MemQuadStorage: 'async_trait,

Returns the list of named graphs in the storage.

fn contains_named_graph<'a, 'life0, 'async_trait>( &'life0 self, graph_name: NamedOrBlankNodeRef<'a>, ) -> Pin<Box<dyn Future<Output = Result<bool, StorageError>> + Send + 'async_trait>>

where 'a: 'async_trait, 'life0: 'async_trait, MemQuadStorage: 'async_trait,

Returns whether graph_name is a named graph in the storage.

fn clear<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, MemQuadStorage: 'async_trait,

Clears the entire storage.

fn clear_graph<'a, 'life0, 'async_trait>( &'life0 self, graph_name: GraphNameRef<'a>, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

where 'a: 'async_trait, 'life0: 'async_trait, MemQuadStorage: 'async_trait,

Clears the entire graph.

fn drop_named_graph<'life0, 'life1, 'async_trait>( &'life0 self, graph_name: NamedOrBlankNodeRef<'life1>, ) -> Pin<Box<dyn Future<Output = Result<bool, StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemQuadStorage: 'async_trait,

Removes the entire named graph from the storage.

fn len<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<usize, StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, MemQuadStorage: 'async_trait,

Returns the number of quads in the storage.

fn optimize<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, MemQuadStorage: 'async_trait,

Optimizes the storage (e.g., building indices).

fn validate<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, MemQuadStorage: 'async_trait,

Validates invariants in the store