Module nakadion::components::connector

A connector to directly consume Nakadi Streams

Re-exports

pub use crate::components::IoError;

pub use crate::api::BytesStream;

pub use crate::api::SubscriptionStreamApi;

pub use crate::api::SubscriptionStreamChunks;

Structs

ConnectAbortOnAuthError	If true abort the consumer when an auth error occurs while connecting to a stream.
ConnectAbortOnConflict	If true abort the consumer when a conflict (409) occurs while connecting to a stream.
ConnectAbortOnSubscriptionNotFound	If true abort the consumer when a subscription does not exist when connection to a stream.
ConnectAttemptTimeoutSecs	The timeout for a single request made to Nakadi to connect to a stream.
ConnectConfig	Parameters to configure the Connector
ConnectError	Error returned on failed connect attempts for a stream
ConnectMaxRetryDelaySecs	The maximum retry delay between failed attempts to connect to a stream.
ConnectTimeoutSecs	The maximum time for connecting to a stream.
Connector	A Connector to connect to a Nakadi Stream
Error	An error for cases where further investigation is not necessary.
EventStream	A stream of analyzed Nakadi Frames
EventStreamBatch	An analyzed line (frame) from Nakadi
EventStreamError
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
NakadiFrame	A frame (line) from Nakadi
RandomFlowId	Crates a random FlowId when converted into a FlowId
StreamId	The id of this stream generated by Nakadi.
StreamParameters	Parameters for starting a new stream on a subscription
StreamedBatchMeta	Metadata on the currently received batch
SubscriptionCursor	Cursor of a subscription with a CursorToken which is usually found within a SubscriptionEventStreamBatch.
SubscriptionId	Id of subscription that was created.

Enums

ConnectErrorKind
ConnectTimeout	The timeout for a request made to Nakadi to connect to a stream including retries

Type Definitions

BoxedEventStream
BoxedFrameStream
BoxedParsedEventsStream