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 |
publisher |
Publish events to Nakadi |
streaming_client |
Structs
CreateHandlerError | |
EventType |
The |
FlowId |
A |
Nakadion | |
NakadionBuilder | |
NakadionConfig |
Settings for establishing a connection to |
PartitionId |
A partition id that comes with a |
StreamId |
A |
SubscriptionId |
A |
Enums
CommitStrategy |
Stragtegy for committing cursors |
ProcessingStatus | |
SubscriptionDiscovery | |
TypedProcessingStatus |
Traits
BatchHandler | |
HandlerFactory | |
TypedBatchHandler |