Struct nakadion::consumer::BatchTimespanSecs

pub struct BatchTimespanSecs(_);

Useful for batching events based on their received_at timestamp.

Methods

impl BatchTimespanSecs

pub fn into_duration(self) -> Duration

impl BatchTimespanSecs

pub fn try_from_env() -> Result<Option<BatchTimespanSecs>, 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_ BATCH_TIMESPAN_SECS "

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

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

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

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<BatchTimespanSecs, 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_ BATCH_TIMESPAN_SECS "

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

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

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

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

Initialize from the environment.

Returns None if the value could not be read for any reason.

The name of the environment variable is "NAKADION_ BATCH_TIMESPAN_SECS "

pub fn from_env_opt_prefixed<T>(prefix: T) -> Option<BatchTimespanSecs> where
    T: Into<String>, 

Initialize from the environment.

Returns None if the value could not be read for any reason.

The name of the environment variable is "prefix_ BATCH_TIMESPAN_SECS "

pub fn from_env_opt_named<T>(var_name: T) -> Option<BatchTimespanSecs> where
    T: AsRef<str>, 

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 BatchTimespanSecs

pub fn new<T>(v: T) -> BatchTimespanSecs where
    T: Into<u32>, 

impl BatchTimespanSecs

pub fn into_inner(self) -> u32

Trait Implementations

impl Clone for BatchTimespanSecs

fn clone(&self) -> BatchTimespanSecs

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Copy for BatchTimespanSecs

impl Debug for BatchTimespanSecs

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for BatchTimespanSecs

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

Deserialize this value from the given Serde deserializer.

impl Display for BatchTimespanSecs

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

Formats the value using the given formatter.

impl Eq for BatchTimespanSecs

impl From<u32> for BatchTimespanSecs

fn from(v: u32) -> BatchTimespanSecs

Performs the conversion.

impl FromStr for BatchTimespanSecs

type Err = Error

The associated error which can be returned from parsing.

fn from_str(
    s: &str
) -> Result<BatchTimespanSecs, <BatchTimespanSecs as FromStr>::Err>

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

impl PartialEq<BatchTimespanSecs> for BatchTimespanSecs

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

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

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

This method tests for !=.

impl Serialize for BatchTimespanSecs

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

Serialize this value into the given Serde serializer.

impl StructuralEq for BatchTimespanSecs

impl StructuralPartialEq for BatchTimespanSecs