Struct fluvio_socket::VersionedSerialSocket

pub struct VersionedSerialSocket { /* private fields */ }

Connection that perform request/response

Implementations

impl VersionedSerialSocket

pub fn new( socket: SharedMultiplexerSocket, config: Arc<ClientConfig>, versions: Versions ) -> Self

pub fn versions(&self) -> &Versions

pub fn new_socket(&self) -> SharedMultiplexerSocket

get new socket

pub fn is_stale(&self) -> bool

Check if inner socket is stale

pub async fn send_receive<R>( &self, request: R ) -> Result<R::Response, SocketError>

where R: Request + Send + Sync,

send and wait for reply serially

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

pub fn lookup_version<R>(&self) -> Option<Version>

where R: Request,

look up version for the request

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

pub fn new_request<R>( &self, request: R, version: Option<i16> ) -> RequestMessage<R>

where R: Request + Send,

create new request based on version

Trait Implementations

impl Deref for VersionedSerialSocket

type Target = Arc<MultiplexerSocket>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl Display for VersionedSerialSocket

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

Formats the value using the given formatter.

impl SerialFrame for VersionedSerialSocket

fn config(&self) -> &ClientConfig

client config

impl Send for VersionedSerialSocket