Struct nakadion::components::committer::CommitConfig

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>,
}

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

impl CommitConfig

pub fn from_env() -> Result<Self, Error>

Initializes all fields from environment variables prefixed with "NAKADION_"

pub fn from_env_prefixed<T: AsRef<str>>(prefix: T) -> Result<Self, Error>

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>

Initializes all fields from environment variables without any prefix

pub fn fill_from_env(&mut self) -> Result<(), Error>

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>

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>

Updates all not yet set fields from environment variables without any prefix

pub fn apply_defaults(&mut self)

pub fn timeout_millis<T: Into<CommitTimeoutMillis>>(self, v: T) -> Self

pub fn attempt_timeout_millis<T: Into<CommitAttemptTimeoutMillis>>(
    self,
    v: T
) -> Self

pub fn initial_retry_interval_millis<T: Into<CommitInitialRetryIntervalMillis>>(
    self,
    v: T
) -> Self

pub fn retry_interval_multiplier<T: Into<CommitRetryIntervalMultiplier>>(
    self,
    v: T
) -> Self

pub fn max_retry_interval_millis<T: Into<CommitMaxRetryIntervalMillis>>(
    self,
    v: T
) -> Self

pub fn retry_on_auth_error<T: Into<CommitRetryOnAuthError>>(self, v: T) -> Self

pub fn commit_strategy<T: Into<CommitStrategy>>(self, v: T) -> Self

pub fn stream_commit_timeout_secs<T: Into<StreamCommitTimeoutSecs>>(
    self,
    v: T
) -> Self

Trait Implementations

impl Clone for CommitConfig

fn clone(&self) -> CommitConfig

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for CommitConfig

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

Formats the value using the given formatter.

impl Default for CommitConfig

fn default() -> CommitConfig

Returns the "default value" for a type.

impl<'de> Deserialize<'de> for CommitConfig

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

Deserialize this value from the given Serde deserializer.

impl Serialize for CommitConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.