Module dataflow::source::kinesis [−][src]
Structs
Contains all information necessary to ingest data from Kinesis
Constants
To read all data from a Kinesis stream, we need to continually update our knowledge of the stream’s shards by calling the ListShards API.
Functions
Creates the necessary data-structures for shard management