Enum mz_ssh_util::tunnel_manager::SshTunnelState

source ·

enum SshTunnelState {
    Connecting(Receiver<()>),
    Connected(Arc<SshTunnelHandle>),
}

Expand description

The state of an SSH tunnel connection.

There is an additional state not represented by this enum, which is the absence of an entry in the map entirely, indicating there is neither an existing tunnel nor an existing connection attempt.

Variants§

§

Connecting(Receiver<()>)

An existing thread is connecting to the tunnel.

The managing thread will resolve the enclosed future when the connection attempt is complete. Only the thread that entered the Connecting state is allowed to move out of this state.

§

Connected(Arc<SshTunnelHandle>)

An existing thread has successfully established the tunnel.

Only the last ManagedSshTunnelHandle is allowed to move out of this state.

Enum mz_ssh_util::tunnel_manager::SshTunnelStateCopy item path

Variants§

Connecting(Receiver<()>)

Connected(Arc<SshTunnelHandle>)

Trait Implementations§

impl Debug for SshTunnelState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Auto Trait Implementations§

impl Freeze for SshTunnelState

impl !RefUnwindSafe for SshTunnelState

impl Send for SshTunnelState

impl Sync for SshTunnelState

impl Unpin for SshTunnelState

impl !UnwindSafe for SshTunnelState

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T, U> CastInto<U> for Twhere U: CastFrom<T>,

fn cast_into(self) -> U

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self>

fn with_current_context(self) -> WithContext<Self>

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<T> Pointable for T

const ALIGN: usize = _

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> Same for T

type Output = T

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Enum mz_ssh_util::tunnel_manager::SshTunnelState

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> CastInto<U> for T
where U: CastFrom<T>,

impl<T, U> Into<U> for T
where U: From<T>,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,