Struct ratsio::nats_client::NatsClientOptionsBuilder

pub struct NatsClientOptionsBuilder { /* fields omitted */ }

Builder for NatsClientOptions.

Methods

impl NatsClientOptionsBuilder

pub fn username<VALUE: Into<String>>(&mut self, value: VALUE) -> &mut Self

Cluster username, can be overwritten by host url nats://:@:

pub fn password<VALUE: Into<String>>(&mut self, value: VALUE) -> &mut Self

Cluster password, can be overwritten by host url nats://:@:

pub fn auth_token<VALUE: Into<String>>(&mut self, value: VALUE) -> &mut Self

Cluster auth_token

pub fn tls_required<VALUE: Into<bool>>(&mut self, value: VALUE) -> &mut Self

Whether TLS is required.

pub fn verbose<VALUE: Into<bool>>(&mut self, value: VALUE) -> &mut Self

verbosity, default true

pub fn pedantic<VALUE: Into<bool>>(&mut self, value: VALUE) -> &mut Self

pedantic, default false

pub fn echo<VALUE: Into<bool>>(&mut self, value: VALUE) -> &mut Self

pedantic, default true

pub fn name<VALUE: Into<String>>(&mut self, value: VALUE) -> &mut Self

Optional client name

pub fn cluster_uris<VALUE: Into<UriVec>>(&mut self, value: VALUE) -> &mut Self

Cluster URI in the IP:PORT format

pub fn ping_interval<VALUE: Into<u16>>(&mut self, value: VALUE) -> &mut Self

Ping interfval in seconds

pub fn ping_max_out<VALUE: Into<u16>>(&mut self, value: VALUE) -> &mut Self

No of unsuccessful pings before the connection is deemed disconnected.

pub fn subscribe_on_reconnect<VALUE: Into<bool>>(
    &mut self,
    value: VALUE
) -> &mut Self

If we should re-subscribe all subscriptions on re-connection. If you don't want re-subscription, add a reconnect_handler and do your thing there.

pub fn ensure_connect<VALUE: Into<bool>>(&mut self, value: VALUE) -> &mut Self

If connect fails, keep trying, forever,

pub fn reconnect_timeout<VALUE: Into<u64>>(&mut self, value: VALUE) -> &mut Self

Time between connection retries

pub fn user_jwt<VALUE: Into<Option<UserJWT>>>(
    &mut self,
    value: VALUE
) -> &mut Self

When using NATS 2.x decentralized security, supply a user JWT for authN/authZ

pub fn build(&self) -> Result<NatsClientOptions, String>

Builds a new NatsClientOptions.

Errors

If a required field has not been initialized.

Trait Implementations

impl Clone for NatsClientOptionsBuilder

fn clone(&self) -> NatsClientOptionsBuilder

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for NatsClientOptionsBuilder

fn default() -> NatsClientOptionsBuilder

Returns the "default value" for a type.