[−][src]Struct nakadion::components::connector::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
[src]
impl ConnectAbortOnAuthError
[src]
pub fn into_inner(self) -> bool
[src]
impl ConnectAbortOnAuthError
[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 " CONNECT_ABORT_ON_AUTH_ERROR "
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_
CONNECT_ABORT_ON_AUTH_ERROR
"
pub fn try_from_env_prefixed<T: Into<String>>(
prefix: T
) -> Result<Option<Self>, Error>
[src]
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>
[src]
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>
[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 "
CONNECT_ABORT_ON_AUTH_ERROR
"
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_ CONNECT_ABORT_ON_AUTH_ERROR "
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
_
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>
[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 " CONNECT_ABORT_ON_AUTH_ERROR "
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_
CONNECT_ABORT_ON_AUTH_ERROR
"
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
_
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>
[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 "
CONNECT_ABORT_ON_AUTH_ERROR
"
Trait Implementations
impl Clone for ConnectAbortOnAuthError
[src]
pub fn clone(&self) -> ConnectAbortOnAuthError
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Copy for ConnectAbortOnAuthError
[src]
impl Debug for ConnectAbortOnAuthError
[src]
impl Default for ConnectAbortOnAuthError
[src]
impl<'de> Deserialize<'de> for ConnectAbortOnAuthError
[src]
pub fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
[src]
__D: Deserializer<'de>,
impl Display for ConnectAbortOnAuthError
[src]
impl Eq for ConnectAbortOnAuthError
[src]
impl From<bool> for ConnectAbortOnAuthError
[src]
pub fn from(v: bool) -> ConnectAbortOnAuthError
[src]
impl FromStr for ConnectAbortOnAuthError
[src]
type Err = Error
The associated error which can be returned from parsing.
pub fn from_str(s: &str) -> Result<Self, Self::Err>
[src]
impl PartialEq<ConnectAbortOnAuthError> for ConnectAbortOnAuthError
[src]
pub fn eq(&self, other: &ConnectAbortOnAuthError) -> bool
[src]
pub fn ne(&self, other: &ConnectAbortOnAuthError) -> bool
[src]
impl Serialize for ConnectAbortOnAuthError
[src]
pub fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
__S: Serializer,
[src]
__S: Serializer,
impl StructuralEq for ConnectAbortOnAuthError
[src]
impl StructuralPartialEq for ConnectAbortOnAuthError
[src]
Auto Trait Implementations
impl RefUnwindSafe for ConnectAbortOnAuthError
[src]
impl Send for ConnectAbortOnAuthError
[src]
impl Sync for ConnectAbortOnAuthError
[src]
impl Unpin for ConnectAbortOnAuthError
[src]
impl UnwindSafe for ConnectAbortOnAuthError
[src]
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> DeserializeOwned for T where
T: for<'de> Deserialize<'de>,
[src]
T: for<'de> Deserialize<'de>,
impl<Q, K> Equivalent<K> for Q where
K: Borrow<Q> + ?Sized,
Q: Eq + ?Sized,
[src]
K: Borrow<Q> + ?Sized,
Q: Eq + ?Sized,
pub fn equivalent(&self, key: &K) -> bool
[src]
impl<T> From<T> for T
[src]
impl<T> Instrument for T
[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T> Instrument for T
[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> Pointable for T
pub const ALIGN: usize
type Init = T
The type for initializers.
pub unsafe fn init(init: <T as Pointable>::Init) -> usize
pub unsafe fn deref<'a>(ptr: usize) -> &'a T
pub unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T
pub unsafe fn drop(ptr: usize)
impl<T> SendSyncUnwindSafe for T where
T: Send + Sync + UnwindSafe + ?Sized,
[src]
T: Send + Sync + UnwindSafe + ?Sized,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T
[src]
pub fn clone_into(&self, target: &mut T)
[src]
impl<T> ToString for T where
T: Display + ?Sized,
[src]
T: Display + ?Sized,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,