Struct mz_server_core::Connection

pub struct Connection {
    pub(crate) conn_uuid: Arc<Mutex<Option<Uuid>>>,
    pub(crate) tcp_stream: TcpStream,
}

A wrapper around a TcpStream that can identify a connection across processes.

Fields

conn_uuid: Arc<Mutex<Option<Uuid>>>

tcp_stream: TcpStream

Implementations

impl Connection

pub(crate) fn new(tcp_stream: TcpStream) -> Connection

pub fn uuid_handle(&self) -> ConnectionUuidHandle

Returns a handle to the connection UUID.

pub async fn take_proxy_header_address(&mut self) -> Option<ProxiedAddress>

Attempts to parse a proxy header from the tcp_stream. If none is found or it is unable to be parsed None will be returned. If a header is found it will be returned and its bytes will be removed from the stream.

It is possible an invalid header was sent, if that is the case any downstream service will be responsible for returning errors to the client.

pub fn peer_addr(&self) -> Result<SocketAddr, Error>

Peer address of the inner tcp_stream.

Trait Implementations

impl AsyncRead for Connection

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>, ) -> Poll<Result<()>>

Attempts to read from the AsyncRead into buf.

impl AsyncReady for Connection

fn ready<'life0, 'async_trait>( &'life0 self, interest: Interest, ) -> Pin<Box<dyn Future<Output = Result<Ready>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Checks for IO readiness.

impl AsyncWrite for Connection

fn poll_write( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize>>

Attempt to write bytes from buf into the object.

fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>>

Attempts to flush the object, ensuring that any buffered data reach their destination.

fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>>

Initiates or attempts to shut down this writer, returning success when the I/O connection has completely shut down.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize, Error>>

Like poll_write, except that it writes from a slice of buffers.

fn is_write_vectored(&self) -> bool

Determines if this writer has an efficient poll_write_vectored implementation.