Struct terminus_store::store::sync::SyncStoreLayer
source · pub struct SyncStoreLayer { /* private fields */ }
Expand description
A layer that keeps track of the store it came out of, allowing the creation of a layer builder on top of this layer.
This type of layer supports querying what was added and what was removed in this layer. This can not be done in general, because the layer that has been loaded may not be the layer that was originally built. This happens whenever a rollup is done. A rollup will create a new layer that bundles the changes of various layers. It allows for more efficient querying, but loses the ability to do these delta queries directly. In order to support them anyway, the SyncStoreLayer will dynamically load in the relevant files to perform the requested addition or removal query method.
Implementations§
source§impl SyncStoreLayer
impl SyncStoreLayer
sourcepub fn open_write(&self) -> Result<SyncStoreLayerBuilder, Error>
pub fn open_write(&self) -> Result<SyncStoreLayerBuilder, Error>
Create a layer builder based on this layer.
sourcepub fn parent(&self) -> Result<Option<SyncStoreLayer>, Error>
pub fn parent(&self) -> Result<Option<SyncStoreLayer>, Error>
Returns the parent of this layer, if any, or None if this layer has no parent.
pub fn squash_upto( &self, upto: &SyncStoreLayer ) -> Result<SyncStoreLayer, Error>
sourcepub fn squash(&self) -> Result<SyncStoreLayer, Error>
pub fn squash(&self) -> Result<SyncStoreLayer, Error>
Create a new base layer consisting of all triples in this layer, as well as all its ancestors.
It is a good idea to keep layer stacks small, meaning, to only have a handful of ancestors for a layer. The more layers there are, the longer queries take. Squash is one approach of accomplishing this. Rollup is another. Squash is the better option if you do not care for history, as it throws away all data that you no longer need.
sourcepub fn rollup(&self) -> Result<(), Error>
pub fn rollup(&self) -> Result<(), Error>
Create a new rollup layer which rolls up all triples in this layer, as well as all its ancestors.
It is a good idea to keep layer stacks small, meaning, to only have a handful of ancestors for a layer. The more layers there are, the longer queries take. Rollup is one approach of accomplishing this. Squash is another. Rollup is the better option if you need to retain history.
sourcepub fn rollup_upto(&self, upto: &SyncStoreLayer) -> Result<(), Error>
pub fn rollup_upto(&self, upto: &SyncStoreLayer) -> Result<(), Error>
Create a new rollup layer which rolls up all triples in this layer, as well as all ancestors up to (but not including) the given ancestor.
It is a good idea to keep layer stacks small, meaning, to only have a handful of ancestors for a layer. The more layers there are, the longer queries take. Rollup is one approach of accomplishing this. Squash is another. Rollup is the better option if you need to retain history.
sourcepub fn imprecise_rollup_upto(&self, upto: &SyncStoreLayer) -> Result<(), Error>
pub fn imprecise_rollup_upto(&self, upto: &SyncStoreLayer) -> Result<(), Error>
Like rollup_upto, rolls up upto the given layer. However, if this layer is a rollup layer, this will roll up upto that rollup.
sourcepub fn triple_addition_exists(
&self,
subject: u64,
predicate: u64,
object: u64
) -> Result<bool>
pub fn triple_addition_exists( &self, subject: u64, predicate: u64, object: u64 ) -> Result<bool>
Returns true if this triple has been added in this layer, or false if it doesn’t.
Since this operation will involve io when this layer is a rollup layer, io errors may occur.
sourcepub fn triple_removal_exists(
&self,
subject: u64,
predicate: u64,
object: u64
) -> Result<bool>
pub fn triple_removal_exists( &self, subject: u64, predicate: u64, object: u64 ) -> Result<bool>
Returns true if this triple has been removed in this layer, or false if it doesn’t.
Since this operation will involve io when this layer is a rollup layer, io errors may occur.
sourcepub fn triple_additions(
&self
) -> Result<Box<dyn Iterator<Item = IdTriple> + Send>>
pub fn triple_additions( &self ) -> Result<Box<dyn Iterator<Item = IdTriple> + Send>>
Returns an iterator over all layer additions.
Since this operation will involve io when this layer is a rollup layer, io errors may occur.
sourcepub fn triple_removals(
&self
) -> Result<Box<dyn Iterator<Item = IdTriple> + Send>>
pub fn triple_removals( &self ) -> Result<Box<dyn Iterator<Item = IdTriple> + Send>>
Returns an iterator over all layer removals.
Since this operation will involve io when this layer is a rollup layer, io errors may occur.
sourcepub fn triple_additions_s(
&self,
subject: u64
) -> Result<Box<dyn Iterator<Item = IdTriple> + Send>>
pub fn triple_additions_s( &self, subject: u64 ) -> Result<Box<dyn Iterator<Item = IdTriple> + Send>>
Returns an iterator over all layer additions that share a particular subject.
Since this operation will involve io when this layer is a rollup layer, io errors may occur.
sourcepub fn triple_removals_s(
&self,
subject: u64
) -> Result<Box<dyn Iterator<Item = IdTriple> + Send>>
pub fn triple_removals_s( &self, subject: u64 ) -> Result<Box<dyn Iterator<Item = IdTriple> + Send>>
Returns an iterator over all layer removals that share a particular subject.
Since this operation will involve io when this layer is a rollup layer, io errors may occur.
sourcepub fn triple_additions_sp(
&self,
subject: u64,
predicate: u64
) -> Result<Box<dyn Iterator<Item = IdTriple> + Send>>
pub fn triple_additions_sp( &self, subject: u64, predicate: u64 ) -> Result<Box<dyn Iterator<Item = IdTriple> + Send>>
Returns an iterator over all layer additions that share a particular subject and predicate.
Since this operation will involve io when this layer is a rollup layer, io errors may occur.
sourcepub fn triple_removals_sp(
&self,
subject: u64,
predicate: u64
) -> Result<Box<dyn Iterator<Item = IdTriple> + Send>>
pub fn triple_removals_sp( &self, subject: u64, predicate: u64 ) -> Result<Box<dyn Iterator<Item = IdTriple> + Send>>
Returns an iterator over all layer removals that share a particular subject and predicate.
Since this operation will involve io when this layer is a rollup layer, io errors may occur.
sourcepub fn triple_additions_p(
&self,
predicate: u64
) -> Result<Box<dyn Iterator<Item = IdTriple> + Send>>
pub fn triple_additions_p( &self, predicate: u64 ) -> Result<Box<dyn Iterator<Item = IdTriple> + Send>>
Returns an iterator over all layer additions that share a particular predicate.
Since this operation will involve io when this layer is a rollup layer, io errors may occur.
sourcepub fn triple_removals_p(
&self,
predicate: u64
) -> Result<Box<dyn Iterator<Item = IdTriple> + Send>>
pub fn triple_removals_p( &self, predicate: u64 ) -> Result<Box<dyn Iterator<Item = IdTriple> + Send>>
Returns an iterator over all layer removals that share a particular predicate.
Since this operation will involve io when this layer is a rollup layer, io errors may occur.
sourcepub fn triple_additions_o(
&self,
object: u64
) -> Result<Box<dyn Iterator<Item = IdTriple> + Send>>
pub fn triple_additions_o( &self, object: u64 ) -> Result<Box<dyn Iterator<Item = IdTriple> + Send>>
Returns an iterator over all layer additions that share a particular object.
Since this operation will involve io when this layer is a rollup layer, io errors may occur.
sourcepub fn triple_removals_o(
&self,
object: u64
) -> Result<Box<dyn Iterator<Item = IdTriple> + Send>>
pub fn triple_removals_o( &self, object: u64 ) -> Result<Box<dyn Iterator<Item = IdTriple> + Send>>
Returns an iterator over all layer removals that share a particular object.
Since this operation will involve io when this layer is a rollup layer, io errors may occur.
sourcepub fn triple_layer_addition_count(&self) -> Result<usize>
pub fn triple_layer_addition_count(&self) -> Result<usize>
Returns the amount of triples that this layer adds.
Since this operation will involve io when this layer is a rollup layer, io errors may occur.
sourcepub fn triple_layer_removal_count(&self) -> Result<usize>
pub fn triple_layer_removal_count(&self) -> Result<usize>
Returns the amount of triples that this layer removes.
Since this operation will involve io when this layer is a rollup layer, io errors may occur.
Trait Implementations§
source§impl Clone for SyncStoreLayer
impl Clone for SyncStoreLayer
source§fn clone(&self) -> SyncStoreLayer
fn clone(&self) -> SyncStoreLayer
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moresource§impl Layer for SyncStoreLayer
impl Layer for SyncStoreLayer
fn parent_name(&self) -> Option<[u32; 5]>
source§fn node_and_value_count(&self) -> usize
fn node_and_value_count(&self) -> usize
source§fn predicate_count(&self) -> usize
fn predicate_count(&self) -> usize
source§fn subject_id(&self, subject: &str) -> Option<u64>
fn subject_id(&self, subject: &str) -> Option<u64>
source§fn predicate_id(&self, predicate: &str) -> Option<u64>
fn predicate_id(&self, predicate: &str) -> Option<u64>
source§fn object_node_id(&self, object: &str) -> Option<u64>
fn object_node_id(&self, object: &str) -> Option<u64>
source§fn object_value_id(&self, object: &TypedDictEntry) -> Option<u64>
fn object_value_id(&self, object: &TypedDictEntry) -> Option<u64>
source§fn id_subject(&self, id: u64) -> Option<String>
fn id_subject(&self, id: u64) -> Option<String>
source§fn id_predicate(&self, id: u64) -> Option<String>
fn id_predicate(&self, id: u64) -> Option<String>
source§fn id_object(&self, id: u64) -> Option<ObjectType>
fn id_object(&self, id: u64) -> Option<ObjectType>
source§fn id_object_is_node(&self, id: u64) -> Option<bool>
fn id_object_is_node(&self, id: u64) -> Option<bool>
source§fn triple_exists(&self, subject: u64, predicate: u64, object: u64) -> bool
fn triple_exists(&self, subject: u64, predicate: u64, object: u64) -> bool
source§fn triples(&self) -> Box<dyn Iterator<Item = IdTriple> + Send>
fn triples(&self) -> Box<dyn Iterator<Item = IdTriple> + Send>
fn triples_s(&self, subject: u64) -> Box<dyn Iterator<Item = IdTriple> + Send>
fn triples_sp( &self, subject: u64, predicate: u64 ) -> Box<dyn Iterator<Item = IdTriple> + Send>
fn triples_p(&self, predicate: u64) -> Box<dyn Iterator<Item = IdTriple> + Send>
fn triples_o(&self, object: u64) -> Box<dyn Iterator<Item = IdTriple> + Send>
source§fn clone_boxed(&self) -> Box<dyn Layer>
fn clone_boxed(&self) -> Box<dyn Layer>
source§fn triple_addition_count(&self) -> usize
fn triple_addition_count(&self) -> usize
source§fn triple_removal_count(&self) -> usize
fn triple_removal_count(&self) -> usize
source§fn all_counts(&self) -> LayerCounts
fn all_counts(&self) -> LayerCounts
fn single_triple_sp(&self, subject: u64, predicate: u64) -> Option<IdTriple>
source§fn id_object_node(&self, id: u64) -> Option<String>
fn id_object_node(&self, id: u64) -> Option<String>
source§fn id_object_value(&self, id: u64) -> Option<TypedDictEntry>
fn id_object_value(&self, id: u64) -> Option<TypedDictEntry>
source§fn id_object_is_value(&self, id: u64) -> Option<bool>
fn id_object_is_value(&self, id: u64) -> Option<bool>
source§fn id_triple_exists(&self, triple: IdTriple) -> bool
fn id_triple_exists(&self, triple: IdTriple) -> bool
source§fn value_triple_exists(&self, triple: &ValueTriple) -> bool
fn value_triple_exists(&self, triple: &ValueTriple) -> bool
source§fn value_triple_to_id(&self, triple: &ValueTriple) -> Option<IdTriple>
fn value_triple_to_id(&self, triple: &ValueTriple) -> Option<IdTriple>
ValueTriple
to an IdTriple
, returning None if any of the strings in the triple could not be resolved.source§fn value_triple_to_partially_resolved(
&self,
triple: ValueTriple
) -> PartiallyResolvedTriple
fn value_triple_to_partially_resolved( &self, triple: ValueTriple ) -> PartiallyResolvedTriple
source§fn id_triple_to_string(&self, triple: &IdTriple) -> Option<ValueTriple>
fn id_triple_to_string(&self, triple: &IdTriple) -> Option<ValueTriple>
source§fn triple_count(&self) -> usize
fn triple_count(&self) -> usize
source§impl PartialEq for SyncStoreLayer
impl PartialEq for SyncStoreLayer
source§fn eq(&self, other: &SyncStoreLayer) -> bool
fn eq(&self, other: &SyncStoreLayer) -> bool
self
and other
values to be equal, and is used
by ==
.impl Eq for SyncStoreLayer
Auto Trait Implementations§
impl !RefUnwindSafe for SyncStoreLayer
impl Send for SyncStoreLayer
impl Sync for SyncStoreLayer
impl Unpin for SyncStoreLayer
impl !UnwindSafe for SyncStoreLayer
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
source§impl<T> CheckedAs for T
impl<T> CheckedAs for T
source§fn checked_as<Dst>(self) -> Option<Dst>where
T: CheckedCast<Dst>,
fn checked_as<Dst>(self) -> Option<Dst>where
T: CheckedCast<Dst>,
source§impl<Src, Dst> CheckedCastFrom<Src> for Dstwhere
Src: CheckedCast<Dst>,
impl<Src, Dst> CheckedCastFrom<Src> for Dstwhere
Src: CheckedCast<Dst>,
source§fn checked_cast_from(src: Src) -> Option<Dst>
fn checked_cast_from(src: Src) -> Option<Dst>
source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
source§impl<T> FmtForward for T
impl<T> FmtForward for T
source§fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
self
to use its Binary
implementation when Debug
-formatted.source§fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
self
to use its Display
implementation when
Debug
-formatted.source§fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
self
to use its LowerExp
implementation when
Debug
-formatted.source§fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
self
to use its LowerHex
implementation when
Debug
-formatted.source§fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
self
to use its Octal
implementation when Debug
-formatted.source§fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
self
to use its Pointer
implementation when
Debug
-formatted.source§fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
self
to use its UpperExp
implementation when
Debug
-formatted.source§fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
self
to use its UpperHex
implementation when
Debug
-formatted.source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> OverflowingAs for T
impl<T> OverflowingAs for T
source§fn overflowing_as<Dst>(self) -> (Dst, bool)where
T: OverflowingCast<Dst>,
fn overflowing_as<Dst>(self) -> (Dst, bool)where
T: OverflowingCast<Dst>,
source§impl<Src, Dst> OverflowingCastFrom<Src> for Dstwhere
Src: OverflowingCast<Dst>,
impl<Src, Dst> OverflowingCastFrom<Src> for Dstwhere
Src: OverflowingCast<Dst>,
source§fn overflowing_cast_from(src: Src) -> (Dst, bool)
fn overflowing_cast_from(src: Src) -> (Dst, bool)
source§impl<T> Pipe for Twhere
T: ?Sized,
impl<T> Pipe for Twhere
T: ?Sized,
source§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
source§fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
self
and passes that borrow into the pipe function. Read moresource§fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
self
and passes that borrow into the pipe function. Read moresource§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
source§fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R
) -> R
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R ) -> R
source§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
self
, then passes self.as_ref()
into the pipe function.source§fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
self
, then passes self.as_mut()
into the pipe
function.source§fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
self
, then passes self.deref()
into the pipe function.source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<T> SaturatingAs for T
impl<T> SaturatingAs for T
source§fn saturating_as<Dst>(self) -> Dstwhere
T: SaturatingCast<Dst>,
fn saturating_as<Dst>(self) -> Dstwhere
T: SaturatingCast<Dst>,
source§impl<Src, Dst> SaturatingCastFrom<Src> for Dstwhere
Src: SaturatingCast<Dst>,
impl<Src, Dst> SaturatingCastFrom<Src> for Dstwhere
Src: SaturatingCast<Dst>,
source§fn saturating_cast_from(src: Src) -> Dst
fn saturating_cast_from(src: Src) -> Dst
source§impl<T> Tap for T
impl<T> Tap for T
source§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
Borrow<B>
of a value. Read moresource§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
BorrowMut<B>
of a value. Read moresource§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
AsRef<R>
view of a value. Read moresource§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
AsMut<R>
view of a value. Read moresource§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
Deref::Target
of a value. Read moresource§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
Deref::Target
of a value. Read moresource§fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
.tap()
only in debug builds, and is erased in release builds.source§fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
.tap_mut()
only in debug builds, and is erased in release
builds.source§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
.tap_borrow()
only in debug builds, and is erased in release
builds.source§fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
.tap_borrow_mut()
only in debug builds, and is erased in release
builds.source§fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
.tap_ref()
only in debug builds, and is erased in release
builds.source§fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
.tap_ref_mut()
only in debug builds, and is erased in release
builds.source§fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
.tap_deref()
only in debug builds, and is erased in release
builds.