Enum nakadion::publisher::PartialFailureStrategy

pub enum PartialFailureStrategy {
    Abort,
    RetryAll,
    RetryNotSubmitted,
}

Strategy for handling partial submit failures

The default is PartialFailureStrategy::Abort

Variants

Abort

Always abort. Never retry on partial failures.

RetryAll

Always retry all events

RetryNotSubmitted

Only retry those events where the publishing status is not PublishingStatus::Submitted

Implementations

impl PartialFailureStrategy

pub const ENV_TYPE_NAME: &'static str

The default name of the environment variable for this type.

The name of the environment variable is " PUBLISH_PARTIAL_FAILURE_STRATEGY "

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

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

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

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

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

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

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

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

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

Trait Implementations

impl Clone for PartialFailureStrategy

fn clone(&self) -> PartialFailureStrategy

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Copy for PartialFailureStrategy

impl Debug for PartialFailureStrategy

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

Formats the value using the given formatter.

impl Default for PartialFailureStrategy

fn default() -> Self

Returns the "default value" for a type.

impl<'de> Deserialize<'de> for PartialFailureStrategy

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

Deserialize this value from the given Serde deserializer.

impl Display for PartialFailureStrategy

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

Formats the value using the given formatter.

impl FromStr for PartialFailureStrategy

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 Serialize for PartialFailureStrategy

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

Serialize this value into the given Serde serializer.