feat : support kubectl rollout history for statefulset

Author: NeverRaR

extended/src/main/java/io/kubernetes/client/extended/kubectl/KubectlRolloutHistory.java

@@ -26,6 +26,7 @@
 import io.kubernetes.client.openapi.models.V1OwnerReference;
 import io.kubernetes.client.openapi.models.V1PodTemplateSpec;
 import io.kubernetes.client.openapi.models.V1ReplicaSet;
+import io.kubernetes.client.openapi.models.V1StatefulSet;
 import io.kubernetes.client.util.labels.LabelSelector;
 import java.util.ArrayList;
 import java.util.HashMap;
@@ -94,6 +95,11 @@ public ApiType execute() throws KubectlException {
         V1DaemonSet daemonSet = api.readNamespacedDaemonSet(name, namespace, null, null, null);
         daemonSetViewHistory(daemonSet, api);
         return (ApiType) daemonSet;
+      } else if (apiTypeClass.equals(V1StatefulSet.class)) {
+        V1StatefulSet statefulSet =
+            api.readNamespacedStatefulSet(name, namespace, null, null, null);
+        statefulSetViewHistory(statefulSet, api);
+        return (ApiType) statefulSet;
       } else {
         throw new KubectlException("Unsupported class for rollout history: " + apiTypeClass);
       }
@@ -122,7 +128,7 @@ private void validate() throws KubectlException {
       msg.append("Missing namespace, ");
     }
     if (revision < 0) {
-      msg.append("revision must be a positive integer: ").append(revision);
+      msg.append("Revision must be a positive integer: ").append(revision);
     }
     if (msg.length() > 0) {
       throw new KubectlException(msg.toString());
@@ -181,6 +187,25 @@ private void daemonSetViewHistory(V1DaemonSet daemonSet, AppsV1Api api) throws A
         });
   }
 
+  private void statefulSetViewHistory(V1StatefulSet statefulSet, AppsV1Api api)
+      throws ApiException {
+    LabelSelector selector = LabelSelector.parse(statefulSet.getSpec().getSelector());
+    List<V1ControllerRevision> historyList = controlledHistory(api, statefulSet, selector);
+    parseHistory(
+        historyList,
+        history -> {
+          V1StatefulSet stsOfHistory = applyStatefulSetHistory(statefulSet, history);
+          return stsOfHistory.getSpec().getTemplate();
+        });
+  }
+
+  private V1StatefulSet applyStatefulSetHistory(V1StatefulSet sts, V1ControllerRevision history) {
+    String stsJson = new JSON().serialize(sts);
+    String patch = new JSON().serialize(history.getData());
+    String patched = applyDirectivePatch(stsJson, patch);
+    return new JSON().deserialize(patched, V1StatefulSet.class);
+  }
+
   private V1DaemonSet applyDaemonSetHistory(V1DaemonSet ds, V1ControllerRevision history) {
     String dsJson = new JSON().serialize(ds);
     String patch = new JSON().serialize(history.getData());