Struct ratsio::nats_client::NatsClientOptionsBuilder

pub struct NatsClientOptionsBuilder { /* fields omitted */ }

Builder for NatsClientOptions.

Methods

impl NatsClientOptionsBuilder

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

CONNECT command that will be sent upon calling the connect() method

pub fn cluster_uris<VALUE: Into<Vec<String>>>(     &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 build(&self) -> Result<NatsClientOptions, String>

Builds a new NatsClientOptions.

Errors

If a required field has not been initialized.

Trait Implementations

impl Default for NatsClientOptionsBuilder

fn default() -> NatsClientOptionsBuilder

Returns the "default value" for a type.

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.