Enum nakadion::consumer::ConnectTimeout

pub enum ConnectTimeout {
    Infinite,
    Seconds(u64),
}

The timeout for a request made to Nakadi to connect to a stream including retries

FromStr

ConnectTimeout can be parsed from a str slice.

use nakadion::components::connector::ConnectTimeout;

let ct: ConnectTimeout = "infinite".parse().unwrap();
assert_eq!(ct, ConnectTimeout::Infinite);

let ct: ConnectTimeout = "60".parse().unwrap();
assert_eq!(ct, ConnectTimeout::Seconds(60));

// JSON also works

let ct: ConnectTimeout = "\"infinite\"".parse().unwrap();
assert_eq!(ct, ConnectTimeout::Infinite);

let ct: ConnectTimeout = r#"{"seconds":60}"#.parse().unwrap();
assert_eq!(ct, ConnectTimeout::Seconds(60));

let ct: ConnectTimeout = "59".parse().unwrap();
assert_eq!(ct, ConnectTimeout::Seconds(59));

Serialize/Deserialize

use nakadion::components::connector::ConnectTimeout;
use serde_json::{self, json};

let infinite_json = json!("infinite");
let ct: ConnectTimeout = serde_json::from_value(infinite_json).unwrap();
assert_eq!(ct, ConnectTimeout::Infinite);

let seconds_json = json!({"seconds": 25});
let ct: ConnectTimeout = serde_json::from_value(seconds_json).unwrap();
assert_eq!(ct, ConnectTimeout::Seconds(25));

Variants

Infinite

There is no limit on the number of connect attempts being done

Seconds(u64)

Retry only for the given time.

This not an exact value and the effective timeout might be longer than the value given here.

Implementations

impl ConnectTimeout

pub const ENV_TYPE_NAME: &'static str

The default name of the environment variable for this type. The name of the environment variable is " CONNECT_TIMEOUT "

pub fn try_from_env() -> Result<Option<Self>, Error>

Initialize from the environment. Returns None if the value was not found and fails if the value could not be parsed. The name of the environment variable is "NAKADION_ CONNECT_TIMEOUT "

pub fn try_from_env_prefixed<T: Into<String>>(
    prefix: T
) -> Result<Option<Self>, Error>

Initialize from the environment. Returns None if the value was not found and fails if the value could not be parsed. The name of the environment variable is "prefix_ CONNECT_TIMEOUT " The underscore and prefix will be omitted if prefix is empty.

pub fn try_from_env_named<T: AsRef<str>>(
    var_name: T
) -> Result<Option<Self>, Error>

Initialize from the environment. Returns None if the value was not found and fails if the value could not be parsed. The name of the environment variable is var_name.

pub fn try_from_env_type_name() -> Result<Option<Self>, Error>

Initialize from the environment. Returns None if the value was not found and fails if the value could not be parsed. The name of the environment variable is " CONNECT_TIMEOUT "

pub fn from_env() -> Result<Self, Error>

Initialize from the environment. Fails if the value was not found or if the value could not be parsed. The name of the environment variable is "NAKADION_ CONNECT_TIMEOUT "

pub fn from_env_prefixed<T: Into<String>>(prefix: T) -> Result<Self, Error>

Initialize from the environment. Fails if the value was not found or if the value could not be parsed. The name of the environment variable is "prefix_ CONNECT_TIMEOUT " The underscore and prefix will be omitted if prefix is empty.

pub fn from_env_named<T: AsRef<str>>(var_name: T) -> Result<Self, Error>

Initialize from the environment. Fails if the value was not found or if the value could not be parsed. The name of the environment variable is var_name.

pub fn from_env_type_name() -> Result<Self, Error>

Initialize from the environment. Fails if the value was not found or if the value could not be parsed. The name of the environment variable is " CONNECT_TIMEOUT "

pub fn from_env_opt() -> Option<Self>

Initialize from the environment. Returns None if the value could not be read for any reason. The name of the environment variable is "NAKADION_ CONNECT_TIMEOUT "

pub fn from_env_opt_prefixed<T: Into<String>>(prefix: T) -> Option<Self>

Initialize from the environment. Returns None if the value could not be read for any reason. The name of the environment variable is "prefix_ CONNECT_TIMEOUT " The underscore and prefix will be omitted if prefix is empty.

pub fn from_env_opt_named<T: AsRef<str>>(var_name: T) -> Option<Self>

Initialize from the environment. Returns None if the value could not be read for any reason. The name of the environment variable is var_name.

pub fn from_env_opt_type_name() -> Option<Self>

Initialize from the environment. Returns None if the value could not be read for any reason. The name of the environment variable is " CONNECT_TIMEOUT "

pub fn into_duration_opt(self) -> Option<Duration>

Trait Implementations

impl Clone for ConnectTimeout

fn clone(&self) -> ConnectTimeout

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Copy for ConnectTimeout

impl Debug for ConnectTimeout

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

Formats the value using the given formatter.

impl Default for ConnectTimeout

fn default() -> Self

Returns the "default value" for a type.

impl<'de> Deserialize<'de> for ConnectTimeout

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

Deserialize this value from the given Serde deserializer.

impl Display for ConnectTimeout

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

Formats the value using the given formatter.

impl Eq for ConnectTimeout

impl<T> From<T> for ConnectTimeout where
    T: Into<u64>, 

fn from(v: T) -> Self

Performs the conversion.

impl FromStr for ConnectTimeout

type Err = Error

The associated error which can be returned from parsing.

fn from_str(s: &str) -> Result<Self, Self::Err>

Parses a string s to return a value of this type.

impl PartialEq<ConnectTimeout> for ConnectTimeout

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

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

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

This method tests for !=.

impl Serialize for ConnectTimeout

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

Serialize this value into the given Serde serializer.

impl StructuralEq for ConnectTimeout

impl StructuralPartialEq for ConnectTimeout