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<S>( addr: S, connector: Box<dyn TcpDomainConnector + 'static, Global>, use_spu_local_address: bool ) -> ClientConfigwhere S: Into<String>,

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 ) -> impl Future<Output = 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.