Module nakadion::client
[−]
[src]
The Client.
Use the NakadiClient
to consume events from Nakadi
The NakadiClient
the
Nakadi Subscription API
.
Structs
ClientError |
The Error type. |
ConnectorSettings |
Settings for establishing a connection to |
ConnectorSettingsBuilder |
Builder for |
Cursor |
A |
HyperClientConnector |
A |
NakadiClient |
The client to consume events from |
NakadiWorker |
The worker runs the consumption of events. It will try to reconnect automatically once the stream breaks. |
StreamId |
A |
SubscriptionId |
A |
Enums
AfterBatchAction |
Describes what to do after a batch has been processed. |
ClientErrorKind |
The kind of an error. |
Traits
Checkpoints |
Checkpoints cursors |
ClientResultExt |
Additional methods for |
Handler |
Handles batches of events received from |
NakadiConnector |
Connects to |
ReadsStream |
Connects to |
Type Definitions
ClientResult |
Convenient wrapper around |