[][src]Module nakadion::components

Components to directly interact with Nakadi

This are used by the Consumer internally so metrics and instrumentation within this module are tailored for the Consumer but can be used apart from it.

Modules

committer

Component to commit cursors

connector

A connector to directly consume Nakadi Streams

streams

Transformed Streams of a binary Nakadi Stream

Structs

IoError

Traits

StreamingEssentials