Struct Handshake

pub struct Handshake<C>where
    C: ClusterAPI,{
    pub prefix: String,
    pub raddr: SocketAddr,
    pub config: Config,
    pub proto: Protocol,
    pub cluster: C,
    pub conn: Option<TcpStream>,
}

Expand description

Type handles incoming connection.

Complete the handshake by sending the appropriate CONNACK packet. This type is threadable and spawned for every incoming connection, once the handshake is completed, connection is handed over to the Cluster.

Fields§

§prefix: String§raddr: SocketAddr§config: Config§proto: Protocol§cluster: C§conn: Option<TcpStream>

Trait Implementations§

impl<C> Threadable for Handshake<C>
where C: ClusterAPI,

type Req = ()

Request type that the implementing type can handle.

type Resp = ()

Response type that the implementing type shall return.

fn main_loop(self, _rx: Rx<(), ()>) -> Self

Entry point for the thread.

impl<C> ToJson for Handshake<C>
where C: ClusterAPI,

fn to_config_json(&self) -> String

Implementing type shall return configuration as JSON string.

fn to_stats_json(&self) -> String

Implementing type shall return statistics as JSON string.

Auto Trait Implementations§

impl<C> !Freeze for Handshake<C>

impl<C> RefUnwindSafe for Handshake<C>
where C: RefUnwindSafe,

impl<C> Send for Handshake<C>
where C: Send,

impl<C> Sync for Handshake<C>
where C: Sync,

impl<C> Unpin for Handshake<C>
where C: Unpin,

impl<C> UnwindSafe for Handshake<C>
where C: UnwindSafe,

Blanket Implementations§

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

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

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

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

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

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

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

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

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

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

type Error = Infallible

The type returned in the event of a conversion error.

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

Performs the conversion.

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

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

The type returned in the event of a conversion error.

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

Performs the conversion.