[−][src]Enum nakadion::components::connector::ConnectOnConflictRetryDelaySecs
The retry delay between failed attempts when the previous one was a conflict.
The defualt is 30 seconds
Variants
Use the same delay as after any other failed connect attempt
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 ConnectOnConflictRetryDelaySecs
[src]
pub const ENV_TYPE_NAME: &'static str
[src]
The default name of the environment variable for this type. The name of the environment variable is " CONNECT_ON_CONFLICT_RETRY_SECS "
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_ON_CONFLICT_RETRY_SECS
"
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_ON_CONFLICT_RETRY_SECS
"
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>
[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 try_from_env_type_name() -> 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 "
CONNECT_ON_CONFLICT_RETRY_SECS
"
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_ON_CONFLICT_RETRY_SECS "
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_ON_CONFLICT_RETRY_SECS
"
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>
[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_type_name() -> 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 " CONNECT_ON_CONFLICT_RETRY_SECS "
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_ON_CONFLICT_RETRY_SECS
"
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_ON_CONFLICT_RETRY_SECS
"
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>
[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 from_env_opt_type_name() -> 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 "
CONNECT_ON_CONFLICT_RETRY_SECS
"
pub fn into_duration_opt(self) -> Option<Duration>
[src]
Trait Implementations
impl Clone for ConnectOnConflictRetryDelaySecs
[src]
fn clone(&self) -> ConnectOnConflictRetryDelaySecs
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Copy for ConnectOnConflictRetryDelaySecs
[src]
impl Debug for ConnectOnConflictRetryDelaySecs
[src]
impl Default for ConnectOnConflictRetryDelaySecs
[src]
impl<'de> Deserialize<'de> for ConnectOnConflictRetryDelaySecs
[src]
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
[src]
__D: Deserializer<'de>,
impl Display for ConnectOnConflictRetryDelaySecs
[src]
impl Eq for ConnectOnConflictRetryDelaySecs
[src]
impl FromStr for ConnectOnConflictRetryDelaySecs
[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<ConnectOnConflictRetryDelaySecs> for ConnectOnConflictRetryDelaySecs
[src]
fn eq(&self, other: &ConnectOnConflictRetryDelaySecs) -> bool
[src]
fn ne(&self, other: &ConnectOnConflictRetryDelaySecs) -> bool
[src]
impl Serialize for ConnectOnConflictRetryDelaySecs
[src]
fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
__S: Serializer,
[src]
__S: Serializer,
impl StructuralEq for ConnectOnConflictRetryDelaySecs
[src]
impl StructuralPartialEq for ConnectOnConflictRetryDelaySecs
[src]
Auto Trait Implementations
impl RefUnwindSafe for ConnectOnConflictRetryDelaySecs
impl Send for ConnectOnConflictRetryDelaySecs
impl Sync for ConnectOnConflictRetryDelaySecs
impl Unpin for ConnectOnConflictRetryDelaySecs
impl UnwindSafe for ConnectOnConflictRetryDelaySecs
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,
[src]
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>,