Struct mz_kafka_util::client::BrokerRewrite
source · pub struct BrokerRewrite {
pub host: String,
pub port: Option<u16>,
}
Expand description
Rewrites a broker address.
For use with TunnelingClientContext
.
Fields§
§host: String
The rewritten hostname.
port: Option<u16>
The rewritten port.
If unspecified, the broker’s original port is left unchanged.
Trait Implementations§
source§impl Clone for BrokerRewrite
impl Clone for BrokerRewrite
source§fn clone(&self) -> BrokerRewrite
fn clone(&self) -> BrokerRewrite
Returns a copy 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 BrokerRewrite
impl RefUnwindSafe for BrokerRewrite
impl Send for BrokerRewrite
impl Sync for BrokerRewrite
impl Unpin for BrokerRewrite
impl UnwindSafe for BrokerRewrite
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> FutureExt for T
impl<T> FutureExt for T
source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
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> 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