Struct fluvio_socket::FluvioSink
source · pub struct FluvioSink { /* private fields */ }
Implementations§
source§impl FluvioSink
impl FluvioSink
pub fn get_mut_tcp_sink( &mut self, ) -> &mut FramedWrite<Compat<BoxWriteConnection>, FluvioCodec>
pub fn id(&self) -> ConnectionFd
convert to shared sink
pub fn new(sink: BoxWriteConnection, fd: ConnectionFd) -> Self
sourcepub fn disable_zerocopy(&mut self)
pub fn disable_zerocopy(&mut self)
don’t use zero copy
sourcepub async fn send_request<R>(
&mut self,
req_msg: &RequestMessage<R>,
) -> Result<(), SocketError>
pub async fn send_request<R>( &mut self, req_msg: &RequestMessage<R>, ) -> Result<(), SocketError>
as client, send request to server
sourcepub async fn send_response<P>(
&mut self,
resp_msg: &ResponseMessage<P>,
version: Version,
) -> Result<(), SocketError>
pub async fn send_response<P>( &mut self, resp_msg: &ResponseMessage<P>, version: Version, ) -> Result<(), SocketError>
as server, send back response
Trait Implementations§
source§impl AsRawFd for FluvioSink
impl AsRawFd for FluvioSink
Auto Trait Implementations§
impl Freeze for FluvioSink
impl !RefUnwindSafe for FluvioSink
impl Send for FluvioSink
impl Sync for FluvioSink
impl Unpin for FluvioSink
impl !UnwindSafe for FluvioSink
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more