pub struct EnhancedBinaryFormat { /* private fields */ }Expand description
Enhanced binary format with streaming support
Implementations§
Source§impl EnhancedBinaryFormat
impl EnhancedBinaryFormat
Sourcepub fn with_compression(self, enable: bool) -> Self
pub fn with_compression(self, enable: bool) -> Self
Configure compression
Sourcepub fn with_checksums(self, enable: bool) -> Self
pub fn with_checksums(self, enable: bool) -> Self
Configure checksums
Sourcepub fn with_chunk_size(self, size: usize) -> Self
pub fn with_chunk_size(self, size: usize) -> Self
Set chunk size for streaming
Sourcepub async fn serialize(&self, event: &StreamEvent) -> Result<Bytes>
pub async fn serialize(&self, event: &StreamEvent) -> Result<Bytes>
Serialize event in enhanced binary format
Sourcepub async fn deserialize(&self, data: &[u8]) -> Result<StreamEvent>
pub async fn deserialize(&self, data: &[u8]) -> Result<StreamEvent>
Deserialize event from enhanced binary format
Sourcepub async fn serialize_streaming(
&self,
event: &StreamEvent,
) -> Result<Vec<Bytes>>
pub async fn serialize_streaming( &self, event: &StreamEvent, ) -> Result<Vec<Bytes>>
Create streaming chunks for large events
Sourcepub async fn deserialize_streaming(
&self,
chunks: Vec<Bytes>,
) -> Result<StreamEvent>
pub async fn deserialize_streaming( &self, chunks: Vec<Bytes>, ) -> Result<StreamEvent>
Reassemble streaming chunks
Trait Implementations§
Auto Trait Implementations§
impl Freeze for EnhancedBinaryFormat
impl RefUnwindSafe for EnhancedBinaryFormat
impl Send for EnhancedBinaryFormat
impl Sync for EnhancedBinaryFormat
impl Unpin for EnhancedBinaryFormat
impl UnsafeUnpin for EnhancedBinaryFormat
impl UnwindSafe for EnhancedBinaryFormat
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
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> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> Pointable for T
impl<T> Pointable for T
Source§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
Source§impl<SS, SP> SupersetOf<SS> for SPwhere
SS: SubsetOf<SP>,
impl<SS, SP> SupersetOf<SS> for SPwhere
SS: SubsetOf<SP>,
Source§fn to_subset(&self) -> Option<SS>
fn to_subset(&self) -> Option<SS>
The inverse inclusion map: attempts to construct
self from the equivalent element of its
superset. Read moreSource§fn is_in_subset(&self) -> bool
fn is_in_subset(&self) -> bool
Checks if
self is actually part of its subset T (and can be converted to it).Source§fn to_subset_unchecked(&self) -> SS
fn to_subset_unchecked(&self) -> SS
Use with care! Same as
self.to_subset but without any property checks. Always succeeds.Source§fn from_subset(element: &SS) -> SP
fn from_subset(element: &SS) -> SP
The inclusion map: converts
self to the equivalent element of its superset.