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