Struct fluvio::metadata::smartmodule::ClientConfig

pub struct ClientConfig { /* private fields */ }

Low level configuration option to directly connect to Fluvio This can bypass higher level validation required for CLI and end user application

Implementations

impl ClientConfig

pub fn new( addr: impl Into<String>, connector: Box<dyn TcpDomainConnector>, use_spu_local_address: bool ) -> ClientConfig

pub fn with_addr(addr: String) -> ClientConfig

pub fn addr(&self) -> &str

pub fn client_id(&self) -> &str

pub fn use_spu_local_address(&self) -> bool

pub fn set_client_id(&mut self, id: impl Into<String>)

pub fn set_addr(&mut self, domain: String)

pub async fn connect(self) -> Result<VersionedSocket, SocketError>

pub fn with_prefix_sni_domain(&self, prefix: &str) -> ClientConfig

create new config with prefix add to domain, this is useful for SNI

Trait Implementations

impl Debug for ClientConfig

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

Formats the value using the given formatter.

impl Display for ClientConfig

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

Formats the value using the given formatter.

impl From<String> for ClientConfig

fn from(addr: String) -> ClientConfig

Converts to this type from the input type.

impl TryFrom<FluvioConfig> for ClientConfig

type Error = Error

The type returned in the event of a conversion error.

fn try_from(config: FluvioConfig) -> Result<Self, Self::Error>

Performs the conversion.