[−][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 |