Function dataflow::source::kinesis::create_state

async fn create_state(
    base_metrics: &KinesisMetrics, 
    c: KinesisSourceConnector
) -> Result<(KinesisClient, String, HashMap<String, ShardMetrics>, VecDeque<(String, Option<String>)>), Error>

Creates the necessary data-structures for shard management