Struct ratsio::ops::Connect

pub struct Connect {
    pub verbose: bool,
    pub pedantic: bool,
    pub tls_required: bool,
    pub auth_token: Option<String>,
    pub user: Option<String>,
    pub pass: Option<String>,
    pub name: Option<String>,
    pub lang: String,
    pub version: String,
    pub protocol: u32,
    pub echo: bool,
    pub sig: Option<String>,
    pub jwt: Option<String>,
}

CONNECT {["option_name":option_value],...}

The valid options are as follows:

• verbose: Turns on +OK protocol acknowledgements.
• pedantic: Turns on additional strict format checking, e.g. for properly formed subjects
• tls_required: Indicates whether the client requires an SSL connection.
• auth_token: Client authorization token (if auth_required is set)
• user: Connection username (if auth_required is set)
• pass: Connection password (if auth_required is set)
• name: Optional client name
• lang: The implementation language of the client.
• version: The version of the client.
• jwt: If using User JWT credentials, this contains an encoded JWT for the user
• sig: A signature produced from the nonce the server sent with its INFO message (if using JWT security)
• protocol: optional int. Sending 0 (or absent) indicates client supports original protocol. Sending 1 indicates that the client supports dynamic reconfiguration of cluster topology changes by asynchronously receiving INFO messages with known servers it can reconnect to.
• echo: Optional boolean. If set to true, the server (version 1.2.0+) will not send originating messages from this connection to its own subscriptions. Clients should set this to true only for server supporting this feature, which is when proto in the INFO protocol is set to at least 1.

Fields

verbose: bool

pedantic: bool

tls_required: bool

auth_token: Option<String>

user: Option<String>

pass: Option<String>

name: Option<String>

lang: String

version: String

protocol: u32

echo: bool

sig: Option<String>

jwt: Option<String>

Methods

impl Connect

pub fn builder() -> ConnectBuilder

Trait Implementations

impl Clone for Connect

fn clone(&self) -> Connect

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Connect

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

Formats the value using the given formatter.

impl Default for Connect

fn default() -> Self

Returns the "default value" for a type.

impl<'de> Deserialize<'de> for Connect

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl From<JsonValue> for Connect

fn from(value: JsonValue) -> Self

Performs the conversion.

impl PartialEq<Connect> for Connect

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

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

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

This method tests for !=.

impl Serialize for Connect

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 Connect