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 ConcurrentWorkerSettings.

NakadiWorker

The NakadiWorker runs the consumption of events.

SequentialWorkerSettings

Enums

WorkerSettings

Settings for the worker.

Traits

Worker

Common fuctionality a worker must provide.