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 | |
publisher | |
streaming_client |
Structs
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 |