Struct ConnectionConfig

pub struct ConnectionConfig {
    pub subscriptions: Box<[Subject]>,
    pub consumers: Box<[ConsumerConfig]>,
    pub cluster_uris: Box<[Box<str>]>,
    pub auth_jwt: Option<Box<str>>,
    pub auth_seed: Option<Box<str>>,
    pub tls_ca: Option<Box<str>>,
    pub tls_ca_file: Option<Box<str>>,
    pub ping_interval_sec: Option<u16>,
    pub custom_inbox_prefix: Option<Box<str>>,
}

Configuration for connecting a nats client. More options are available if you use the json than variables in the values string map.

Fields

subscriptions: Box<[Subject]>

List of topics to subscribe to

consumers: Box<[ConsumerConfig]>

List of JetStream consumers

cluster_uris: Box<[Box<str>]>

Cluster(s) to make a subscription on and connect to

auth_jwt: Option<Box<str>>

Auth JWT to use (if necessary)

auth_seed: Option<Box<str>>

Auth seed to use (if necessary)

tls_ca: Option<Box<str>>

TLS Certificate Authority, encoded as a string

tls_ca_file: Option<Box<str>>

TLS Certifiate Authority, as a path on disk

ping_interval_sec: Option<u16>

Ping interval in seconds

custom_inbox_prefix: Option<Box<str>>

Inbox prefix to use (by default

Implementations

impl ConnectionConfig

pub fn merge(&self, extra: &ConnectionConfig) -> ConnectionConfig

Merge a given ConnectionConfig with another, coalescing fields and overriding where necessary

impl ConnectionConfig

pub fn from_link_config(_: &LinkConfig<'_>) -> Result<ConnectionConfig>

Create a ConnectionConfig from a given LinkConfig

pub fn from_map(values: &HashMap<String, String>) -> Result<ConnectionConfig>

Construct configuration Struct from the passed hostdata config

NOTE: Prefer Self::from_link_config rather than this method directly

Trait Implementations

impl Clone for ConnectionConfig

fn clone(&self) -> ConnectionConfig

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ConnectionConfig

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

Formats the value using the given formatter.

impl Default for ConnectionConfig

fn default() -> ConnectionConfig

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ConnectionConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for ConnectionConfig

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for ConnectionConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for ConnectionConfig