kube-core: Add Restart marker and request.

Signed-off-by: Adrian Pistol <vifino@tty.sh>

kube-core/Cargo.toml

@@ -25,6 +25,7 @@ form_urlencoded = "1.0.1"
 http = "0.2.2"
 json-patch = { version = "0.2.6", optional = true }
 once_cell = "1.8.0"
+chrono = "0.4.19"
 
 [dependencies.k8s-openapi]
 version = "0.13.0"

kube-core/src/lib.rs

@@ -41,6 +41,8 @@ pub mod response;
 
 pub mod subresource;
 
+pub mod util;
+
 pub mod watch;
 pub use watch::WatchEvent;
 

kube-core/src/util.rs

@@ -0,0 +1,36 @@
+//! Utils and helpers
+
+use crate::{
+    params::{Patch, PatchParams},
+    Request, Result,
+};
+use chrono::Utc;
+use k8s_openapi::api::apps::v1::{DaemonSet, Deployment, ReplicaSet, StatefulSet};
+
+/// Restartable Resource marker trait
+pub trait Restart {}
+
+impl Restart for Deployment {}
+impl Restart for DaemonSet {}
+impl Restart for StatefulSet {}
+impl Restart for ReplicaSet {}
+
+impl Request {
+    /// Restart a resource
+    pub fn restart(&self, name: &str) -> Result<http::Request<Vec<u8>>> {
+        let patch = serde_json::json!({
+          "spec": {
+            "template": {
+              "metadata": {
+                "annotations": {
+                  "kube.kubernetes.io/restartedAt": Utc::now().to_rfc3339()
+                }
+              }
+            }
+          }
+        });
+
+        let pparams = PatchParams::default();
+        self.patch(name, &pparams, &Patch::Merge(patch))
+    }
+}