Struct nakadion::publisher::PublisherConfig

pub struct PublisherConfig {
    pub timeout_millis: Option<PublishTimeoutMillis>,
    pub attempt_timeout_millis: Option<PublishAttemptTimeoutMillis>,
    pub initial_retry_interval_millis: Option<PublishInitialRetryIntervalMillis>,
    pub retry_interval_multiplier: Option<PublishRetryIntervalMultiplier>,
    pub max_retry_interval_millis: Option<PublishMaxRetryIntervalMillis>,
    pub retry_on_auth_error: Option<PublishRetryOnAuthError>,
    pub partial_failure_strategy: Option<SubmissionFailureStrategy>,
}

Configuration for a publisher

Fields

timeout_millis: Option<PublishTimeoutMillis>

Timeout for a complete publishing including potential retries

attempt_timeout_millis: Option<PublishAttemptTimeoutMillis>

Timeout for a single publish request with Nakadi

initial_retry_interval_millis: Option<PublishInitialRetryIntervalMillis>

Interval length before the first retry attempt

retry_interval_multiplier: Option<PublishRetryIntervalMultiplier>

Multiplier for the length of of the next retry interval

max_retry_interval_millis: Option<PublishMaxRetryIntervalMillis>

Maximum length of an interval before a retry

retry_on_auth_error: Option<PublishRetryOnAuthError>

Retry on authentication/authorization errors if true

partial_failure_strategy: Option<SubmissionFailureStrategy>

Strategy for handling partial failures

Implementations

impl PublisherConfig

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 timeout_millis<T: Into<PublishTimeoutMillis>>(self, v: T) -> Self

Timeout for a complete publishing including potential retries

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

Timeout for a single publish request with Nakadi

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

Interval length before the first retry attempt

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

Multiplier for the length of of the next retry interval

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

Maximum length of an interval before a retry

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

Retry on authentication/authorization errors if true

pub fn partial_failure_strategy<T: Into<SubmissionFailureStrategy>>(
    self,
    v: T
) -> Self

Strategy for handling partial failures

Trait Implementations

impl Clone for PublisherConfig

fn clone(&self) -> PublisherConfig

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for PublisherConfig

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

Formats the value using the given formatter.

impl Default for PublisherConfig

fn default() -> PublisherConfig

Returns the "default value" for a type.

impl<'de> Deserialize<'de> for PublisherConfig

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

Deserialize this value from the given Serde deserializer.

impl Serialize for PublisherConfig

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

Serialize this value into the given Serde serializer.