Struct fluvio_socket::VersionedSerialSocket
source · pub struct VersionedSerialSocket { /* private fields */ }
Expand description
Connection that perform request/response
Implementations§
source§impl VersionedSerialSocket
impl VersionedSerialSocket
pub fn new( socket: SharedMultiplexerSocket, config: Arc<ClientConfig>, versions: Versions ) -> Self
pub fn versions(&self) -> &Versions
sourcepub fn new_socket(&self) -> SharedMultiplexerSocket
pub fn new_socket(&self) -> SharedMultiplexerSocket
get new socket
sourcepub async fn send_receive<R>(
&self,
request: R
) -> Result<R::Response, SocketError>
pub async fn send_receive<R>( &self, request: R ) -> Result<R::Response, SocketError>
send and wait for reply serially
sourcepub async fn send_async<R>(
&self,
request: R
) -> Result<AsyncResponse<R>, SocketError>
pub async fn send_async<R>( &self, request: R ) -> Result<AsyncResponse<R>, SocketError>
send and do not wait for reply
sourcepub fn lookup_version<R>(&self) -> Option<Version>where
R: Request,
pub fn lookup_version<R>(&self) -> Option<Version>where
R: Request,
look up version for the request
sourcepub async fn send_receive_with_retry<R, I>(
&self,
request: R,
retries: I
) -> Result<R::Response, SocketError>
pub async fn send_receive_with_retry<R, I>( &self, request: R, retries: I ) -> Result<R::Response, SocketError>
send, wait for reply and retry if failed
sourcepub fn new_request<R>(
&self,
request: R,
version: Option<i16>
) -> RequestMessage<R>
pub fn new_request<R>( &self, request: R, version: Option<i16> ) -> RequestMessage<R>
create new request based on version
Trait Implementations§
source§impl Deref for VersionedSerialSocket
impl Deref for VersionedSerialSocket
source§impl Display for VersionedSerialSocket
impl Display for VersionedSerialSocket
source§impl SerialFrame for VersionedSerialSocket
impl SerialFrame for VersionedSerialSocket
source§fn config(&self) -> &ClientConfig
fn config(&self) -> &ClientConfig
client config
impl Send for VersionedSerialSocket
Auto Trait Implementations§
impl Freeze for VersionedSerialSocket
impl !RefUnwindSafe for VersionedSerialSocket
impl Sync for VersionedSerialSocket
impl Unpin for VersionedSerialSocket
impl !UnwindSafe for VersionedSerialSocket
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