Function dataflow::source::kinesis::create_state [−][src]
async fn create_state(
base_metrics: &KinesisMetrics,
c: KinesisSourceConnector
) -> Result<(KinesisClient, String, HashMap<String, ShardMetrics>, VecDeque<(String, Option<String>)>), Error>
Expand description
Creates the necessary data-structures for shard management