Enum nakadion::consumer::complex_types::StreamDeadPolicy

#[non_exhaustive]pub enum StreamDeadPolicy {
    Never,
    NoFramesFor {
        seconds: u32,
    },
    NoEventsFor {
        seconds: u32,
    },
}

Specifies when a stream is considered dead and has to be aborted.

Once a stream is considered dead a reconnect for a new stream will be attempted.

The default is NoFramesFor { seconds: 300 }

FromStr

use nakadion::consumer::StreamDeadPolicy;

let policy = "never".parse::<StreamDeadPolicy>().unwrap();
assert_eq!(policy, StreamDeadPolicy::Never);

let policy = "no_frames_for_seconds 1".parse::<StreamDeadPolicy>().unwrap();
assert_eq!(
    policy,
    StreamDeadPolicy::NoFramesFor { seconds: 1}
);

let policy = "no_events_for_seconds 2".parse::<StreamDeadPolicy>().unwrap();
assert_eq!(
    policy,
    StreamDeadPolicy::NoEventsFor { seconds: 2}
);

JSON is also valid:

use nakadion::consumer::StreamDeadPolicy;

let policy = r#""never""#.parse::<StreamDeadPolicy>().unwrap();
assert_eq!(policy, StreamDeadPolicy::Never);

let policy = r#"{"no_frames_for":{"seconds": 1}}"#.parse::<StreamDeadPolicy>().unwrap();
assert_eq!(
    policy,
    StreamDeadPolicy::NoFramesFor { seconds: 1}
);

let policy = r#"{"no_events_for":{"seconds": 2}}"#.parse::<StreamDeadPolicy>().unwrap();
assert_eq!(
    policy,
    StreamDeadPolicy::NoEventsFor { seconds: 2}
);

Environment variables

Fetching values from the environment uses FromStr for parsing

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Never

The stream is never considered dead

NoFramesFor

The stream is considered dead if no frames (lines) have been received from Nakadi for seconds

Fields of NoFramesFor

seconds: u32

NoEventsFor

The stream is considered dead if no events (lines with events) have been received from Nakadi for seconds

Fields of NoEventsFor

seconds: u32

Implementations

impl StreamDeadPolicy

pub const ENV_TYPE_NAME: &'static str

The default name of the environment variable for this type. The name of the environment variable is " STREAM_DEAD_POLICY "

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

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

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

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

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

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

pub fn validate(self) -> Result<(), Error>

Trait Implementations

impl Clone for StreamDeadPolicy

fn clone(&self) -> StreamDeadPolicy

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Copy for StreamDeadPolicy

impl Debug for StreamDeadPolicy

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

Formats the value using the given formatter.

impl Default for StreamDeadPolicy

fn default() -> Self

Returns the "default value" for a type.

impl<'de> Deserialize<'de> for StreamDeadPolicy

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

Deserialize this value from the given Serde deserializer.

impl Display for StreamDeadPolicy

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

Formats the value using the given formatter.

impl Eq for StreamDeadPolicy

impl FromStr for StreamDeadPolicy

type Err = Error

The associated error which can be returned from parsing.

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

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

impl PartialEq<StreamDeadPolicy> for StreamDeadPolicy

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

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

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

This method tests for !=.

impl Serialize for StreamDeadPolicy

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 StreamDeadPolicy

impl StructuralPartialEq for StreamDeadPolicy