[][src]Module nakadion::publisher

Publish events to Nakadi

Re-exports

pub use crate::api::PublishApi;
pub use crate::api::PublishFailure;
pub use crate::api::PublishFuture;

Structs

BatchResponse

An aggregation of status items corresponding to each individual Event’s publishing attempt.

Bytes

A reference counted contiguous slice of memory.

Error

An error for cases where further investigation is not necessary

EventTypeName

Name of an EventType. The name is constrained by a regular expression.

FlowId

The flow id of the request, which is written into the logs and passed to called services. Helpful for operational troubleshooting and log analysis.

NakadiApiError

An error type to get insights on why an HTTP request failed

PublishAttemptTimeoutMillis

The time a publish attempt for the events batch may take.

PublishInitialRetryIntervalMillis

The initial delay between retry attempts.

PublishMaxRetryIntervalMillis

The maximum interval between retries.

PublishRetryIntervalMultiplier

The multiplier for the delay increase between retries.

PublishRetryOnAuthErrors

If true, retries are done on auth errors.

PublishTimeoutMillis

The a publishing the events batch including retries may take.

Publisher

Publishes events with retries

PublisherConfig

Configuration for a publisher

Enums

PartialFailureStrategy

Strategy for handling partial submit failures

Traits

PublishesEvents

Publish non serialized events.

PublishesSerializedEvents

Publishes events that have been serialized before