Struct fluvio_socket::VersionedSocket
source · pub struct VersionedSocket { /* private fields */ }
Expand description
This sockets knows about support versions Version information are automatically insert into request
Implementations§
source§impl VersionedSocket
impl VersionedSocket
sourcepub async fn connect(
socket: FluvioSocket,
config: Arc<ClientConfig>
) -> Result<Self, SocketError>
pub async fn connect( socket: FluvioSocket, config: Arc<ClientConfig> ) -> Result<Self, SocketError>
connect to end point and retrieve versions
pub fn split(self) -> (FluvioSocket, Arc<ClientConfig>, Versions)
Trait Implementations§
source§impl Display for VersionedSocket
impl Display for VersionedSocket
source§impl SerialFrame for VersionedSocket
impl SerialFrame for VersionedSocket
source§fn config(&self) -> &ClientConfig
fn config(&self) -> &ClientConfig
client config
Auto Trait Implementations§
impl !RefUnwindSafe for VersionedSocket
impl Send for VersionedSocket
impl Sync for VersionedSocket
impl Unpin for VersionedSocket
impl !UnwindSafe for VersionedSocket
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