Struct fluvio_socket::FluvioSocket

pub struct FluvioSocket { /* fields omitted */ }

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) -> RawFd

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

as client, send request and wait for reply from server

impl FluvioSocket

pub fn from_stream(
    write: BoxWriteConnection,
    read: BoxReadConnection,
    raw_fd: RawFd
) -> Self

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

connect to target address with connector

impl FluvioSocket

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

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

Performs the conversion.

impl From<TcpStream> for FluvioSocket

fn from(tcp_stream: TcpStream) -> Self

Performs the conversion.