Struct ClientBuilder

pub struct ClientBuilder { /* private fields */ }

Implementations

impl ClientBuilder

pub fn new(proto: Topic) -> Self

Creates a builder connect to a server using some protocol.

pub fn set_agent_name(&mut self, name: &str)

Sets the agent name.

pub fn set_exact_agent_str(&mut self, agent_str: String)

Sets the full agent string without supplementary info.

pub fn set_connect_timeout(&mut self, tout: Duration)

Sets the connection timeout.

pub async fn connect_tcp_authed<A: AuthConfig>( self, socket_addr: SocketAddr, auth: A, ) -> Result<ConnectionHandle, Error>

Connects to a server using a Tokio TCP stream and a provided auth config.

pub async fn connect_tcp( self, socket_addr: SocketAddr, ) -> Result<ConnectionHandle, Error>

Connects to a server using a Tokio TCP stream without an auth config.