Struct kafka_protocol::records::RecordBatchEncoder
source · [−]pub struct RecordBatchEncoder;Expand description
Batch encoder for Kafka records.
Implementations
sourceimpl RecordBatchEncoder
impl RecordBatchEncoder
sourcepub fn encode<'a, B, I>(
buf: &mut B,
records: I,
options: &RecordEncodeOptions
) -> Result<(), EncodeError> where
B: ByteBufMut,
I: Iterator<Item = &'a Record> + Clone,
pub fn encode<'a, B, I>(
buf: &mut B,
records: I,
options: &RecordEncodeOptions
) -> Result<(), EncodeError> where
B: ByteBufMut,
I: Iterator<Item = &'a Record> + Clone,
Encode records into given buffer, using provided encoding options that select the encoding strategy based on version.
Trait Implementations
sourceimpl Clone for RecordBatchEncoder
impl Clone for RecordBatchEncoder
sourcefn clone(&self) -> RecordBatchEncoder
fn clone(&self) -> RecordBatchEncoder
Returns a copy of the value. Read more
1.0.0 · sourcefn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source. Read more
Auto Trait Implementations
impl RefUnwindSafe for RecordBatchEncoder
impl Send for RecordBatchEncoder
impl Sync for RecordBatchEncoder
impl Unpin for RecordBatchEncoder
impl UnwindSafe for RecordBatchEncoder
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> ToOwned for T where
T: Clone,
impl<T> ToOwned for T where
T: Clone,
type Owned = T
type Owned = T
The resulting type after obtaining ownership.
sourcefn clone_into(&self, target: &mut T)
fn clone_into(&self, target: &mut T)
🔬 This is a nightly-only experimental API. (
toowned_clone_into)Uses borrowed data to replace owned data, usually by cloning. Read more