crd.rs

        let errors: Vec<kube::Error> = futures::stream::iter(crate::resources::all())
            .map(|resource| async move { client.create(&PostParams::default(), &resource).await })
            .buffered(100)
            .inspect(|result| {
                if let Ok(o) = result {
                    info!(name = o.name_any(), "created CRD");
                }
            })
            .collect::<Vec<Result<CustomResourceDefinition, _>>>()
            .await
            .into_iter()
            .filter(Result::is_err)
            .map(Result::unwrap_err)
            .collect();

        if !errors.is_empty() {
            return Err(errors
                .into_iter()
                .fold(eyre!("unable to create resources"), |acc, err| {
                    acc.error(err)
                }));
        }