Module nakadion::client [−] [src]

Use the NakadiClient to consume events from Nakadi

Structs

BatchInfo
ClientError	The Error type.
ConnectorSettings	Settings for establishing a connection to `Nakadi`.
ConnectorSettingsBuilder	Builder for `ConnectorSettings`.
Cursor	A `Cursor` describes a position in the stream. The cursor is used for checkpointing.
HyperClientConnector	A `NakadiConnector` using `Hyper` for dispatching requests.
NakadiClient	The client to consume events from `Nakadi`
NakadiWorker	The worker runs the consumption of events. It will try to reconnect automatically once the stream breaks.
StreamId	A `StreamId` identifies a subscription. It must be provided for checkpointing with a `Cursor`.
SubscriptionId	A `SubscriptionId` is used to guaratee a continous flow of events for a client.

AfterBatchAction	Describes what to do after a batch has been processed.
ClientErrorKind	The kind of an error.

Checkpoints	Checkpoints cursors
ClientResultExt	Additional methods for `Result`, for easy interaction with this crate.
Handler	Handles batches of events received from `Nakadi`.
NakadiConnector	Connects to `Nakadi` for checkpointing and consuming events.
ReadsStream	Connects to `Nakadi` and reads the stream-

Convenient wrapper around std::Result.