mgmt, start/stop for aks

sdk/resourcemanager/azure-resourcemanager-containerservice/CHANGELOG.md

@@ -2,6 +2,9 @@
 
 ## 2.7.0-beta.1 (Unreleased)
 
+### Features Added
+
+- Supported `start` and `stop` for `KubernetesCluster`.
 
 ## 2.6.0 (2021-06-18)
 

sdk/resourcemanager/azure-resourcemanager-containerservice/src/main/java/com/azure/resourcemanager/containerservice/implementation/KubernetesClusterImpl.java

@@ -206,6 +206,26 @@ public String systemAssignedManagedServiceIdentityPrincipalId() {
         return objectId;
     }
 
+    @Override
+    public void start() {
+        this.startAsync().block();
+    }
+
+    @Override
+    public Mono<Void> startAsync() {
+        return manager().kubernetesClusters().startAsync(this.resourceGroupName(), this.name());
+    }
+
+    @Override
+    public void stop() {
+        this.stopAsync().block();
+    }
+
+    @Override
+    public Mono<Void> stopAsync() {
+        return manager().kubernetesClusters().stopAsync(this.resourceGroupName(), this.name());
+    }
+
     private Mono<List<CredentialResult>> listAdminConfig(final KubernetesClusterImpl self) {
         return this
             .manager()

sdk/resourcemanager/azure-resourcemanager-containerservice/src/main/java/com/azure/resourcemanager/containerservice/implementation/KubernetesClustersImpl.java

@@ -160,4 +160,26 @@ public Mono<List<CredentialResult>> listUserKubeConfigContentAsync(
             .listClusterUserCredentialsAsync(resourceGroupName, kubernetesClusterName)
             .map(CredentialResultsInner::kubeconfigs);
     }
+
+    @Override
+    public void start(String resourceGroupName, String kubernetesClusterName) {
+        this.startAsync(resourceGroupName, kubernetesClusterName).block();
+    }
+
+    @Override
+    public Mono<Void> startAsync(String resourceGroupName, String kubernetesClusterName) {
+        return this.manager().serviceClient().getManagedClusters()
+            .startAsync(resourceGroupName, kubernetesClusterName);
+    }
+
+    @Override
+    public void stop(String resourceGroupName, String kubernetesClusterName) {
+        this.stopAsync(resourceGroupName, kubernetesClusterName).block();
+    }
+
+    @Override
+    public Mono<Void> stopAsync(String resourceGroupName, String kubernetesClusterName) {
+        return this.manager().serviceClient().getManagedClusters()
+            .stopAsync(resourceGroupName, kubernetesClusterName);
+    }
 }

sdk/resourcemanager/azure-resourcemanager-containerservice/src/main/java/com/azure/resourcemanager/containerservice/models/KubernetesCluster.java

@@ -15,6 +15,7 @@
 import com.azure.resourcemanager.resources.fluentcore.model.Creatable;
 import com.azure.resourcemanager.resources.fluentcore.model.Refreshable;
 import com.azure.resourcemanager.resources.fluentcore.model.Updatable;
+import reactor.core.publisher.Mono;
 
 import java.util.List;
 import java.util.Map;
@@ -88,6 +89,32 @@ public interface KubernetesCluster
      */
     String systemAssignedManagedServiceIdentityPrincipalId();
 
+    // Actions
+
+    /**
+     * Starts a stopped Kubernetes cluster.
+     */
+    void start();
+
+    /**
+     * Starts a stopped Kubernetes cluster.
+     *
+     * @return the completion.
+     */
+    Mono<Void> startAsync();
+
+    /**
+     * Stops a running Kubernetes cluster.
+     */
+    void stop();
+
+    /**
+     * Stops a running Kubernetes cluster.
+     *
+     * @return the completion.
+     */
+    Mono<Void> stopAsync();
+
     // Fluent interfaces
 
     /** Interface for all the definitions related to a Kubernetes cluster. */

sdk/resourcemanager/azure-resourcemanager-containerservice/src/main/java/com/azure/resourcemanager/containerservice/models/KubernetesClusters.java

@@ -85,4 +85,38 @@ Mono<List<CredentialResult>> listAdminKubeConfigContentAsync(
      * @return a future representation of the Kube.config content which can be used with a Kubernetes client
      */
     Mono<List<CredentialResult>> listUserKubeConfigContentAsync(String resourceGroupName, String kubernetesClusterName);
+
+    /**
+     * Starts a stopped Kubernetes cluster.
+     *
+     * @param resourceGroupName The name of the resource group.
+     * @param kubernetesClusterName The name of the managed cluster resource.
+     */
+    void start(String resourceGroupName, String kubernetesClusterName);
+
+    /**
+     * Starts a stopped Kubernetes cluster.
+     *
+     * @param resourceGroupName The name of the resource group.
+     * @param kubernetesClusterName The name of the managed cluster resource.
+     * @return the completion.
+     */
+    Mono<Void> startAsync(String resourceGroupName, String kubernetesClusterName);
+
+    /**
+     * Stops a running Kubernetes cluster.
+     *
+     * @param resourceGroupName The name of the resource group.
+     * @param kubernetesClusterName The name of the managed cluster resource.
+     */
+    void stop(String resourceGroupName, String kubernetesClusterName);
+
+    /**
+     * Stops a running Kubernetes cluster.
+     *
+     * @param resourceGroupName The name of the resource group.
+     * @param kubernetesClusterName The name of the managed cluster resource.
+     * @return the completion.
+     */
+    Mono<Void> stopAsync(String resourceGroupName, String kubernetesClusterName);
 }

sdk/resourcemanager/azure-resourcemanager-containerservice/src/test/java/com/azure/resourcemanager/containerservice/KubernetesClustersTests.java

@@ -102,6 +102,16 @@ public void canCRUDKubernetesCluster() throws Exception {
 
         Assertions.assertNotNull(kubernetesCluster.tags().get("tag1"));
 
+        // stop
+        kubernetesCluster.stop();
+        kubernetesCluster.refresh();
+        Assertions.assertEquals(Code.STOPPED, kubernetesCluster.powerState().code());
+
+        // start
+        kubernetesCluster.start();
+        kubernetesCluster.refresh();
+        Assertions.assertEquals(Code.RUNNING, kubernetesCluster.powerState().code());
+
         // update
         kubernetesCluster =
             kubernetesCluster