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

Merge 1b1b28a861912fb07eb40eca71cca2caf9a1b5ce into af1be2677e619e483210064ff658e62ec25053aa

Author: SDKAuto

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

@@ -1,6 +1,8 @@
 # Release History
 
-## 1.0.0-beta.5 (Unreleased)
+## 1.0.0-beta.1 (2022-09-14)
+
+- 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-2022-07. For documentation on how to use this package, please see [Azure Management Libraries for Java](https://aka.ms/azsdk/java/mgmt).
 
 ### Features Added
 

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

@@ -2,7 +2,7 @@
 
 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-2022-02. For documentation on how to use this package, please see [Azure Management Libraries for Java](https://aka.ms/azsdk/java/mgmt).
+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-2022-07. 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
 
@@ -32,7 +32,7 @@ Various documentation is available to help you get started
 <dependency>
     <groupId>com.azure.resourcemanager</groupId>
     <artifactId>azure-resourcemanager-kusto</artifactId>
-    <version>1.0.0-beta.4</version>
+    <version>1.0.0-beta.5</version>
 </dependency>
 ```
 [//]: # ({x-version-update-end})

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

@@ -13,7 +13,7 @@
   <packaging>jar</packaging>
 
   <name>Microsoft Azure SDK for Kusto Management</name>
-  <description>This package contains Microsoft Azure SDK for Kusto Management SDK. For documentation on how to use this package, please see https://aka.ms/azsdk/java/mgmt. 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-2022-02.</description>
+  <description>This package contains Microsoft Azure SDK for Kusto Management SDK. For documentation on how to use this package, please see https://aka.ms/azsdk/java/mgmt. 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-2022-07.</description>
   <url>https://github.com/Azure/azure-sdk-for-java</url>
 
   <licenses>

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

@@ -10,11 +10,13 @@
 import com.azure.core.http.HttpPipelineBuilder;
 import com.azure.core.http.HttpPipelinePosition;
 import com.azure.core.http.policy.AddDatePolicy;
+import com.azure.core.http.policy.AddHeadersFromContextPolicy;
 import com.azure.core.http.policy.HttpLogOptions;
 import com.azure.core.http.policy.HttpLoggingPolicy;
 import com.azure.core.http.policy.HttpPipelinePolicy;
 import com.azure.core.http.policy.HttpPolicyProviders;
 import com.azure.core.http.policy.RequestIdPolicy;
+import com.azure.core.http.policy.RetryOptions;
 import com.azure.core.http.policy.RetryPolicy;
 import com.azure.core.http.policy.UserAgentPolicy;
 import com.azure.core.management.http.policy.ArmChallengeAuthenticationPolicy;
@@ -115,6 +117,19 @@ public static KustoManager authenticate(TokenCredential credential, AzureProfile
         return configure().authenticate(credential, profile);
     }
 
+    /**
+     * Creates an instance of Kusto service API entry point.
+     *
+     * @param httpPipeline the {@link HttpPipeline} configured with Azure authentication credential.
+     * @param profile the Azure profile for client.
+     * @return the Kusto service API instance.
+     */
+    public static KustoManager authenticate(HttpPipeline httpPipeline, AzureProfile profile) {
+        Objects.requireNonNull(httpPipeline, "'httpPipeline' cannot be null.");
+        Objects.requireNonNull(profile, "'profile' cannot be null.");
+        return new KustoManager(httpPipeline, profile, null);
+    }
+
     /**
      * Gets a Configurable instance that can be used to create KustoManager with optional configuration.
      *
@@ -126,13 +141,14 @@ public static Configurable configure() {
 
     /** The Configurable allowing configurations to be set. */
     public static final class Configurable {
-        private final ClientLogger logger = new ClientLogger(Configurable.class);
+        private static final ClientLogger LOGGER = new ClientLogger(Configurable.class);
 
         private HttpClient httpClient;
         private HttpLogOptions httpLogOptions;
         private final List<HttpPipelinePolicy> policies = new ArrayList<>();
         private final List<String> scopes = new ArrayList<>();
         private RetryPolicy retryPolicy;
+        private RetryOptions retryOptions;
         private Duration defaultPollInterval;
 
         private Configurable() {
@@ -193,16 +209,31 @@ public Configurable withRetryPolicy(RetryPolicy retryPolicy) {
             return this;
         }
 
+        /**
+         * Sets the retry options for the HTTP pipeline retry policy.
+         *
+         * <p>This setting has no effect, if retry policy is set via {@link #withRetryPolicy(RetryPolicy)}.
+         *
+         * @param retryOptions the retry options for the HTTP pipeline retry policy.
+         * @return the configurable object itself.
+         */
+        public Configurable withRetryOptions(RetryOptions retryOptions) {
+            this.retryOptions = Objects.requireNonNull(retryOptions, "'retryOptions' cannot be null.");
+            return this;
+        }
+
         /**
          * Sets the default poll interval, used when service does not provide "Retry-After" header.
          *
          * @param defaultPollInterval the default poll interval.
          * @return the configurable object itself.
          */
         public Configurable withDefaultPollInterval(Duration defaultPollInterval) {
-            this.defaultPollInterval = Objects.requireNonNull(defaultPollInterval, "'retryPolicy' cannot be null.");
+            this.defaultPollInterval =
+                Objects.requireNonNull(defaultPollInterval, "'defaultPollInterval' cannot be null.");
             if (this.defaultPollInterval.isNegative()) {
-                throw logger.logExceptionAsError(new IllegalArgumentException("'httpPipeline' cannot be negative"));
+                throw LOGGER
+                    .logExceptionAsError(new IllegalArgumentException("'defaultPollInterval' cannot be negative"));
             }
             return this;
         }
@@ -224,7 +255,7 @@ public KustoManager authenticate(TokenCredential credential, AzureProfile profil
                 .append("-")
                 .append("com.azure.resourcemanager.kusto")
                 .append("/")
-                .append("1.0.0-beta.4");
+                .append("1.0.0-beta.1");
             if (!Configuration.getGlobalConfiguration().get("AZURE_TELEMETRY_DISABLED", false)) {
                 userAgentBuilder
                     .append(" (")
@@ -242,10 +273,15 @@ public KustoManager authenticate(TokenCredential credential, AzureProfile profil
                 scopes.add(profile.getEnvironment().getManagementEndpoint() + "/.default");
             }
             if (retryPolicy == null) {
-                retryPolicy = new RetryPolicy("Retry-After", ChronoUnit.SECONDS);
+                if (retryOptions != null) {
+                    retryPolicy = new RetryPolicy(retryOptions);
+                } else {
+                    retryPolicy = new RetryPolicy("Retry-After", ChronoUnit.SECONDS);
+                }
             }
             List<HttpPipelinePolicy> policies = new ArrayList<>();
             policies.add(new UserAgentPolicy(userAgentBuilder.toString()));
+            policies.add(new AddHeadersFromContextPolicy());
             policies.add(new RequestIdPolicy());
             policies
                 .addAll(
@@ -276,15 +312,23 @@ public KustoManager authenticate(TokenCredential credential, AzureProfile profil
         }
     }
 
-    /** @return Resource collection API of Clusters. */
+    /**
+     * Gets the resource collection API of Clusters. It manages Cluster.
+     *
+     * @return Resource collection API of Clusters.
+     */
     public Clusters clusters() {
         if (this.clusters == null) {
             this.clusters = new ClustersImpl(clientObject.getClusters(), this);
         }
         return clusters;
     }
 
-    /** @return Resource collection API of ClusterPrincipalAssignments. */
+    /**
+     * Gets the resource collection API of ClusterPrincipalAssignments. It manages ClusterPrincipalAssignment.
+     *
+     * @return Resource collection API of ClusterPrincipalAssignments.
+     */
     public ClusterPrincipalAssignments clusterPrincipalAssignments() {
         if (this.clusterPrincipalAssignments == null) {
             this.clusterPrincipalAssignments =
@@ -293,15 +337,23 @@ public ClusterPrincipalAssignments clusterPrincipalAssignments() {
         return clusterPrincipalAssignments;
     }
 
-    /** @return Resource collection API of Databases. */
+    /**
+     * Gets the resource collection API of Databases.
+     *
+     * @return Resource collection API of Databases.
+     */
     public Databases databases() {
         if (this.databases == null) {
             this.databases = new DatabasesImpl(clientObject.getDatabases(), this);
         }
         return databases;
     }
 
-    /** @return Resource collection API of AttachedDatabaseConfigurations. */
+    /**
+     * Gets the resource collection API of AttachedDatabaseConfigurations. It manages AttachedDatabaseConfiguration.
+     *
+     * @return Resource collection API of AttachedDatabaseConfigurations.
+     */
     public AttachedDatabaseConfigurations attachedDatabaseConfigurations() {
         if (this.attachedDatabaseConfigurations == null) {
             this.attachedDatabaseConfigurations =
@@ -310,7 +362,11 @@ public AttachedDatabaseConfigurations attachedDatabaseConfigurations() {
         return attachedDatabaseConfigurations;
     }
 
-    /** @return Resource collection API of ManagedPrivateEndpoints. */
+    /**
+     * Gets the resource collection API of ManagedPrivateEndpoints. It manages ManagedPrivateEndpoint.
+     *
+     * @return Resource collection API of ManagedPrivateEndpoints.
+     */
     public ManagedPrivateEndpoints managedPrivateEndpoints() {
         if (this.managedPrivateEndpoints == null) {
             this.managedPrivateEndpoints =
@@ -319,7 +375,11 @@ public ManagedPrivateEndpoints managedPrivateEndpoints() {
         return managedPrivateEndpoints;
     }
 
-    /** @return Resource collection API of DatabasePrincipalAssignments. */
+    /**
+     * Gets the resource collection API of DatabasePrincipalAssignments. It manages DatabasePrincipalAssignment.
+     *
+     * @return Resource collection API of DatabasePrincipalAssignments.
+     */
     public DatabasePrincipalAssignments databasePrincipalAssignments() {
         if (this.databasePrincipalAssignments == null) {
             this.databasePrincipalAssignments =
@@ -328,15 +388,23 @@ public DatabasePrincipalAssignments databasePrincipalAssignments() {
         return databasePrincipalAssignments;
     }
 
-    /** @return Resource collection API of Scripts. */
+    /**
+     * Gets the resource collection API of Scripts. It manages Script.
+     *
+     * @return Resource collection API of Scripts.
+     */
     public Scripts scripts() {
         if (this.scripts == null) {
             this.scripts = new ScriptsImpl(clientObject.getScripts(), this);
         }
         return scripts;
     }
 
-    /** @return Resource collection API of PrivateEndpointConnections. */
+    /**
+     * Gets the resource collection API of PrivateEndpointConnections. It manages PrivateEndpointConnection.
+     *
+     * @return Resource collection API of PrivateEndpointConnections.
+     */
     public PrivateEndpointConnections privateEndpointConnections() {
         if (this.privateEndpointConnections == null) {
             this.privateEndpointConnections =
@@ -345,39 +413,59 @@ public PrivateEndpointConnections privateEndpointConnections() {
         return privateEndpointConnections;
     }
 
-    /** @return Resource collection API of PrivateLinkResources. */
+    /**
+     * Gets the resource collection API of PrivateLinkResources.
+     *
+     * @return Resource collection API of PrivateLinkResources.
+     */
     public PrivateLinkResources privateLinkResources() {
         if (this.privateLinkResources == null) {
             this.privateLinkResources = new PrivateLinkResourcesImpl(clientObject.getPrivateLinkResources(), this);
         }
         return privateLinkResources;
     }
 
-    /** @return Resource collection API of DataConnections. */
+    /**
+     * Gets the resource collection API of DataConnections.
+     *
+     * @return Resource collection API of DataConnections.
+     */
     public DataConnections dataConnections() {
         if (this.dataConnections == null) {
             this.dataConnections = new DataConnectionsImpl(clientObject.getDataConnections(), this);
         }
         return dataConnections;
     }
 
-    /** @return Resource collection API of Operations. */
+    /**
+     * Gets the resource collection API of Operations.
+     *
+     * @return Resource collection API of Operations.
+     */
     public Operations operations() {
         if (this.operations == null) {
             this.operations = new OperationsImpl(clientObject.getOperations(), this);
         }
         return operations;
     }
 
-    /** @return Resource collection API of OperationsResults. */
+    /**
+     * Gets the resource collection API of OperationsResults.
+     *
+     * @return Resource collection API of OperationsResults.
+     */
     public OperationsResults operationsResults() {
         if (this.operationsResults == null) {
             this.operationsResults = new OperationsResultsImpl(clientObject.getOperationsResults(), this);
         }
         return operationsResults;
     }
 
-    /** @return Resource collection API of OperationsResultsLocations. */
+    /**
+     * Gets the resource collection API of OperationsResultsLocations.
+     *
+     * @return Resource collection API of OperationsResultsLocations.
+     */
     public OperationsResultsLocations operationsResultsLocations() {
         if (this.operationsResultsLocations == null) {
             this.operationsResultsLocations =