Trait fluvio_future::net::TcpDomainConnector
source · pub trait TcpDomainConnector: AsyncConnector {
// Required methods
fn connect<'life0, 'life1, 'async_trait>(
&'life0 self,
domain: &'life1 str
) -> Pin<Box<dyn Future<Output = Result<(BoxWriteConnection, BoxReadConnection, ConnectionFd), IoError>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait;
fn new_domain(&self, domain: String) -> DomainConnector;
fn domain(&self) -> &str;
}
Expand description
connect to domain and return connection