get kubernetes to accept my post/patch/delete requests - fixes ynqa#16

Author: clux

Cargo.toml

@@ -17,7 +17,7 @@ edition = "2018"
 base64 = "0.9.3"
 dirs = "1.0.4"
 failure = "0.1.2"
-reqwest = "0.9.2"
+reqwest = "0.9.17"
 serde = "1.0.90"
 serde_derive = "1.0.90"
 serde_json = "1.0.39"

examples/crd_api.rs

@@ -4,7 +4,7 @@
 use serde_json::json;
 
 use kube::{
-    api::{Api, PostResponse, PostParams, Object},
+    api::{Api, PostResponse, PostParams, DeleteParams, Object, PropagationPolicy, Void},
     client::APIClient,
     config,
 };
@@ -23,11 +23,16 @@ pub struct FooSpec {
     info: String,
 }
 
-#[derive(Deserialize, Serialize, Clone, Debug)]
+#[derive(Deserialize, Serialize, Clone, Debug, Default)]
 pub struct FooStatus {
     is_bad: bool,
 }
 
+// shorthands
+type Foo = Object<FooSpec, FooStatus>;
+type FooMeta = Object<Void, Void>;
+type FullCrd = Object<CrdSpec, CrdStatus>;
+
 fn main() -> Result<(), failure::Error> {
     std::env::set_var("RUST_LOG", "info,kube=trace");
     env_logger::init();
@@ -37,6 +42,20 @@ fn main() -> Result<(), failure::Error> {
     // Manage the CRD
     let crds = Api::v1beta1CustomResourceDefinition();
 
+    // Delete any old versions of it first:
+    let dp = DeleteParams {
+        propagation_policy: Some(PropagationPolicy::Foreground),
+        ..Default::default()
+    };
+    //let req = crds.delete("foos.clux.dev", &dp)?;
+    //if let Ok(res) = client.request::<FullCrd>(req) {
+    //    info!("Deleted {}: ({:?})", res.metadata.name, res.status.conditions.unwrap().last());
+    //    use std::{thread, time};
+    //    let five_secs = time::Duration::from_millis(5000);
+    //    thread::sleep(five_secs);
+    //    // even foreground policy doesn't seem to block here..
+    //}
+
     // Create the CRD so we can create Foos in kube
     let foocrd = json!({
         "metadata": {
@@ -50,49 +69,68 @@ fn main() -> Result<(), failure::Error> {
                 "plural": "foos",
                 "singular": "foo",
                 "kind": "Foo",
-            }
-        }
+            },
+            "subresources": {
+                "status": {}
+            },
+        },
     });
 
+    info!("Creating CRD foos.clux.dev");
     let pp = PostParams::default();
     let req = crds.create(&pp, serde_json::to_vec(&foocrd)?)?;
-    if let Ok(res) = client.request::<Object<CrdSpec, CrdStatus>>(req) {
+    if let Ok(res) = client.request::<FullCrd>(req) {
         info!("Created {}", res.metadata.name);
         debug!("Created CRD: {:?}", res.spec);
     } else {
-        // TODO: need error code here for ease
+        // TODO: need error code here for ease - 409 common
     }
 
-
     // Manage the Foo CR
-    let foos = Api::customResource("foos.clux.dev").version("v1");
+    let foos = Api::customResource("foos")
+        .version("v1")
+        .group("clux.dev")
+        .within("dev");
 
-    // Create some Foos
+    // Create Foo baz
+    info!("Creating Foo instance baz");
     let f1 = json!({
-        "metadata": { "name": "baz" },
-        "spec": FooSpec { name: "baz".into(), info: "unpatched baz".into() }
+        "apiVersion": "clux.dev/v1",
+        "kind": "Foo",
+        "metadata": { "name": "baz", "info": "old" },
     });
-    foos.create(&pp, serde_json::to_vec(&f1)?)?;
+    let req = foos.create(&pp, serde_json::to_vec(&f1)?)?;
+    let o = client.request::<FooMeta>(req)?;
+    info!("Created {}", o.metadata.name);
+
+    // Modify a Foo baz with a Patch
+    info!("Patch Foo instance baz");
+    let patch = json!({
+        "spec": { "info": "patched baz" }
+    });
+    let req = foos.patch("baz", &pp, serde_json::to_vec(&patch)?)?;
+    let o = client.request::<Foo>(req)?;
+    info!("Patched {} with new name: {}", o.metadata.name, o.spec.name);
 
+    info!("Create Foo instance qux");
     let f2 = json!({
+        "apiVersion": "clux.dev/v1",
+        "kind": "Foo",
         "metadata": { "name": "qux" },
-        "spec": FooSpec { name: "qux".into(), info: "unpatched qux".into() }
+        "spec": FooSpec { name: "qux".into(), info: "unpatched qux".into() },
+        "status": FooStatus::default(),
     });
-    foos.create(&pp, serde_json::to_vec(&f2)?)?;
-
+    let req = foos.create(&pp, serde_json::to_vec(&f2)?)?;
+    let o = client.request::<FooMeta>(req)?;
+    info!("Created {}", o.metadata.name);
 
-    // Modify a Foo with a Patch
-    //let patch = json!( info => "patched baz" );
-    //let req = foos.patch("baz", &pp, serde_json::to_vec(&patch)?)?;
-    //client.request::<PostResponse<Object<FooSpec, FooStatus>>>(req)?;
 
-    // shorthand
-    type Foo = Object<FooSpec, FooStatus>;
-    // TODO: request should return statuscode as a better useability!
-
-    // Set its status:
-    let fs = FooStatus { is_bad: true };
-    let req = foos.replace_status("baz", &pp, serde_json::to_vec(&fs)?)?;
+    // Update status on -qux
+    info!("Replace Status on Foo instance qux");
+    let fs = json!({
+        "status": FooStatus { is_bad: true }
+    });
+    let req = foos.replace_status("qux", &pp, serde_json::to_vec(&fs)?)?;
     let res = client.request::<Foo>(req)?;
     info!("Replaced status {:?} for {}", res.status, res.metadata.name);