[−][src]Enum nakadion::consumer::ConnectTimeout
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
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.
Methods
impl ConnectTimeout
[src]
pub fn try_from_env() -> Result<Option<Self>, Error>
[src]
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>
[src]
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
"
pub fn try_from_env_named<T: AsRef<str>>(
var_name: T
) -> Result<Option<Self>, Error>
[src]
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 from_env() -> Result<Self, Error>
[src]
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>
[src]
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
"
pub fn from_env_named<T: AsRef<str>>(var_name: T) -> Result<Self, Error>
[src]
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_opt() -> Option<Self>
[src]
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>
[src]
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
"
pub fn from_env_opt_named<T: AsRef<str>>(var_name: T) -> Option<Self>
[src]
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 into_duration_opt(self) -> Option<Duration>
[src]
Trait Implementations
impl Clone for ConnectTimeout
[src]
fn clone(&self) -> ConnectTimeout
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Copy for ConnectTimeout
[src]
impl Debug for ConnectTimeout
[src]
impl Default for ConnectTimeout
[src]
impl<'de> Deserialize<'de> for ConnectTimeout
[src]
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
[src]
__D: Deserializer<'de>,
impl Display for ConnectTimeout
[src]
impl Eq for ConnectTimeout
[src]
impl<T> From<T> for ConnectTimeout where
T: Into<u64>,
[src]
T: Into<u64>,
impl FromStr for ConnectTimeout
[src]
type Err = Error
The associated error which can be returned from parsing.
fn from_str(s: &str) -> Result<Self, Self::Err>
[src]
impl PartialEq<ConnectTimeout> for ConnectTimeout
[src]
fn eq(&self, other: &ConnectTimeout) -> bool
[src]
fn ne(&self, other: &ConnectTimeout) -> bool
[src]
impl Serialize for ConnectTimeout
[src]
fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
__S: Serializer,
[src]
__S: Serializer,
impl StructuralEq for ConnectTimeout
[src]
impl StructuralPartialEq for ConnectTimeout
[src]
Auto Trait Implementations
impl RefUnwindSafe for ConnectTimeout
impl Send for ConnectTimeout
impl Sync for ConnectTimeout
impl Unpin for ConnectTimeout
impl UnwindSafe for ConnectTimeout
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> DeserializeOwned for T where
T: for<'de> Deserialize<'de>,
[src]
T: for<'de> Deserialize<'de>,
impl<Q, K> Equivalent<K> for Q where
K: Borrow<Q> + ?Sized,
Q: Eq + ?Sized,
[src]
K: Borrow<Q> + ?Sized,
Q: Eq + ?Sized,
fn equivalent(&self, key: &K) -> bool
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> SendSyncUnwindSafe for T where
T: Send + Sync + UnwindSafe + ?Sized,
T: Send + Sync + UnwindSafe + ?Sized,
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> ToString for T where
T: Display + ?Sized,
[src]
T: Display + ?Sized,
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>,