Struct fluvio_socket::FluvioSocket

pub struct FluvioSocket { /* private fields */ }

Socket abstract that can send and receive fluvio objects

Implementations

impl FluvioSocket

pub fn new(sink: FluvioSink, stream: FluvioStream) -> Self

pub fn split(self) -> (FluvioSink, FluvioStream)

pub fn set_stale(&mut self)

mark as stale

pub fn is_stale(&self) -> bool

pub fn get_mut_sink(&mut self) -> &mut FluvioSink

pub fn get_mut_stream(&mut self) -> &mut FluvioStream

pub fn id(&self) -> ConnectionFd

pub async fn send<R>( &mut self, req_msg: &RequestMessage<R> ) -> Result<ResponseMessage<R::Response>, SocketError>

where R: Request,

as client, send request and wait for reply from server

impl FluvioSocket

pub fn from_stream( write: BoxWriteConnection, read: BoxReadConnection, fd: ConnectionFd ) -> Self

pub async fn connect_with_connector( addr: &str, connector: &dyn TcpDomainConnector ) -> Result<Self, SocketError>

connect to target address with connector

impl FluvioSocket

pub async fn connect(addr: &str) -> Result<Self, SocketError>

Trait Implementations

impl Debug for FluvioSocket

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

Formats the value using the given formatter.

impl From<(FluvioSink, FluvioStream)> for FluvioSocket

fn from(pair: (FluvioSink, FluvioStream)) -> Self

Converts to this type from the input type.

impl From<TcpStream> for FluvioSocket

fn from(tcp_stream: TcpStream) -> Self

Converts to this type from the input type.