pub struct TopicWriterOptionsBuilder { /* private fields */ }Expand description
Builder for TopicWriterOptions.
Implementations§
Source§impl TopicWriterOptionsBuilder
impl TopicWriterOptionsBuilder
pub fn topic_path(&mut self, value: String) -> &mut Self
pub fn producer_id(&mut self, value: String) -> &mut Self
pub fn session_metadata(&mut self, value: HashMap<String, String>) -> &mut Self
pub fn auto_seq_no(&mut self, value: bool) -> &mut Self
pub fn auto_created_at(&mut self, value: bool) -> &mut Self
pub fn write_request_messages_chunk_size(&mut self, value: usize) -> &mut Self
pub fn write_request_send_messages_period( &mut self, value: Duration, ) -> &mut Self
pub fn codec(&mut self, value: Codec) -> &mut Self
pub fn custom_encoders( &mut self, value: HashMap<Codec, fn(Bytes) -> Bytes>, ) -> &mut Self
pub fn connection_options( &mut self, value: TopicWriterConnectionOptions, ) -> &mut Self
Trait Implementations§
Source§impl Clone for TopicWriterOptionsBuilder
impl Clone for TopicWriterOptionsBuilder
Source§fn clone(&self) -> TopicWriterOptionsBuilder
fn clone(&self) -> TopicWriterOptionsBuilder
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl Freeze for TopicWriterOptionsBuilder
impl RefUnwindSafe for TopicWriterOptionsBuilder
impl Send for TopicWriterOptionsBuilder
impl Sync for TopicWriterOptionsBuilder
impl Unpin for TopicWriterOptionsBuilder
impl UnwindSafe for TopicWriterOptionsBuilder
Blanket Implementations§
Source§impl<T> Any for T
impl<T> Any for T
Source§fn type_id_compat(&self) -> TypeId
fn type_id_compat(&self) -> TypeId
TODO: once 1.33.0 is the minimum supported compiler version, remove
Any::type_id_compat and use StdAny::type_id instead.
https://github.com/rust-lang/rust/issues/27745
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> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
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> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request