Enum mz_kafka_util::client::BrokerRewriteHandle
source · enum BrokerRewriteHandle {
Simple(BrokerRewrite),
SshTunnel(ManagedSshTunnelHandle),
FailedDefaultSshTunnel(String),
}
Variants§
Simple(BrokerRewrite)
SshTunnel(ManagedSshTunnelHandle)
FailedDefaultSshTunnel(String)
For default ssh tunnels, we store an error if creation
of the tunnel failed, so that tunnel_status
can return it.
Trait Implementations§
source§impl Clone for BrokerRewriteHandle
impl Clone for BrokerRewriteHandle
source§fn clone(&self) -> BrokerRewriteHandle
fn clone(&self) -> BrokerRewriteHandle
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 BrokerRewriteHandle
impl RefUnwindSafe for BrokerRewriteHandle
impl Send for BrokerRewriteHandle
impl Sync for BrokerRewriteHandle
impl Unpin for BrokerRewriteHandle
impl UnwindSafe for BrokerRewriteHandle
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> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§default unsafe fn clone_to_uninit(&self, dst: *mut T)
default unsafe fn clone_to_uninit(&self, dst: *mut T)
🔬This is a nightly-only experimental API. (
clone_to_uninit
)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
Creates a shared type from an unshared type.