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: Serialize + Sync>(
self,
values: &[T],
) -> Result<Vec<u8>>
pub fn serialize_batch<T: Serialize + Sync>( self, values: &[T], ) -> Result<Vec<u8>>
Encodes an ordered collection as a deterministic parallel batch frame.
Sourcepub fn deserialize_batch<T: DeserializeOwned + Send>(
self,
input: &[u8],
) -> Result<Vec<T>>
pub fn deserialize_batch<T: DeserializeOwned + 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> 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