pub enum Record {
Command(CommandRecord),
Envelope(EnvelopeRecord),
}Variants§
Command(CommandRecord)
Envelope(EnvelopeRecord)
Implementations§
Source§impl Record
impl Record
pub fn try_from_parts( headers: Vec<Header>, body: Bytes, ) -> Result<Self, PublicRecordError>
pub fn sequenced(self, position: StreamPosition) -> SequencedRecord
pub fn into_parts(self) -> (Vec<Header>, Bytes)
Trait Implementations§
Source§impl MeteredSize for Record
impl MeteredSize for Record
Source§fn metered_size(&self) -> usize
fn metered_size(&self) -> usize
Return the metered size of a record or batch of records.
impl Eq for Record
impl StructuralPartialEq for Record
Auto Trait Implementations§
impl !Freeze for Record
impl RefUnwindSafe for Record
impl Send for Record
impl Sync for Record
impl Unpin for Record
impl UnwindSafe for Record
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