async fn get_shard_iterators( kinesis_client: &KinesisClient, stream_name: &str) -> Result<VecDeque<Option<String>>, Error>