Struct nakadion::components::connector::ConnectAbortOnAuthError

pub struct ConnectAbortOnAuthError(_);

If true abort the consumer when an auth error occurs while connecting to a stream.

In some environments it can be good retry on auth errors since it it might take some time for auth to be set up correctly

The default is false which means no abort occurs on auth errors.

Implementations

impl ConnectAbortOnAuthError

pub fn new<T: Into<bool>>(v: T) -> Self

impl ConnectAbortOnAuthError

pub fn into_inner(self) -> bool

impl ConnectAbortOnAuthError

pub const ENV_TYPE_NAME: &'static str

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

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

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

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

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

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

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

Trait Implementations

impl Clone for ConnectAbortOnAuthError

fn clone(&self) -> ConnectAbortOnAuthError

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Copy for ConnectAbortOnAuthError

impl Debug for ConnectAbortOnAuthError

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

Formats the value using the given formatter.

impl Default for ConnectAbortOnAuthError

fn default() -> Self

Returns the "default value" for a type.

impl<'de> Deserialize<'de> for ConnectAbortOnAuthError

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

Deserialize this value from the given Serde deserializer.

impl Display for ConnectAbortOnAuthError

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

Formats the value using the given formatter.

impl Eq for ConnectAbortOnAuthError

impl From<ConnectAbortOnAuthError> for bool

fn from(v: ConnectAbortOnAuthError) -> bool

Performs the conversion.

impl From<bool> for ConnectAbortOnAuthError

fn from(v: bool) -> ConnectAbortOnAuthError

Performs the conversion.

impl FromStr for ConnectAbortOnAuthError

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<ConnectAbortOnAuthError> for ConnectAbortOnAuthError

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

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

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

This method tests for !=.

impl Serialize for ConnectAbortOnAuthError

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 ConnectAbortOnAuthError

impl StructuralPartialEq for ConnectAbortOnAuthError