pub struct ParallelConfig { /* private fields */ }Available on crate feature
parallel only.Expand description
Ordered parallel batch codec over a base binary configuration.
Elements are encoded independently on scoped worker threads. The frame stores an ordered length table, so scheduling cannot affect output bytes.
Implementations§
Source§impl ParallelConfig
impl ParallelConfig
Sourcepub const fn base_config(self) -> Config
pub const fn base_config(self) -> Config
Returns the underlying wire and resource configuration.
Sourcepub const fn with_worker_count(self, workers: NonZeroUsize) -> Self
pub const fn with_worker_count(self, workers: NonZeroUsize) -> Self
Uses at most workers scoped threads.
Sourcepub const fn worker_count(self) -> NonZeroUsize
pub const fn worker_count(self) -> NonZeroUsize
Returns the configured worker ceiling.
Sourcepub fn serialize_batch<T: NsonSerialize + Sync>(
self,
values: &[T],
) -> Result<Vec<u8>>
pub fn serialize_batch<T: NsonSerialize + Sync>( self, values: &[T], ) -> Result<Vec<u8>>
Encodes an ordered collection as a deterministic parallel batch frame.
Sourcepub fn deserialize_batch<T: for<'de> NsonDeserialize<'de> + Send>(
self,
input: &[u8],
) -> Result<Vec<T>>
pub fn deserialize_batch<T: for<'de> NsonDeserialize<'de> + Send>( self, input: &[u8], ) -> Result<Vec<T>>
Validates and decodes an ordered parallel batch frame.
Trait Implementations§
Source§impl Clone for ParallelConfig
impl Clone for ParallelConfig
Source§fn clone(&self) -> ParallelConfig
fn clone(&self) -> ParallelConfig
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreimpl Copy for ParallelConfig
Source§impl Debug for ParallelConfig
impl Debug for ParallelConfig
impl Eq for ParallelConfig
Source§impl PartialEq for ParallelConfig
impl PartialEq for ParallelConfig
impl StructuralPartialEq for ParallelConfig
Auto Trait Implementations§
impl Freeze for ParallelConfig
impl RefUnwindSafe for ParallelConfig
impl Send for ParallelConfig
impl Sync for ParallelConfig
impl Unpin for ParallelConfig
impl UnsafeUnpin for ParallelConfig
impl UnwindSafe for ParallelConfig
Blanket Implementations§
Source§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
Source§type ArchivedMetadata = ()
type ArchivedMetadata = ()
The archived version of the pointer metadata for this type.
Source§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata,
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata
Converts some archived metadata to the pointer metadata for itself.
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
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<T> LayoutRaw for T
impl<T> LayoutRaw for T
Source§fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
Returns the layout of the type.
Source§impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
Source§unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool
unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool
Returns whether the given value has been niched. Read more
Source§fn resolve_niched(out: Place<NichedOption<T, N1>>)
fn resolve_niched(out: Place<NichedOption<T, N1>>)
Writes data to
out indicating that a T is niched.