Module nakadion::publisher [−][src]
Expand description
Publish events to Nakadi
Re-exports
Modules
Tool for manually assigning partitions
Structs
A cheaply cloneable and sliceable chunk of contiguous memory.
A Builder for a TelemetryDriver
An error for cases where further investigation is not necessary.
Name of an EventType. The name is constrained by a regular expression.
The flow id of the request, which is written into the logs and passed to called services. Helpful for operational troubleshooting and log analysis.
Used by the publisher to notify on measurable state changes
Instrumentation with Metrix
An error type to get insights on why an HTTP request failed
A building block for grouping
The time a publish attempt for an events batch may take.
The initial delay between retry attempts.
The maximum interval between retries.
The multiplier for the delay increase between retries.
If true, retries are done on auth errors.
Publishes events with retries
Configuration for a publisher
Triggers registered ProcessesTelemetryMessages to
poll for messages.
Enums
The timeout for a complete publishing of events to Nakadi including retries
The outcome of a submission/publishing attempt to Nakadi.
Strategy for handling partial submit failures
Traits
Implementors can group everything that can process
TelemetryMessages.
Instruments a Publisher
Publish non serialized events.
Publishes events that have been serialized before