[−][src]Module nakadion::publisher
Publish events to Nakadi
Re-exports
pub use crate::api::PublishApi; |
pub use crate::api::PublishError; |
pub use crate::api::PublishFuture; |
Modules
partitioner | Tool for manually assigning partitions |
Structs
BatchStats | |
Bytes | A reference counted contiguous slice of memory. |
DriverBuilder | A Builder for a |
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. |
Instrumentation | Used by the publisher to notify on measurable state changes |
Metrix | Instrumentation with Metrix |
NakadiApiError | An error type to get insights on why an HTTP request failed |
ProcessorMount | A building block for grouping |
PublishAttemptTimeoutMillis | The time a publish attempt for an 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. |
PublishRetryOnAuthError | If true, retries are done on auth errors. |
Publisher | Publishes events with retries |
PublisherConfig | Configuration for a publisher |
TelemetryDriver | Triggers registered |
Enums
Metric | |
PublishTimeoutMillis | The timeout for a complete publishing of events to Nakadi including retries |
SubmissionFailure | The outcome of a submission/publishing attempt to Nakadi. |
SubmissionFailureStrategy | Strategy for handling partial submit failures |
Traits
AggregatesProcessors | Implementors can group everything that can process
|
Instruments | Instruments a |
PublishesEvents | Publish non serialized events. |
PublishesSerializedEvents | Publishes events that have been serialized before |