[][src]Enum nakadion::publisher::SubmissionFailureStrategy

#[non_exhaustive]pub enum SubmissionFailureStrategy {
    Abort,
    RetryAll,
    RetryNotSubmitted,
}

Strategy for handling partial submit failures

The default is SubmissionFailureStrategy::Abort

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.
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 SubmissionFailureStrategy[src]

pub const ENV_TYPE_NAME: &'static str[src]

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

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

pub fn try_from_env_prefixed<T: Into<String>>(
    prefix: T
) -> 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 "prefix_ PUBLISH_SUBMISSION_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>
[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 var_name.

pub fn try_from_env_type_name() -> 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 " PUBLISH_SUBMISSION_FAILURE_STRATEGY "

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

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_ PUBLISH_SUBMISSION_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>[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_type_name() -> 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 " PUBLISH_SUBMISSION_FAILURE_STRATEGY "

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

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_ PUBLISH_SUBMISSION_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>[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.

pub fn from_env_opt_type_name() -> 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 " PUBLISH_SUBMISSION_FAILURE_STRATEGY "

Trait Implementations

impl Clone for SubmissionFailureStrategy[src]

impl Copy for SubmissionFailureStrategy[src]

impl Debug for SubmissionFailureStrategy[src]

impl Default for SubmissionFailureStrategy[src]

impl<'de> Deserialize<'de> for SubmissionFailureStrategy[src]

impl Display for SubmissionFailureStrategy[src]

impl FromStr for SubmissionFailureStrategy[src]

type Err = Error

The associated error which can be returned from parsing.

impl Serialize for SubmissionFailureStrategy[src]

Auto Trait Implementations

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> DeserializeOwned for T where
    T: for<'de> Deserialize<'de>, 
[src]

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T> SendSyncUnwindSafe for T where
    T: Send + Sync + UnwindSafe + ?Sized

impl<T> ToOwned for T where
    T: Clone
[src]

type Owned = T

The resulting type after obtaining ownership.

impl<T> ToString for T where
    T: Display + ?Sized
[src]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<V, T> VZip<V> for T where
    V: MultiLane<T>,