Module mz_storage::source::kinesis

source ·

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.

Statics

CALLSITE 🔒
CALLSITE 🔒
CALLSITE 🔒
CALLSITE 🔒
META 🔒
META 🔒
META 🔒
META 🔒

Functions

Creates the necessary data-structures for shard management

Opaque Types

 🔒
 🔒
 🔒