CodeGen from PR 13166 in Azure/azure-rest-api-specs

Merge b353336f78b47a9a9d83765d68a6b9b87ea76f95 into 89f00c23e9b247304c490504f182aebd0dff4f4e

Author: SDKAuto

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

@@ -1,7 +1,8 @@
 # Release History
 
-## 1.0.0-beta.2 (Unreleased)
+## 1.0.0-beta.1 (2021-02-26)
 
+- Azure Resource Manager Kusto client library for Java. This package contains Microsoft Azure SDK for Kusto Management SDK. The Azure Kusto management API provides a RESTful set of web services that interact with Azure Kusto services to manage your clusters and databases. The API enables you to create, update, and delete clusters and databases. Package tag package-2020-09-18. For documentation on how to use this package, please see [Azure Management Libraries for Java](https://aka.ms/azsdk/java/mgmt).
 
 ## 1.0.0-beta.1 (2020-12-18)
 

sdk/kusto/azure-resourcemanager-kusto/README.md

@@ -4,6 +4,20 @@ Azure Resource Manager Kusto client library for Java.
 
 This package contains Microsoft Azure SDK for Kusto Management SDK. The Azure Kusto management API provides a RESTful set of web services that interact with Azure Kusto services to manage your clusters and databases. The API enables you to create, update, and delete clusters and databases. Package tag package-2020-09-18. For documentation on how to use this package, please see [Azure Management Libraries for Java](https://aka.ms/azsdk/java/mgmt).
 
+## We'd love to hear your feedback
+
+We're always working on improving our products and the way we communicate with our users. So we'd love to learn what's working and how we can do better.
+
+If you haven't already, please take a few minutes to [complete this short survey][survey] we have put together.
+
+Thank you in advance for your collaboration. We really appreciate your time!
+
+## Documentation
+
+Various documentation is available to help you get started
+
+- [API reference documentation][docs]
+
 ## Getting started
 
 ### Prerequisites
@@ -18,7 +32,7 @@ This package contains Microsoft Azure SDK for Kusto Management SDK. The Azure Ku
 <dependency>
     <groupId>com.azure.resourcemanager</groupId>
     <artifactId>azure-resourcemanager-kusto</artifactId>
-    <version>1.0.0-beta.1</version>
+    <version>1.0.0-beta.2</version>
 </dependency>
 ```
 [//]: # ({x-version-update-end})
@@ -75,6 +89,8 @@ For details on contributing to this repository, see the [contributing guide](htt
 1. Create new Pull Request
 
 <!-- LINKS -->
+[survey]: https://microsoft.qualtrics.com/jfe/form/SV_ehN0lIk2FKEBkwd?Q_CHL=DOCS
+[docs]: https://azure.github.io/azure-sdk-for-java/
 [jdk]: https://docs.microsoft.com/java/azure/jdk/
 [azure_subscription]: https://azure.microsoft.com/free/
 [azure_identity]: https://github.com/Azure/azure-sdk-for-java/blob/master/sdk/identity/azure-identity

sdk/kusto/azure-resourcemanager-kusto/pom.xml

@@ -41,6 +41,11 @@
         <legal><![CDATA[[INFO] Any downloads listed may be third party software.  Microsoft grants you no rights for third party software.]]></legal>
     </properties>
     <dependencies>
+        <dependency>
+            <groupId>com.azure</groupId>
+            <artifactId>azure-core</artifactId>
+            <version>1.13.0</version> <!-- {x-version-update;com.azure:azure-core;dependency} -->
+        </dependency>
         <dependency>
             <groupId>com.azure</groupId>
             <artifactId>azure-core-management</artifactId>

sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/KustoManager.java

@@ -180,17 +180,31 @@ public KustoManager authenticate(TokenCredential credential, AzureProfile profil
             Objects.requireNonNull(credential, "'credential' cannot be null.");
             Objects.requireNonNull(profile, "'profile' cannot be null.");
 
+            StringBuilder userAgentBuilder = new StringBuilder();
+            userAgentBuilder
+                .append("azsdk-java")
+                .append("-")
+                .append("com.azure.resourcemanager.kusto")
+                .append("/")
+                .append("1.0.0-beta.1");
+            if (!Configuration.getGlobalConfiguration().get("AZURE_TELEMETRY_DISABLED", false)) {
+                userAgentBuilder
+                    .append(" (")
+                    .append(Configuration.getGlobalConfiguration().get("java.version"))
+                    .append("; ")
+                    .append(Configuration.getGlobalConfiguration().get("os.name"))
+                    .append("; ")
+                    .append(Configuration.getGlobalConfiguration().get("os.version"))
+                    .append("; auto-generated)");
+            } else {
+                userAgentBuilder.append(" (auto-generated)");
+            }
+
             if (retryPolicy == null) {
                 retryPolicy = new RetryPolicy("Retry-After", ChronoUnit.SECONDS);
             }
             List<HttpPipelinePolicy> policies = new ArrayList<>();
-            policies
-                .add(
-                    new UserAgentPolicy(
-                        null,
-                        "com.azure.resourcemanager.kusto",
-                        "1.0.0-beta.1",
-                        Configuration.getGlobalConfiguration()));
+            policies.add(new UserAgentPolicy(userAgentBuilder.toString()));
             policies.add(new RequestIdPolicy());
             HttpPolicyProviders.addBeforeRetryPolicies(policies);
             policies.add(retryPolicy);

sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/AttachedDatabaseConfigurationsImpl.java

@@ -32,14 +32,14 @@ public AttachedDatabaseConfigurationsImpl(
     public PagedIterable<AttachedDatabaseConfiguration> listByCluster(String resourceGroupName, String clusterName) {
         PagedIterable<AttachedDatabaseConfigurationInner> inner =
             this.serviceClient().listByCluster(resourceGroupName, clusterName);
-        return inner.mapPage(inner1 -> new AttachedDatabaseConfigurationImpl(inner1, this.manager()));
+        return Utils.mapPage(inner, inner1 -> new AttachedDatabaseConfigurationImpl(inner1, this.manager()));
     }
 
     public PagedIterable<AttachedDatabaseConfiguration> listByCluster(
         String resourceGroupName, String clusterName, Context context) {
         PagedIterable<AttachedDatabaseConfigurationInner> inner =
             this.serviceClient().listByCluster(resourceGroupName, clusterName, context);
-        return inner.mapPage(inner1 -> new AttachedDatabaseConfigurationImpl(inner1, this.manager()));
+        return Utils.mapPage(inner, inner1 -> new AttachedDatabaseConfigurationImpl(inner1, this.manager()));
     }
 
     public AttachedDatabaseConfiguration get(

sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/ClusterImpl.java

@@ -4,16 +4,21 @@
 
 package com.azure.resourcemanager.kusto.implementation;
 
+import com.azure.core.http.rest.PagedIterable;
 import com.azure.core.management.Region;
 import com.azure.core.util.Context;
 import com.azure.resourcemanager.kusto.KustoManager;
 import com.azure.resourcemanager.kusto.fluent.models.ClusterInner;
+import com.azure.resourcemanager.kusto.fluent.models.FollowerDatabaseDefinitionInner;
 import com.azure.resourcemanager.kusto.models.AzureSku;
 import com.azure.resourcemanager.kusto.models.Cluster;
 import com.azure.resourcemanager.kusto.models.ClusterUpdate;
+import com.azure.resourcemanager.kusto.models.DiagnoseVirtualNetworkResult;
 import com.azure.resourcemanager.kusto.models.EngineType;
+import com.azure.resourcemanager.kusto.models.FollowerDatabaseDefinition;
 import com.azure.resourcemanager.kusto.models.Identity;
 import com.azure.resourcemanager.kusto.models.KeyVaultProperties;
+import com.azure.resourcemanager.kusto.models.LanguageExtension;
 import com.azure.resourcemanager.kusto.models.LanguageExtensionsList;
 import com.azure.resourcemanager.kusto.models.OptimizedAutoscale;
 import com.azure.resourcemanager.kusto.models.ProvisioningState;
@@ -237,6 +242,76 @@ public Cluster refresh(Context context) {
         return this;
     }
 
+    public void stop() {
+        serviceManager.clusters().stop(resourceGroupName, clusterName);
+    }
+
+    public void stop(Context context) {
+        serviceManager.clusters().stop(resourceGroupName, clusterName, context);
+    }
+
+    public void start() {
+        serviceManager.clusters().start(resourceGroupName, clusterName);
+    }
+
+    public void start(Context context) {
+        serviceManager.clusters().start(resourceGroupName, clusterName, context);
+    }
+
+    public PagedIterable<FollowerDatabaseDefinition> listFollowerDatabases() {
+        return serviceManager.clusters().listFollowerDatabases(resourceGroupName, clusterName);
+    }
+
+    public PagedIterable<FollowerDatabaseDefinition> listFollowerDatabases(Context context) {
+        return serviceManager.clusters().listFollowerDatabases(resourceGroupName, clusterName, context);
+    }
+
+    public void detachFollowerDatabases(FollowerDatabaseDefinitionInner followerDatabaseToRemove) {
+        serviceManager.clusters().detachFollowerDatabases(resourceGroupName, clusterName, followerDatabaseToRemove);
+    }
+
+    public void detachFollowerDatabases(FollowerDatabaseDefinitionInner followerDatabaseToRemove, Context context) {
+        serviceManager
+            .clusters()
+            .detachFollowerDatabases(resourceGroupName, clusterName, followerDatabaseToRemove, context);
+    }
+
+    public DiagnoseVirtualNetworkResult diagnoseVirtualNetwork() {
+        return serviceManager.clusters().diagnoseVirtualNetwork(resourceGroupName, clusterName);
+    }
+
+    public DiagnoseVirtualNetworkResult diagnoseVirtualNetwork(Context context) {
+        return serviceManager.clusters().diagnoseVirtualNetwork(resourceGroupName, clusterName, context);
+    }
+
+    public PagedIterable<LanguageExtension> listLanguageExtensions() {
+        return serviceManager.clusters().listLanguageExtensions(resourceGroupName, clusterName);
+    }
+
+    public PagedIterable<LanguageExtension> listLanguageExtensions(Context context) {
+        return serviceManager.clusters().listLanguageExtensions(resourceGroupName, clusterName, context);
+    }
+
+    public void addLanguageExtensions(LanguageExtensionsList languageExtensionsToAdd) {
+        serviceManager.clusters().addLanguageExtensions(resourceGroupName, clusterName, languageExtensionsToAdd);
+    }
+
+    public void addLanguageExtensions(LanguageExtensionsList languageExtensionsToAdd, Context context) {
+        serviceManager
+            .clusters()
+            .addLanguageExtensions(resourceGroupName, clusterName, languageExtensionsToAdd, context);
+    }
+
+    public void removeLanguageExtensions(LanguageExtensionsList languageExtensionsToRemove) {
+        serviceManager.clusters().removeLanguageExtensions(resourceGroupName, clusterName, languageExtensionsToRemove);
+    }
+
+    public void removeLanguageExtensions(LanguageExtensionsList languageExtensionsToRemove, Context context) {
+        serviceManager
+            .clusters()
+            .removeLanguageExtensions(resourceGroupName, clusterName, languageExtensionsToRemove, context);
+    }
+
     public ClusterImpl withRegion(Region location) {
         this.innerModel().withLocation(location.toString());
         return this;

sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/ClusterPrincipalAssignmentsImpl.java

@@ -101,14 +101,14 @@ public void delete(String resourceGroupName, String clusterName, String principa
     public PagedIterable<ClusterPrincipalAssignment> list(String resourceGroupName, String clusterName) {
         PagedIterable<ClusterPrincipalAssignmentInner> inner =
             this.serviceClient().list(resourceGroupName, clusterName);
-        return inner.mapPage(inner1 -> new ClusterPrincipalAssignmentImpl(inner1, this.manager()));
+        return Utils.mapPage(inner, inner1 -> new ClusterPrincipalAssignmentImpl(inner1, this.manager()));
     }
 
     public PagedIterable<ClusterPrincipalAssignment> list(
         String resourceGroupName, String clusterName, Context context) {
         PagedIterable<ClusterPrincipalAssignmentInner> inner =
             this.serviceClient().list(resourceGroupName, clusterName, context);
-        return inner.mapPage(inner1 -> new ClusterPrincipalAssignmentImpl(inner1, this.manager()));
+        return Utils.mapPage(inner, inner1 -> new ClusterPrincipalAssignmentImpl(inner1, this.manager()));
     }
 
     public ClusterPrincipalAssignment getById(String id) {

sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/ClustersImpl.java

@@ -94,14 +94,14 @@ public PagedIterable<FollowerDatabaseDefinition> listFollowerDatabases(
         String resourceGroupName, String clusterName) {
         PagedIterable<FollowerDatabaseDefinitionInner> inner =
             this.serviceClient().listFollowerDatabases(resourceGroupName, clusterName);
-        return inner.mapPage(inner1 -> new FollowerDatabaseDefinitionImpl(inner1, this.manager()));
+        return Utils.mapPage(inner, inner1 -> new FollowerDatabaseDefinitionImpl(inner1, this.manager()));
     }
 
     public PagedIterable<FollowerDatabaseDefinition> listFollowerDatabases(
         String resourceGroupName, String clusterName, Context context) {
         PagedIterable<FollowerDatabaseDefinitionInner> inner =
             this.serviceClient().listFollowerDatabases(resourceGroupName, clusterName, context);
-        return inner.mapPage(inner1 -> new FollowerDatabaseDefinitionImpl(inner1, this.manager()));
+        return Utils.mapPage(inner, inner1 -> new FollowerDatabaseDefinitionImpl(inner1, this.manager()));
     }
 
     public void detachFollowerDatabases(
@@ -140,32 +140,32 @@ public DiagnoseVirtualNetworkResult diagnoseVirtualNetwork(
 
     public PagedIterable<Cluster> listByResourceGroup(String resourceGroupName) {
         PagedIterable<ClusterInner> inner = this.serviceClient().listByResourceGroup(resourceGroupName);
-        return inner.mapPage(inner1 -> new ClusterImpl(inner1, this.manager()));
+        return Utils.mapPage(inner, inner1 -> new ClusterImpl(inner1, this.manager()));
     }
 
     public PagedIterable<Cluster> listByResourceGroup(String resourceGroupName, Context context) {
         PagedIterable<ClusterInner> inner = this.serviceClient().listByResourceGroup(resourceGroupName, context);
-        return inner.mapPage(inner1 -> new ClusterImpl(inner1, this.manager()));
+        return Utils.mapPage(inner, inner1 -> new ClusterImpl(inner1, this.manager()));
     }
 
     public PagedIterable<Cluster> list() {
         PagedIterable<ClusterInner> inner = this.serviceClient().list();
-        return inner.mapPage(inner1 -> new ClusterImpl(inner1, this.manager()));
+        return Utils.mapPage(inner, inner1 -> new ClusterImpl(inner1, this.manager()));
     }
 
     public PagedIterable<Cluster> list(Context context) {
         PagedIterable<ClusterInner> inner = this.serviceClient().list(context);
-        return inner.mapPage(inner1 -> new ClusterImpl(inner1, this.manager()));
+        return Utils.mapPage(inner, inner1 -> new ClusterImpl(inner1, this.manager()));
     }
 
     public PagedIterable<SkuDescription> listSkus() {
         PagedIterable<SkuDescriptionInner> inner = this.serviceClient().listSkus();
-        return inner.mapPage(inner1 -> new SkuDescriptionImpl(inner1, this.manager()));
+        return Utils.mapPage(inner, inner1 -> new SkuDescriptionImpl(inner1, this.manager()));
     }
 
     public PagedIterable<SkuDescription> listSkus(Context context) {
         PagedIterable<SkuDescriptionInner> inner = this.serviceClient().listSkus(context);
-        return inner.mapPage(inner1 -> new SkuDescriptionImpl(inner1, this.manager()));
+        return Utils.mapPage(inner, inner1 -> new SkuDescriptionImpl(inner1, this.manager()));
     }
 
     public CheckNameResult checkNameAvailability(String location, ClusterCheckNameRequest clusterName) {
@@ -195,27 +195,27 @@ public Response<CheckNameResult> checkNameAvailabilityWithResponse(
     public PagedIterable<AzureResourceSku> listSkusByResource(String resourceGroupName, String clusterName) {
         PagedIterable<AzureResourceSkuInner> inner =
             this.serviceClient().listSkusByResource(resourceGroupName, clusterName);
-        return inner.mapPage(inner1 -> new AzureResourceSkuImpl(inner1, this.manager()));
+        return Utils.mapPage(inner, inner1 -> new AzureResourceSkuImpl(inner1, this.manager()));
     }
 
     public PagedIterable<AzureResourceSku> listSkusByResource(
         String resourceGroupName, String clusterName, Context context) {
         PagedIterable<AzureResourceSkuInner> inner =
             this.serviceClient().listSkusByResource(resourceGroupName, clusterName, context);
-        return inner.mapPage(inner1 -> new AzureResourceSkuImpl(inner1, this.manager()));
+        return Utils.mapPage(inner, inner1 -> new AzureResourceSkuImpl(inner1, this.manager()));
     }
 
     public PagedIterable<LanguageExtension> listLanguageExtensions(String resourceGroupName, String clusterName) {
         PagedIterable<LanguageExtensionInner> inner =
             this.serviceClient().listLanguageExtensions(resourceGroupName, clusterName);
-        return inner.mapPage(inner1 -> new LanguageExtensionImpl(inner1, this.manager()));
+        return Utils.mapPage(inner, inner1 -> new LanguageExtensionImpl(inner1, this.manager()));
     }
 
     public PagedIterable<LanguageExtension> listLanguageExtensions(
         String resourceGroupName, String clusterName, Context context) {
         PagedIterable<LanguageExtensionInner> inner =
             this.serviceClient().listLanguageExtensions(resourceGroupName, clusterName, context);
-        return inner.mapPage(inner1 -> new LanguageExtensionImpl(inner1, this.manager()));
+        return Utils.mapPage(inner, inner1 -> new LanguageExtensionImpl(inner1, this.manager()));
     }
 
     public void addLanguageExtensions(

sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/DataConnectionsImpl.java

@@ -38,14 +38,14 @@ public PagedIterable<DataConnection> listByDatabase(
         String resourceGroupName, String clusterName, String databaseName) {
         PagedIterable<DataConnectionInner> inner =
             this.serviceClient().listByDatabase(resourceGroupName, clusterName, databaseName);
-        return inner.mapPage(inner1 -> new DataConnectionImpl(inner1, this.manager()));
+        return Utils.mapPage(inner, inner1 -> new DataConnectionImpl(inner1, this.manager()));
     }
 
     public PagedIterable<DataConnection> listByDatabase(
         String resourceGroupName, String clusterName, String databaseName, Context context) {
         PagedIterable<DataConnectionInner> inner =
             this.serviceClient().listByDatabase(resourceGroupName, clusterName, databaseName, context);
-        return inner.mapPage(inner1 -> new DataConnectionImpl(inner1, this.manager()));
+        return Utils.mapPage(inner, inner1 -> new DataConnectionImpl(inner1, this.manager()));
     }
 
     public DataConnectionValidationListResult dataConnectionValidation(

sdk/kusto/azure-resourcemanager-kusto/src/main/java/com/azure/resourcemanager/kusto/implementation/DatabasePrincipalAssignmentsImpl.java

@@ -120,14 +120,14 @@ public PagedIterable<DatabasePrincipalAssignment> list(
         String resourceGroupName, String clusterName, String databaseName) {
         PagedIterable<DatabasePrincipalAssignmentInner> inner =
             this.serviceClient().list(resourceGroupName, clusterName, databaseName);
-        return inner.mapPage(inner1 -> new DatabasePrincipalAssignmentImpl(inner1, this.manager()));
+        return Utils.mapPage(inner, inner1 -> new DatabasePrincipalAssignmentImpl(inner1, this.manager()));
     }
 
     public PagedIterable<DatabasePrincipalAssignment> list(
         String resourceGroupName, String clusterName, String databaseName, Context context) {
         PagedIterable<DatabasePrincipalAssignmentInner> inner =
             this.serviceClient().list(resourceGroupName, clusterName, databaseName, context);
-        return inner.mapPage(inner1 -> new DatabasePrincipalAssignmentImpl(inner1, this.manager()));
+        return Utils.mapPage(inner, inner1 -> new DatabasePrincipalAssignmentImpl(inner1, this.manager()));
     }
 
     public DatabasePrincipalAssignment getById(String id) {