[−][src]Struct ratsio::ops::Connect
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
[src]
pub fn builder() -> ConnectBuilder
[src]
Trait Implementations
impl Clone for Connect
[src]
impl Debug for Connect
[src]
impl Default for Connect
[src]
impl<'de> Deserialize<'de> for Connect
[src]
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
[src]
__D: Deserializer<'de>,
impl From<JsonValue> for Connect
[src]
impl PartialEq<Connect> for Connect
[src]
impl Serialize for Connect
[src]
fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
__S: Serializer,
[src]
__S: Serializer,
impl StructuralPartialEq for Connect
[src]
Auto Trait Implementations
impl RefUnwindSafe for Connect
impl Send for Connect
impl Sync for Connect
impl Unpin for Connect
impl UnwindSafe for Connect
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> Clear for T where
T: InitializableFromZeroed + ?Sized,
T: InitializableFromZeroed + ?Sized,
fn clear(&mut self)
impl<T> DeserializeOwned for T where
T: Deserialize<'de>,
[src]
T: Deserialize<'de>,
impl<T> Erased for T
impl<T> From<T> for T
[src]
impl<T> InitializableFromZeroed for T where
T: Default,
T: Default,
unsafe fn initialize(place: *mut T)
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> Same<T> for T
type Output = T
Should always be Self
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,