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

BatchLine	An analyzed line (frame) from Nakadi
BatchLineError
ConnectError	Error returned on failed connect attempts for a stream
ConnectStreamTimeoutSecs	The timeout for a request made to Nakadi to connect to a stream.
Connector	A `Connector` to connect to a Nakadi Stream
ConnectorParams	Parameters to configure the `Connector`
Error	An error for cases where further investigation is not necessary
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	Id of a stream
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 a subscription