Struct fluvio_socket::FluvioSink

pub struct FluvioSink { /* fields omitted */ }

Implementations

impl FluvioSink

pub fn get_mut_tcp_sink(
    &mut self
) -> &mut FramedWrite<Compat<BoxWriteConnection>, FluvioCodec>

pub fn id(&self) -> ConnectionFd

pub fn as_shared(self) -> ExclusiveFlvSink

convert to shared sink

pub fn new(sink: BoxWriteConnection, fd: ConnectionFd) -> Self

pub async fn send_request<R>(
    &mut self,
    req_msg: &RequestMessage<R>
) -> Result<(), SocketError> where
    RequestMessage<R>: FlvEncoder + Default + Debug, 

as client, send request to server

pub async fn send_response<P>(
    &mut self,
    resp_msg: &ResponseMessage<P>,
    version: Version
) -> Result<(), SocketError> where
    ResponseMessage<P>: FlvEncoder + Default + Debug, 

as server, send back response

Trait Implementations

impl AsRawFd for FluvioSink

fn as_raw_fd(&self) -> RawFd

Extracts the raw file descriptor.

impl Debug for FluvioSink

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

Formats the value using the given formatter.