Enum nakadion::components::connector::ConnectOnConflictRetryDelaySecs

pub enum ConnectOnConflictRetryDelaySecs {
    Default,
    Seconds(u64),
}

The retry delay between failed attempts when the previous one was a conflict.

The defualt is 30 seconds

Variants

Default

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

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_ON_CONFLICT_RETRY_SECS "

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_ON_CONFLICT_RETRY_SECS "

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_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>

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_ON_CONFLICT_RETRY_SECS "

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_ON_CONFLICT_RETRY_SECS "

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_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>

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_ON_CONFLICT_RETRY_SECS "

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_ON_CONFLICT_RETRY_SECS "

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_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>

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_ON_CONFLICT_RETRY_SECS "

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

Trait Implementations

impl Clone for ConnectOnConflictRetryDelaySecs

pub fn clone(&self) -> ConnectOnConflictRetryDelaySecs

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Copy for ConnectOnConflictRetryDelaySecs

impl Debug for ConnectOnConflictRetryDelaySecs

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

Formats the value using the given formatter.

impl Default for ConnectOnConflictRetryDelaySecs

pub fn default() -> Self

Returns the "default value" for a type.

impl<'de> Deserialize<'de> for ConnectOnConflictRetryDelaySecs

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

Deserialize this value from the given Serde deserializer.

impl Display for ConnectOnConflictRetryDelaySecs

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

Formats the value using the given formatter.

impl Eq for ConnectOnConflictRetryDelaySecs

impl FromStr for ConnectOnConflictRetryDelaySecs

type Err = Error

The associated error which can be returned from parsing.

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

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

impl PartialEq<ConnectOnConflictRetryDelaySecs> for ConnectOnConflictRetryDelaySecs

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

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

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

This method tests for !=.

impl Serialize for ConnectOnConflictRetryDelaySecs

pub 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 ConnectOnConflictRetryDelaySecs

impl StructuralPartialEq for ConnectOnConflictRetryDelaySecs