Crate nakadion [−] [src]

WARNING! This is the fist iteration of a rewrite. API might change and features will be added. Documentation not yet updated!

Modules

api_client
auth
consumer
events
metrics	Metrics collected by `Nakadion`
publisher	Publish events to Nakadi
streaming_client

EventType	The `Nakadi Event Type`. Similiar to a topic.
FlowId	A `StreamId` identifies a subscription. It must be provided for checkpointing with a `Cursor`.
Nakadion
NakadionBuilder
NakadionConfig	Settings for establishing a connection to `Nakadi`.
PartitionId	A partition id that comes with a `Cursor`
StreamId	A `StreamId` identifies a subscription. It must be provided for checkpointing with a `Cursor`.
SubscriptionId	A `SubscriptionId` is used to guarantee a continous flow of events for a client.

CommitStrategy	Stragtegy for committing cursors
ProcessingStatus
SubscriptionDiscovery
TypedProcessingStatus