Return created objects when applying kube manifest

Signed-off-by: Robert Detjens <[email protected]>

Author: detjensrobert

src/clients.rs

@@ -174,12 +174,17 @@ pub async fn kube_api_for(
     }
 }
 
-/// Apply multi-document manifest file
-pub async fn apply_manifest_yaml(client: &kube::Client, manifest: &str) -> Result<()> {
+/// Apply multi-document manifest file, return created resources
+pub async fn apply_manifest_yaml(
+    client: &kube::Client,
+    manifest: &str,
+) -> Result<Vec<DynamicObject>> {
     // set ourself as the owner for managed fields
     // https://kubernetes.io/docs/reference/using-api/server-side-apply/#managers
     let pp = PatchParams::apply("beavercds").force();
 
+    let mut results = vec![];
+
     // this manifest has multiple documents (crds, deployment)
     for yaml in multidoc_deserialize(manifest)? {
         let obj: DynamicObject = serde_yml::from_value(yaml)?;
@@ -195,7 +200,10 @@ pub async fn apply_manifest_yaml(client: &kube::Client, manifest: &str) -> Resul
             .patch(&obj.name_any(), &pp, &Patch::Apply(&obj))
             .await
         {
-            Ok(d) => Ok(()),
+            Ok(d) => {
+                results.push(d);
+                Ok(())
+            }
             // if error is from cluster api, mark it as such
             Err(kube::Error::Api(ae)) => {
                 // Err(kube::Error::Api(ae).into())
@@ -206,7 +214,7 @@ pub async fn apply_manifest_yaml(client: &kube::Client, manifest: &str) -> Resul
         }?;
     }
 
-    Ok(())
+    Ok(results)
 }
 
 /// Deserialize multi-document yaml string into a Vec of the documents

src/cluster_setup/mod.rs

@@ -68,7 +68,9 @@ pub async fn install_certmanager(profile: &config::ProfileConfig) -> Result<()>
     // letsencrypt and letsencrypt-staging
     const ISSUERS_YAML: &str =
         include_str!("../asset_files/setup_manifests/letsencrypt.issuers.yaml");
-    apply_manifest_yaml(&client, ISSUERS_YAML).await
+    apply_manifest_yaml(&client, ISSUERS_YAML).await?;
+
+    Ok(())
 }
 
 pub async fn install_extdns(profile: &config::ProfileConfig) -> Result<()> {