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>where
R: Request + Send + Sync,
pub async fn send_receive<R>( &self, request: R ) -> Result<R::Response, SocketError>where R: Request + Send + Sync,
send and wait for reply serially
sourcepub async fn send_async<R>(
&self,
request: R
) -> Result<AsyncResponse<R>, SocketError>where
R: Request + Send + Sync,
pub async fn send_async<R>( &self, request: R ) -> Result<AsyncResponse<R>, SocketError>where R: Request + Send + Sync,
send and do not wait for reply
sourcepub async fn send_receive_with_retry<R, I>(
&self,
request: R,
retries: I
) -> Result<R::Response, SocketError>where
R: Request + Send + Sync + Clone,
I: IntoIterator<Item = Duration> + Debug + Send,
pub async fn send_receive_with_retry<R, I>( &self, request: R, retries: I ) -> Result<R::Response, SocketError>where R: Request + Send + Sync + Clone, I: IntoIterator<Item = Duration> + Debug + Send,
send, wait for reply and retry if failed
Trait Implementations§
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