pub struct RecordWriter<'a> { /* private fields */ }Expand description
A struct that writes transformed records to the output topic..
Implementations§
Source§impl<'a> RecordWriter<'a>
impl<'a> RecordWriter<'a>
pub fn new(sink: &'a mut dyn RecordSink) -> RecordWriter<'a>
Sourcepub fn write<'b>(
&mut self,
r: impl Into<BorrowedRecord<'b>>,
) -> Result<(), WriteError>
pub fn write<'b>( &mut self, r: impl Into<BorrowedRecord<'b>>, ) -> Result<(), WriteError>
Write a record to the default output topic, returning any errors.
Sourcepub fn write_with_options<'b>(
&mut self,
r: impl Into<BorrowedRecord<'b>>,
opts: WriteOptions<'b>,
) -> Result<(), WriteError>
pub fn write_with_options<'b>( &mut self, r: impl Into<BorrowedRecord<'b>>, opts: WriteOptions<'b>, ) -> Result<(), WriteError>
Write a record with the given options, returning any errors.
Auto Trait Implementations§
impl<'a> Freeze for RecordWriter<'a>
impl<'a> !RefUnwindSafe for RecordWriter<'a>
impl<'a> !Send for RecordWriter<'a>
impl<'a> !Sync for RecordWriter<'a>
impl<'a> Unpin for RecordWriter<'a>
impl<'a> !UnwindSafe for RecordWriter<'a>
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