Struct nakadion::consumer::CommitConfig [−][src]
pub struct CommitConfig {
pub timeout_millis: Option<CommitTimeoutMillis>,
pub attempt_timeout_millis: Option<CommitAttemptTimeoutMillis>,
pub initial_retry_interval_millis: Option<CommitInitialRetryIntervalMillis>,
pub retry_interval_multiplier: Option<CommitRetryIntervalMultiplier>,
pub max_retry_interval_millis: Option<CommitMaxRetryIntervalMillis>,
pub retry_on_auth_error: Option<CommitRetryOnAuthError>,
pub commit_strategy: Option<CommitStrategy>,
pub stream_commit_timeout_secs: Option<StreamCommitTimeoutSecs>,
}
Expand description
Configuration for a Committer
Fields
timeout_millis: Option<CommitTimeoutMillis>
Timeout for a complete commit including potential retries
attempt_timeout_millis: Option<CommitAttemptTimeoutMillis>
Timeout for a single commit request with Nakadi
initial_retry_interval_millis: Option<CommitInitialRetryIntervalMillis>
Interval length before the first retry attempt
retry_interval_multiplier: Option<CommitRetryIntervalMultiplier>
Multiplier for the length of of the next retry interval
max_retry_interval_millis: Option<CommitMaxRetryIntervalMillis>
Maximum length of an interval before a retry
retry_on_auth_error: Option<CommitRetryOnAuthError>
Retry on authentication/authorization errors if true
commit_strategy: Option<CommitStrategy>
stream_commit_timeout_secs: Option<StreamCommitTimeoutSecs>
Maximum amount of seconds that Nakadi will be waiting for commit after sending a batch to a client.
Implementations
Initializes all fields from environment variables prefixed with “NAKADION_”
Initializes all fields from environment variables prefixed with “[prefix]_”
The underscore is omitted if prefix
is empty
Initializes all fields from environment variables without any prefix
Updates all not yet set fields from environment variables prefixed with “NAKADION_”
Updates all not yet set fields from environment variables prefixed with “[prefix]_”
The underscore is omitted if prefix
is empty
Updates all not yet set fields from environment variables without any prefix
pub fn initial_retry_interval_millis<T: Into<CommitInitialRetryIntervalMillis>>(
self,
v: T
) -> Self
Trait Implementations
Returns the “default value” for a type. Read more
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Auto Trait Implementations
impl RefUnwindSafe for CommitConfig
impl Send for CommitConfig
impl Sync for CommitConfig
impl Unpin for CommitConfig
impl UnwindSafe for CommitConfig
Blanket Implementations
Mutably borrows from an owned value. Read more
pub fn vzip(self) -> V
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more