[−][src]Struct nakadion::api::Builder
Fields (Non-exhaustive)
Struct { .. }
syntax; cannot be matched against without a wildcard ..
; and struct update syntax will not work.nakadi_base_url: Option<NakadiBaseUrl>
timeout_millis: Option<ApiClientTimeoutMillis>
Timeout for a complete publishing including potential retries
attempt_timeout_millis: Option<ApiClientAttemptTimeoutMillis>
Timeout for a single request attempt to Nakadi
initial_retry_interval_millis: Option<ApiClientInitialRetryIntervalMillis>
Interval length before the first retry attempt
retry_interval_multiplier: Option<ApiClientRetryIntervalMultiplier>
Multiplier for the length of of the next retry interval
max_retry_interval_millis: Option<ApiClientMaxRetryIntervalMillis>
Maximum length of an interval before a retry
retry_on_auth_errors: Option<ApiClientRetryOnAuthErrors>
Retry on authentication/authorization errors if true
Implementations
impl Builder
[src]
pub fn from_env() -> Result<Self, Error>
[src]
Initializes all fields from environment variables prefixed with "NAKADION_"
pub fn from_env_prefixed<T: AsRef<str>>(prefix: T) -> Result<Self, Error>
[src]
Initializes all fields from environment variables prefixed with "[prefix]_"
The underscore is omitted if prefix
is empty
pub fn from_env_type_names() -> Result<Self, Error>
[src]
Initializes all fields from environment variables without any prefix
pub fn fill_from_env(&mut self) -> Result<(), Error>
[src]
Updates all not yet set fields from environment variables prefixed with "NAKADION_"
pub fn fill_from_env_prefixed<T: AsRef<str>>(
&mut self,
prefix: T
) -> Result<(), Error>
[src]
&mut self,
prefix: T
) -> Result<(), Error>
Updates all not yet set fields from environment variables prefixed with "[prefix]_"
The underscore is omitted if prefix
is empty
pub fn fill_from_env_type_names(&mut self) -> Result<(), Error>
[src]
Updates all not yet set fields from environment variables without any prefix
pub fn nakadi_base_url(mut self: Self, url: NakadiBaseUrl) -> Self
[src]
pub fn timeout_millis<T: Into<ApiClientTimeoutMillis>>(
mut self: Self,
v: T
) -> Self
[src]
mut self: Self,
v: T
) -> Self
Timeout for a complete request including potential retries
pub fn attempt_timeout_millis<T: Into<ApiClientAttemptTimeoutMillis>>(
mut self: Self,
v: T
) -> Self
[src]
mut self: Self,
v: T
) -> Self
Timeout for a single attempt to get a response from Nakadi
pub fn initial_retry_interval_millis<T: Into<ApiClientInitialRetryIntervalMillis>>(
mut self: Self,
v: T
) -> Self
[src]
mut self: Self,
v: T
) -> Self
Interval length before the first retry attempt
pub fn retry_interval_multiplier<T: Into<ApiClientRetryIntervalMultiplier>>(
mut self: Self,
v: T
) -> Self
[src]
mut self: Self,
v: T
) -> Self
Multiplier for the length of of the next retry interval
pub fn max_retry_interval_millis<T: Into<ApiClientMaxRetryIntervalMillis>>(
mut self: Self,
v: T
) -> Self
[src]
mut self: Self,
v: T
) -> Self
Maximum length of an interval before a retry
pub fn retry_on_auth_errors<T: Into<ApiClientRetryOnAuthErrors>>(
mut self: Self,
v: T
) -> Self
[src]
mut self: Self,
v: T
) -> Self
Retry on authentication/authorization errors if true
impl Builder
[src]
pub fn build_with<D, P>(
self,
dispatch_http_request: D,
access_token_provider: P
) -> Result<ApiClient, Error> where
D: DispatchHttpRequest + Send + Sync + 'static,
P: ProvidesAccessToken + Send + Sync + 'static,
[src]
self,
dispatch_http_request: D,
access_token_provider: P
) -> Result<ApiClient, Error> where
D: DispatchHttpRequest + Send + Sync + 'static,
P: ProvidesAccessToken + Send + Sync + 'static,
Build an ApiClient
from this Builder
No environment variables are read
pub fn build_from_env_with_dispatcher<D>(
self,
dispatch_http_request: D
) -> Result<ApiClient, Error> where
D: DispatchHttpRequest + Send + Sync + 'static,
[src]
self,
dispatch_http_request: D
) -> Result<ApiClient, Error> where
D: DispatchHttpRequest + Send + Sync + 'static,
Build an ApiClient
from this Builder
Unset fields of this Builder
will be set from the environment
including the settings for the ProvidesAccessToken
Environment variables must be prefixed with NAKADION
pub fn build_from_env_prefixed_with_dispatcher<T, D>(
mut self: Self,
prefix: T,
dispatch_http_request: D
) -> Result<ApiClient, Error> where
T: AsRef<str>,
D: DispatchHttpRequest + Send + Sync + 'static,
[src]
mut self: Self,
prefix: T,
dispatch_http_request: D
) -> Result<ApiClient, Error> where
T: AsRef<str>,
D: DispatchHttpRequest + Send + Sync + 'static,
Build an ApiClient
from this Builder
Unset fields of this Builder
will be set from the environment
including the settings for the ProvidesAccessToken
impl Builder
[src]
pub fn finish<P>(self, access_token_provider: P) -> Result<ApiClient, Error> where
P: ProvidesAccessToken + Send + Sync + 'static,
[src]
P: ProvidesAccessToken + Send + Sync + 'static,
pub fn finish_from_env(self) -> Result<ApiClient, Error>
[src]
pub fn finish_from_env_prefixed<T>(self, prefix: T) -> Result<ApiClient, Error> where
T: AsRef<str>,
[src]
T: AsRef<str>,
Trait Implementations
impl Debug for Builder
[src]
impl Default for Builder
[src]
impl<'de> Deserialize<'de> for Builder
[src]
pub fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
[src]
__D: Deserializer<'de>,
impl Serialize for Builder
[src]
Auto Trait Implementations
impl RefUnwindSafe for Builder
[src]
impl Send for Builder
[src]
impl Sync for Builder
[src]
impl Unpin for Builder
[src]
impl UnwindSafe for Builder
[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<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, 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>,