[−][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(self, url: NakadiBaseUrl) -> Self
[src]
pub fn timeout_millis<T: Into<ApiClientTimeoutMillis>>(self, v: T) -> Self
[src]
Timeout for a complete request including potential retries
pub fn attempt_timeout_millis<T: Into<ApiClientAttemptTimeoutMillis>>(
self,
v: T
) -> Self
[src]
self,
v: T
) -> Self
Timeout for a single attempt to get a response from Nakadi
pub fn initial_retry_interval_millis<T: Into<ApiClientInitialRetryIntervalMillis>>(
self,
v: T
) -> Self
[src]
self,
v: T
) -> Self
Interval length before the first retry attempt
pub fn retry_interval_multiplier<T: Into<ApiClientRetryIntervalMultiplier>>(
self,
v: T
) -> Self
[src]
self,
v: T
) -> Self
Multiplier for the length of of the next retry interval
pub fn max_retry_interval_millis<T: Into<ApiClientMaxRetryIntervalMillis>>(
self,
v: T
) -> Self
[src]
self,
v: T
) -> Self
Maximum length of an interval before a retry
pub fn retry_on_auth_errors<T: Into<ApiClientRetryOnAuthErrors>>(
self,
v: T
) -> Self
[src]
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>(
self,
prefix: T,
dispatch_http_request: D
) -> Result<ApiClient, Error> where
T: AsRef<str>,
D: DispatchHttpRequest + Send + Sync + 'static,
[src]
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
impl Send for Builder
impl Sync for Builder
impl Unpin for Builder
impl UnwindSafe for Builder
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> 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>,