Struct fluvio_socket::FluvioSink

pub struct FluvioSink { /* private fields */ }

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 + 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 + 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.