Struct ratsio::nats_client::NatsClientOptions

pub struct NatsClientOptions {
    pub connect: Connect,
    pub cluster_uris: Vec<String>,
    pub ping_interval: u16,
    pub ping_max_out: u16,
    pub subscribe_on_reconnect: bool,
    pub ensure_connect: bool,
    pub reconnect_timeout: u64,
}

Options that are to be given to the client for initialization

Fields

connect: Connect

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

cluster_uris: Vec<String>

Cluster URI in the IP:PORT format

ping_interval: u16

Ping interfval in seconds

ping_max_out: u16

No of unsuccessful pings before the connection is deemed disconnected.

subscribe_on_reconnect: bool

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.

ensure_connect: bool

If connect fails, keep trying, forever,

reconnect_timeout: u64

Time between connection retries

Methods

impl NatsClientOptions

pub fn builder() -> NatsClientOptionsBuilder

Trait Implementations

impl Default for NatsClientOptions

fn default() -> Self

Returns the "default value" for a type.

impl PartialEq<NatsClientOptions> for NatsClientOptions

fn eq(&self, other: &NatsClientOptions) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &NatsClientOptions) -> bool

This method tests for !=.

impl Clone for NatsClientOptions

fn clone(&self) -> NatsClientOptions

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for NatsClientOptions

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.