Module nakadion::worker
[−]
[src]
The components to consume from the stream.
This is basically the machinery that drives the consumption.
It will consume events and call the Handler
and react on its commands on how to continue.
Structs
ConcurrentWorkerSettings |
The settings for a concurrent worker. |
ConcurrentWorkerSettingsBuilder |
Builder for |
NakadiWorker |
The |
SequentialWorkerSettings |
Enums
WorkerSettings |
Settings for the worker. |
Traits
Worker |
Common fuctionality a worker must provide. |