Struct tokio_nsq::NSQConfigShared

pub struct NSQConfigShared { /* fields omitted */ }

Configuration options shared by both produces and consumers

Implementations

impl NSQConfigShared

pub fn new() -> Self

Construct a configuration with sane defaults.

pub fn set_backoff_max_wait(self, duration: Duration) -> Self

The maximum reconnect backoff wait. Defaults to 60 seconds.

pub fn set_backoff_healthy_after(self, duration: Duration) -> Self

How long a connection should be healthy before backoff is reset. Defaults to 45 seconds.

pub fn set_compression(self, compression: NSQConfigSharedCompression) -> Self

Connection compression options. Defaults to no compression.

pub fn set_credentials(self, credentials: Vec<u8>) -> Self

Credentials to send NSQD if authentication is requried. Defaults to no credentials.

pub fn set_tls(self, tls: NSQConfigSharedTLS) -> Self

Connection encryption options. Defaults to no encryption

pub fn set_client_id<S: Into<String>>(self, client_id: S) -> Self

A string used to identify an NSQ client. Defaults to anonymous identity.

pub fn set_write_timeout(self, duration: Option<Duration>) -> Self

Timeout for socket write operations. Defaults to 10 seconds. Setting the duration to None disables write timeouts.

pub fn set_read_timeout(self, duration: Option<Duration>) -> Self

Timeout for socket read operations. Defaults to 60 seconds. Must be greater than the heartbeat interval. Setting the duration to None disables read timeouts.

pub fn set_hostname<S: Into<String>>(self, hostname: S) -> Self

The hostname sent to NSQD. Defaults to the hostname provided by the operating system.

pub fn set_user_agent<S: Into<String>>(self, user_agent: S) -> Self

The user agent sent to NSQD. Defaults to "tokio_nsq/".

Trait Implementations

impl Clone for NSQConfigShared

fn clone(&self) -> NSQConfigShared

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for NSQConfigShared

fn default() -> Self

Returns the "default value" for a type.