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

Tool for manually assigning partitions

BatchStats
Bytes	A reference counted contiguous slice of memory.
DriverBuilder	A Builder for a `TelemetryDriver`
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 `ProcessesTelemetryMessages` to poll for messages.

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

AggregatesProcessors	Implementors can group everything that can process `TelemetryMessage`s.
Instruments	Instruments a `Publisher`
PublishesEvents	Publish non serialized events.
PublishesSerializedEvents	Publishes events that have been serialized before