Struct DbspSerializer 

pub struct DbspSerializer<'a> { /* private fields */ }

The rkyv::ser::Serializer used by DBSP.

Trait Implementations

impl Fallible for DbspSerializer<'_>

type Error = CompositeSerializerError<<FBufSerializer<FBuf> as Fallible>::Error, <DbspScratch as Fallible>::Error, SharedSerializeMapError>

The error produced by any failing methods.

impl ScratchSpace for DbspSerializer<'_>

unsafe fn push_scratch( &mut self, layout: Layout, ) -> Result<NonNull<[u8]>, Self::Error>

Allocates scratch space of the requested size.

unsafe fn pop_scratch( &mut self, ptr: NonNull<u8>, layout: Layout, ) -> Result<(), Self::Error>

Deallocates previously allocated scratch space.

impl Serialize<DbspSerializer<'_>> for Box<DynData>

fn serialize( &self, _serializer: &mut DbspSerializer<'_>, ) -> Result<Self::Resolver, <DbspSerializer<'_> as Fallible>::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.

impl<T> Serialize<DbspSerializer<'_>> for Box<DynDataTyped<T>>

fn serialize( &self, _serializer: &mut DbspSerializer<'_>, ) -> Result<Self::Resolver, <DbspSerializer<'_> as Fallible>::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.

impl<T> Serialize<DbspSerializer<'_>> for Box<DynOpt<T>>

fn serialize( &self, _serializer: &mut DbspSerializer<'_>, ) -> Result<Self::Resolver, <DbspSerializer<'_> as Fallible>::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.

impl<T1, T2> Serialize<DbspSerializer<'_>> for Box<DynPair<T1, T2>>

fn serialize( &self, _serializer: &mut DbspSerializer<'_>, ) -> Result<Self::Resolver, <DbspSerializer<'_> as Fallible>::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.

impl<T1, T2> Serialize<DbspSerializer<'_>> for Box<DynPairs<T1, T2>>

fn serialize( &self, _serializer: &mut DbspSerializer<'_>, ) -> Result<Self::Resolver, <DbspSerializer<'_> as Fallible>::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.

impl<T> Serialize<DbspSerializer<'_>> for Box<DynSet<T>>

fn serialize( &self, _serializer: &mut DbspSerializer<'_>, ) -> Result<Self::Resolver, <DbspSerializer<'_> as Fallible>::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.

impl<T> Serialize<DbspSerializer<'_>> for Box<DynVec<T>>

fn serialize( &self, _serializer: &mut DbspSerializer<'_>, ) -> Result<Self::Resolver, <DbspSerializer<'_> as Fallible>::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.

impl Serialize<DbspSerializer<'_>> for Box<DynWeight>

fn serialize( &self, _serializer: &mut DbspSerializer<'_>, ) -> Result<Self::Resolver, <DbspSerializer<'_> as Fallible>::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.

impl<T> Serialize<DbspSerializer<'_>> for Box<DynWeightTyped<T>>

fn serialize( &self, _serializer: &mut DbspSerializer<'_>, ) -> Result<Self::Resolver, <DbspSerializer<'_> as Fallible>::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.

impl<T1, T2> Serialize<DbspSerializer<'_>> for Box<DynWeightedPairs<T1, T2>>

fn serialize( &self, _serializer: &mut DbspSerializer<'_>, ) -> Result<Self::Resolver, <DbspSerializer<'_> as Fallible>::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.

impl<T, D> Serialize<DbspSerializer<'_>> for TypedBox<T, D>

where T: DBData + Erase<D>, D: DataTrait + ?Sized,

fn serialize( &self, serializer: &mut DbspSerializer<'_>, ) -> Result<Self::Resolver, <DbspSerializer<'_> as Fallible>::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.

impl<T, R> Serialize<DbspSerializer<'_>> for Box<DynAverage<T, R>>

fn serialize( &self, _serializer: &mut DbspSerializer<'_>, ) -> Result<Self::Resolver, <DbspSerializer<'_> as Fallible>::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.

impl<VTrait, UTrait> Serialize<DbspSerializer<'_>> for Box<dyn UpdateTrait<VTrait, UTrait>>

fn serialize( &self, _serializer: &mut DbspSerializer<'_>, ) -> Result<Self::Resolver, <DbspSerializer<'_> as Fallible>::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.

impl<KTrait, VTrait> Serialize<DbspSerializer<'_>> for Box<DynNeighborhoodDescr<KTrait, VTrait>>

fn serialize( &self, _serializer: &mut DbspSerializer<'_>, ) -> Result<Self::Resolver, <DbspSerializer<'_> as Fallible>::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.

impl<TS, A> Serialize<DbspSerializer<'_>> for Box<dyn ChildPtrTrait<TS, A>>

fn serialize( &self, _serializer: &mut DbspSerializer<'_>, ) -> Result<Self::Resolver, <DbspSerializer<'_> as Fallible>::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.

impl<TS, A> Serialize<DbspSerializer<'_>> for Box<dyn TreeNodeTrait<TS, A>>

fn serialize( &self, _serializer: &mut DbspSerializer<'_>, ) -> Result<Self::Resolver, <DbspSerializer<'_> as Fallible>::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.

impl<TS, A> Serialize<DbspSerializer<'_>> for Box<dyn TreeNodeUpdateTrait<TS, A>>

fn serialize( &self, _serializer: &mut DbspSerializer<'_>, ) -> Result<Self::Resolver, <DbspSerializer<'_> as Fallible>::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.

impl<K: DataTrait + ?Sized, R: WeightTrait + ?Sized> Serialize<DbspSerializer<'_>> for FileWSet<K, R>

fn serialize( &self, _serializer: &mut DbspSerializer<'_>, ) -> Result<Self::Resolver, <DbspSerializer<'_> as Fallible>::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.

impl<K, V, R, O> Serialize<DbspSerializer<'_>> for VecIndexedWSet<K, V, R, O>

where K: DataTrait + ?Sized, V: DataTrait + ?Sized, R: WeightTrait + ?Sized, O: OrdOffset,

fn serialize( &self, _serializer: &mut DbspSerializer<'_>, ) -> Result<Self::Resolver, <DbspSerializer<'_> as Fallible>::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.

impl<K, T, R, O> Serialize<DbspSerializer<'_>> for VecKeyBatch<K, T, R, O>

where K: DataTrait + ?Sized, T: Timestamp, R: WeightTrait + ?Sized, O: OrdOffset,

fn serialize( &self, _serializer: &mut DbspSerializer<'_>, ) -> Result<Self::Resolver, <DbspSerializer<'_> as Fallible>::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.

impl<K, V, T, R, O> Serialize<DbspSerializer<'_>> for VecValBatch<K, V, T, R, O>

where K: DataTrait + ?Sized, V: DataTrait + ?Sized, R: WeightTrait + ?Sized, T: Timestamp + Lattice, O: OrdOffset,

fn serialize( &self, _serializer: &mut DbspSerializer<'_>, ) -> Result<Self::Resolver, <DbspSerializer<'_> as Fallible>::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.

impl<K: DataTrait + ?Sized, R: WeightTrait + ?Sized> Serialize<DbspSerializer<'_>> for VecWSet<K, R>

fn serialize( &self, _serializer: &mut DbspSerializer<'_>, ) -> Result<Self::Resolver, <DbspSerializer<'_> as Fallible>::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.

impl Serializer for DbspSerializer<'_>

fn pos(&self) -> usize

Returns the current position of the serializer.

fn write(&mut self, bytes: &[u8]) -> Result<(), Self::Error>

Attempts to write the given bytes to the serializer.

fn pad(&mut self, padding: usize) -> Result<(), Self::Error>

Advances the given number of bytes as padding.

fn align(&mut self, align: usize) -> Result<usize, Self::Error>

Aligns the position of the serializer to the given alignment.

fn align_for<T>(&mut self) -> Result<usize, Self::Error>

Aligns the position of the serializer to be suitable to write the given type.

unsafe fn resolve_aligned<T>( &mut self, value: &T, resolver: <T as Archive>::Resolver, ) -> Result<usize, Self::Error>

where T: Archive + ?Sized,

Resolves the given value with its resolver and writes the archived type.

fn serialize_value<T>(&mut self, value: &T) -> Result<usize, Self::Error>

where T: Serialize<Self>,

Archives the given object and returns the position it was archived at.

unsafe fn resolve_unsized_aligned<T>( &mut self, value: &T, to: usize, metadata_resolver: <T as ArchiveUnsized>::MetadataResolver, ) -> Result<usize, Self::Error>

where T: ArchiveUnsized + ?Sized,

Resolves the given reference with its resolver and writes the archived reference.

fn serialize_unsized_value<T>( &mut self, value: &T, ) -> Result<usize, Self::Error>

where T: SerializeUnsized<Self> + ?Sized,

Archives a reference to the given object and returns the position it was archived at.

impl SharedSerializeRegistry for DbspSerializer<'_>

fn get_shared_ptr(&self, value: *const u8) -> Option<usize>

Gets the position of a previously-added shared pointer.

fn add_shared_ptr( &mut self, value: *const u8, pos: usize, ) -> Result<(), Self::Error>

Adds the position of a shared pointer to the registry.

fn get_shared<T>(&self, value: &T) -> Option<usize>

where T: ?Sized,

Gets the position of a previously-added shared value.

fn add_shared<T>(&mut self, value: &T, pos: usize) -> Result<(), Self::Error>

where T: ?Sized,

Adds the position of a shared value to the registry.

fn serialize_shared<T>(&mut self, value: &T) -> Result<usize, Self::Error>

where T: SerializeUnsized<Self> + ?Sized, Self: Serializer,

Archives the given shared value and returns its position. If the value has already been added then it returns the position of the previously added value.