[−][src]Struct nakadion::consumer::TickIntervalMillis
The internal tick interval.
The applied value is always between [100..5_000] ms. When set outside of its bounds it will be adjusted to fit within the bounds.
Methods
impl TickIntervalMillis
[src]
impl TickIntervalMillis
[src]
pub fn into_inner(self) -> u64
[src]
impl TickIntervalMillis
[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_ TICK_INTERVAL_MILLIS "
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
_
TICK_INTERVAL_MILLIS
"
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_ TICK_INTERVAL_MILLIS "
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
_
TICK_INTERVAL_MILLIS
"
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_ TICK_INTERVAL_MILLIS "
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
_
TICK_INTERVAL_MILLIS
"
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
.
impl TickIntervalMillis
[src]
pub fn into_duration(self) -> Duration
[src]
pub fn adjust(self) -> TickIntervalMillis
[src]
Only 100ms up to 5_000ms allowed. We simply adjust the values because there is no reason to crash if these have been set to an out of range value.
Trait Implementations
impl Clone for TickIntervalMillis
[src]
fn clone(&self) -> TickIntervalMillis
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Copy for TickIntervalMillis
[src]
impl Debug for TickIntervalMillis
[src]
impl Default for TickIntervalMillis
[src]
impl<'de> Deserialize<'de> for TickIntervalMillis
[src]
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
[src]
__D: Deserializer<'de>,
impl Display for TickIntervalMillis
[src]
impl Eq for TickIntervalMillis
[src]
impl From<TickIntervalMillis> for u64
[src]
fn from(v: TickIntervalMillis) -> u64
[src]
impl From<TickIntervalMillis> for Duration
[src]
fn from(v: TickIntervalMillis) -> Self
[src]
impl From<u64> for TickIntervalMillis
[src]
fn from(v: u64) -> TickIntervalMillis
[src]
impl FromStr for TickIntervalMillis
[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<TickIntervalMillis> for TickIntervalMillis
[src]
fn eq(&self, other: &TickIntervalMillis) -> bool
[src]
fn ne(&self, other: &TickIntervalMillis) -> bool
[src]
impl Serialize for TickIntervalMillis
[src]
fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
__S: Serializer,
[src]
__S: Serializer,
impl StructuralEq for TickIntervalMillis
[src]
impl StructuralPartialEq for TickIntervalMillis
[src]
Auto Trait Implementations
impl RefUnwindSafe for TickIntervalMillis
impl Send for TickIntervalMillis
impl Sync for TickIntervalMillis
impl Unpin for TickIntervalMillis
impl UnwindSafe for TickIntervalMillis
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: Deserialize<'de>,
[src]
T: 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>,