Struct nakadion::publisher::PublisherConfig [−][src]
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>,
}
Expand description
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
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
Timeout for a complete publishing including potential retries
Timeout for a single publish request with Nakadi
pub fn initial_retry_interval_millis<T: Into<PublishInitialRetryIntervalMillis>>(
self,
v: T
) -> Self
pub fn initial_retry_interval_millis<T: Into<PublishInitialRetryIntervalMillis>>(
self,
v: T
) -> Self
Interval length before the first retry attempt
Multiplier for the length of of the next retry interval
Maximum length of an interval before a retry
Retry on authentication/authorization errors if true
Strategy for handling partial failures
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 PublisherConfig
impl Send for PublisherConfig
impl Sync for PublisherConfig
impl Unpin for PublisherConfig
impl UnwindSafe for PublisherConfig
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