diff --git a/sdk/resourcemanager/api-specs.json b/sdk/resourcemanager/api-specs.json
index 0a424422c4c54..0c5f6c7cb1972 100644
--- a/sdk/resourcemanager/api-specs.json
+++ b/sdk/resourcemanager/api-specs.json
@@ -347,7 +347,8 @@
"dir": "azure-resourcemanager-redis",
"source": "specification/redis/resource-manager/readme.md",
"package": "com.azure.resourcemanager.redis",
- "args": "--tag=package-2020-12"
+ "args": "--tag=package-2021-06 --rename-model=ErrorDetailAutoGenerated:ErrorDetail",
+ "note": "run RedisConfigurationTests.generateConfigurationUtils"
},
"relay": {
"dir": "azure-resourcemanager-relay",
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/CHANGELOG.md b/sdk/resourcemanager/azure-resourcemanager-redis/CHANGELOG.md
index 69fad11dd85d0..bfa500466ad55 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/CHANGELOG.md
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/CHANGELOG.md
@@ -2,13 +2,11 @@
## 2.13.0-beta.1 (Unreleased)
-### Features Added
-
-### Breaking Changes
+### Other Changes
-### Bugs Fixed
+#### Dependency Updates
-### Other Changes
+- Updated `api-version` to `2021-06-01`.
## 2.12.0 (2022-02-14)
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/pom.xml b/sdk/resourcemanager/azure-resourcemanager-redis/pom.xml
index 17388719c5f86..dc10ab880d0f1 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/pom.xml
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/pom.xml
@@ -49,6 +49,7 @@
false
+ true
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/AsyncOperationStatusClient.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/AsyncOperationStatusClient.java
new file mode 100644
index 0000000000000..2195dfcafe09a
--- /dev/null
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/AsyncOperationStatusClient.java
@@ -0,0 +1,68 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) AutoRest Code Generator.
+
+package com.azure.resourcemanager.redis.fluent;
+
+import com.azure.core.annotation.ReturnType;
+import com.azure.core.annotation.ServiceMethod;
+import com.azure.core.http.rest.Response;
+import com.azure.core.util.Context;
+import com.azure.resourcemanager.redis.fluent.models.OperationStatusInner;
+import reactor.core.publisher.Mono;
+
+/** An instance of this class provides access to all the operations defined in AsyncOperationStatusClient. */
+public interface AsyncOperationStatusClient {
+ /**
+ * For checking the ongoing status of an operation.
+ *
+ * @param location The location at which operation was triggered.
+ * @param operationId The ID of asynchronous operation.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return asynchronous operation status along with {@link Response} on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ Mono> getWithResponseAsync(String location, String operationId);
+
+ /**
+ * For checking the ongoing status of an operation.
+ *
+ * @param location The location at which operation was triggered.
+ * @param operationId The ID of asynchronous operation.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return asynchronous operation status on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ Mono getAsync(String location, String operationId);
+
+ /**
+ * For checking the ongoing status of an operation.
+ *
+ * @param location The location at which operation was triggered.
+ * @param operationId The ID of asynchronous operation.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return asynchronous operation status.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ OperationStatusInner get(String location, String operationId);
+
+ /**
+ * For checking the ongoing status of an operation.
+ *
+ * @param location The location at which operation was triggered.
+ * @param operationId The ID of asynchronous operation.
+ * @param context The context to associate with this operation.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return asynchronous operation status along with {@link Response}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ Response getWithResponse(String location, String operationId, Context context);
+}
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/FirewallRulesClient.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/FirewallRulesClient.java
index 3ded58a9d2641..3ceaf29484434 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/FirewallRulesClient.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/FirewallRulesClient.java
@@ -23,7 +23,7 @@ public interface FirewallRulesClient {
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return all firewall rules in the specified redis cache.
+ * @return all firewall rules in the specified redis cache as paginated response with {@link PagedFlux}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedFlux listAsync(String resourceGroupName, String cacheName);
@@ -36,7 +36,7 @@ public interface FirewallRulesClient {
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return all firewall rules in the specified redis cache.
+ * @return all firewall rules in the specified redis cache as paginated response with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable list(String resourceGroupName, String cacheName);
@@ -50,7 +50,7 @@ public interface FirewallRulesClient {
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return all firewall rules in the specified redis cache.
+ * @return all firewall rules in the specified redis cache as paginated response with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable list(String resourceGroupName, String cacheName, Context context);
@@ -66,7 +66,7 @@ public interface FirewallRulesClient {
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return a firewall rule on a redis cache has a name, and describes a contiguous range of IP addresses permitted
- * to connect.
+ * to connect along with {@link Response} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono> createOrUpdateWithResponseAsync(
@@ -83,7 +83,7 @@ Mono> createOrUpdateWithResponseAsync(
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return a firewall rule on a redis cache has a name, and describes a contiguous range of IP addresses permitted
- * to connect.
+ * to connect on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono createOrUpdateAsync(
@@ -118,7 +118,7 @@ RedisFirewallRuleInner createOrUpdate(
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return a firewall rule on a redis cache has a name, and describes a contiguous range of IP addresses permitted
- * to connect.
+ * to connect along with {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Response createOrUpdateWithResponse(
@@ -137,7 +137,8 @@ Response createOrUpdateWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a single firewall rule in a specified redis cache.
+ * @return a single firewall rule in a specified redis cache along with {@link Response} on successful completion of
+ * {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono> getWithResponseAsync(
@@ -152,7 +153,7 @@ Mono> getWithResponseAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a single firewall rule in a specified redis cache.
+ * @return a single firewall rule in a specified redis cache on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono getAsync(String resourceGroupName, String cacheName, String ruleName);
@@ -181,7 +182,7 @@ Mono> getWithResponseAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a single firewall rule in a specified redis cache.
+ * @return a single firewall rule in a specified redis cache along with {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Response getWithResponse(
@@ -196,7 +197,7 @@ Response getWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link Response} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono> deleteWithResponseAsync(String resourceGroupName, String cacheName, String ruleName);
@@ -210,7 +211,7 @@ Response getWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return A {@link Mono} that completes when a successful response is received.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono deleteAsync(String resourceGroupName, String cacheName, String ruleName);
@@ -238,7 +239,7 @@ Response getWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the response.
+ * @return the {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Response deleteWithResponse(String resourceGroupName, String cacheName, String ruleName, Context context);
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/LinkedServersClient.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/LinkedServersClient.java
index 42395d0e366e9..062f5617263a5 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/LinkedServersClient.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/LinkedServersClient.java
@@ -31,7 +31,8 @@ public interface LinkedServersClient {
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return response to put/get linked server (with properties) for Redis cache.
+ * @return response to put/get linked server (with properties) for Redis cache along with {@link Response} on
+ * successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono>> createWithResponseAsync(
@@ -47,9 +48,10 @@ Mono>> createWithResponseAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return response to put/get linked server (with properties) for Redis cache.
+ * @return the {@link PollerFlux} for polling of response to put/get linked server (with properties) for Redis
+ * cache.
*/
- @ServiceMethod(returns = ReturnType.SINGLE)
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
PollerFlux, RedisLinkedServerWithPropertiesInner> beginCreateAsync(
String resourceGroupName, String name, String linkedServerName, RedisLinkedServerCreateParameters parameters);
@@ -63,9 +65,10 @@ PollerFlux, RedisLinkedServerWi
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return response to put/get linked server (with properties) for Redis cache.
+ * @return the {@link SyncPoller} for polling of response to put/get linked server (with properties) for Redis
+ * cache.
*/
- @ServiceMethod(returns = ReturnType.SINGLE)
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, RedisLinkedServerWithPropertiesInner> beginCreate(
String resourceGroupName, String name, String linkedServerName, RedisLinkedServerCreateParameters parameters);
@@ -80,9 +83,10 @@ SyncPoller, RedisLinkedServerWi
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return response to put/get linked server (with properties) for Redis cache.
+ * @return the {@link SyncPoller} for polling of response to put/get linked server (with properties) for Redis
+ * cache.
*/
- @ServiceMethod(returns = ReturnType.SINGLE)
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, RedisLinkedServerWithPropertiesInner> beginCreate(
String resourceGroupName,
String name,
@@ -100,7 +104,8 @@ SyncPoller, RedisLinkedServerWi
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return response to put/get linked server (with properties) for Redis cache.
+ * @return response to put/get linked server (with properties) for Redis cache on successful completion of {@link
+ * Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono createAsync(
@@ -152,7 +157,7 @@ RedisLinkedServerWithPropertiesInner create(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link Response} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono> deleteWithResponseAsync(String resourceGroupName, String name, String linkedServerName);
@@ -166,7 +171,7 @@ RedisLinkedServerWithPropertiesInner create(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return A {@link Mono} that completes when a successful response is received.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono deleteAsync(String resourceGroupName, String name, String linkedServerName);
@@ -194,7 +199,7 @@ RedisLinkedServerWithPropertiesInner create(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the response.
+ * @return the {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Response deleteWithResponse(String resourceGroupName, String name, String linkedServerName, Context context);
@@ -208,7 +213,8 @@ RedisLinkedServerWithPropertiesInner create(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the detailed information about a linked server of a redis cache (requires Premium SKU).
+ * @return the detailed information about a linked server of a redis cache (requires Premium SKU) along with {@link
+ * Response} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono> getWithResponseAsync(
@@ -223,7 +229,8 @@ Mono> getWithResponseAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the detailed information about a linked server of a redis cache (requires Premium SKU).
+ * @return the detailed information about a linked server of a redis cache (requires Premium SKU) on successful
+ * completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono getAsync(String resourceGroupName, String name, String linkedServerName);
@@ -252,7 +259,8 @@ Mono> getWithResponseAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the detailed information about a linked server of a redis cache (requires Premium SKU).
+ * @return the detailed information about a linked server of a redis cache (requires Premium SKU) along with {@link
+ * Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Response getWithResponse(
@@ -266,7 +274,8 @@ Response getWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the list of linked servers associated with this redis cache (requires Premium SKU).
+ * @return the list of linked servers associated with this redis cache (requires Premium SKU) as paginated response
+ * with {@link PagedFlux}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedFlux listAsync(String resourceGroupName, String name);
@@ -279,7 +288,8 @@ Response getWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the list of linked servers associated with this redis cache (requires Premium SKU).
+ * @return the list of linked servers associated with this redis cache (requires Premium SKU) as paginated response
+ * with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable list(String resourceGroupName, String name);
@@ -293,7 +303,8 @@ Response getWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the list of linked servers associated with this redis cache (requires Premium SKU).
+ * @return the list of linked servers associated with this redis cache (requires Premium SKU) as paginated response
+ * with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable list(String resourceGroupName, String name, Context context);
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/OperationsClient.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/OperationsClient.java
index 7e1623757de1f..6e4fe53846e8e 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/OperationsClient.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/OperationsClient.java
@@ -18,7 +18,7 @@ public interface OperationsClient {
*
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return result of the request to list REST API operations.
+ * @return result of the request to list REST API operations as paginated response with {@link PagedFlux}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedFlux listAsync();
@@ -28,7 +28,7 @@ public interface OperationsClient {
*
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return result of the request to list REST API operations.
+ * @return result of the request to list REST API operations as paginated response with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable list();
@@ -40,7 +40,7 @@ public interface OperationsClient {
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return result of the request to list REST API operations.
+ * @return result of the request to list REST API operations as paginated response with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable list(Context context);
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/PatchSchedulesClient.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/PatchSchedulesClient.java
index 9d7e2d3fb3046..7ec9fa39b4b85 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/PatchSchedulesClient.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/PatchSchedulesClient.java
@@ -24,7 +24,8 @@ public interface PatchSchedulesClient {
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return all patch schedules in the specified redis cache (there is only one).
+ * @return all patch schedules in the specified redis cache (there is only one) as paginated response with {@link
+ * PagedFlux}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedFlux listByRedisResourceAsync(String resourceGroupName, String cacheName);
@@ -37,7 +38,8 @@ public interface PatchSchedulesClient {
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return all patch schedules in the specified redis cache (there is only one).
+ * @return all patch schedules in the specified redis cache (there is only one) as paginated response with {@link
+ * PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable listByRedisResource(String resourceGroupName, String cacheName);
@@ -51,7 +53,8 @@ public interface PatchSchedulesClient {
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return all patch schedules in the specified redis cache (there is only one).
+ * @return all patch schedules in the specified redis cache (there is only one) as paginated response with {@link
+ * PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable listByRedisResource(
@@ -67,7 +70,8 @@ PagedIterable listByRedisResource(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return response to put/get patch schedules for Redis cache.
+ * @return response to put/get patch schedules for Redis cache along with {@link Response} on successful completion
+ * of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono> createOrUpdateWithResponseAsync(
@@ -83,7 +87,7 @@ Mono> createOrUpdateWithResponseAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return response to put/get patch schedules for Redis cache.
+ * @return response to put/get patch schedules for Redis cache on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono createOrUpdateAsync(
@@ -116,7 +120,7 @@ RedisPatchScheduleInner createOrUpdate(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return response to put/get patch schedules for Redis cache.
+ * @return response to put/get patch schedules for Redis cache along with {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Response createOrUpdateWithResponse(
@@ -135,7 +139,7 @@ Response createOrUpdateWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link Response} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono> deleteWithResponseAsync(String resourceGroupName, String name, DefaultName defaultParameter);
@@ -149,7 +153,7 @@ Response createOrUpdateWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return A {@link Mono} that completes when a successful response is received.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono deleteAsync(String resourceGroupName, String name, DefaultName defaultParameter);
@@ -177,7 +181,7 @@ Response createOrUpdateWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the response.
+ * @return the {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Response deleteWithResponse(
@@ -192,7 +196,8 @@ Response deleteWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the patching schedule of a redis cache.
+ * @return the patching schedule of a redis cache along with {@link Response} on successful completion of {@link
+ * Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono> getWithResponseAsync(
@@ -207,7 +212,7 @@ Mono> getWithResponseAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the patching schedule of a redis cache.
+ * @return the patching schedule of a redis cache on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono getAsync(String resourceGroupName, String name, DefaultName defaultParameter);
@@ -236,7 +241,7 @@ Mono> getWithResponseAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the patching schedule of a redis cache.
+ * @return the patching schedule of a redis cache along with {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Response getWithResponse(
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/PrivateEndpointConnectionsClient.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/PrivateEndpointConnectionsClient.java
index 923b11de75e47..516489f0446ed 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/PrivateEndpointConnectionsClient.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/PrivateEndpointConnectionsClient.java
@@ -28,7 +28,8 @@ public interface PrivateEndpointConnectionsClient {
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return list of private endpoint connection associated with the specified storage account.
+ * @return list of private endpoint connection associated with the specified storage account as paginated response
+ * with {@link PagedFlux}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedFlux listAsync(String resourceGroupName, String cacheName);
@@ -41,7 +42,8 @@ public interface PrivateEndpointConnectionsClient {
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return list of private endpoint connection associated with the specified storage account.
+ * @return list of private endpoint connection associated with the specified storage account as paginated response
+ * with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable list(String resourceGroupName, String cacheName);
@@ -55,7 +57,8 @@ public interface PrivateEndpointConnectionsClient {
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return list of private endpoint connection associated with the specified storage account.
+ * @return list of private endpoint connection associated with the specified storage account as paginated response
+ * with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable list(String resourceGroupName, String cacheName, Context context);
@@ -70,7 +73,8 @@ public interface PrivateEndpointConnectionsClient {
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the specified private endpoint connection associated with the redis cache.
+ * @return the specified private endpoint connection associated with the redis cache along with {@link Response} on
+ * successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono> getWithResponseAsync(
@@ -86,7 +90,8 @@ Mono> getWithResponseAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the specified private endpoint connection associated with the redis cache.
+ * @return the specified private endpoint connection associated with the redis cache on successful completion of
+ * {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono getAsync(
@@ -119,7 +124,7 @@ PrivateEndpointConnectionInner get(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the specified private endpoint connection associated with the redis cache.
+ * @return the specified private endpoint connection associated with the redis cache along with {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Response getWithResponse(
@@ -136,7 +141,8 @@ Response getWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the Private Endpoint Connection resource.
+ * @return the Private Endpoint Connection resource along with {@link Response} on successful completion of {@link
+ * Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono>> putWithResponseAsync(
@@ -156,9 +162,9 @@ Mono>> putWithResponseAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the Private Endpoint Connection resource.
+ * @return the {@link PollerFlux} for polling of the Private Endpoint Connection resource.
*/
- @ServiceMethod(returns = ReturnType.SINGLE)
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
PollerFlux, PrivateEndpointConnectionInner> beginPutAsync(
String resourceGroupName,
String cacheName,
@@ -176,9 +182,9 @@ PollerFlux, PrivateEndpointConnection
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the Private Endpoint Connection resource.
+ * @return the {@link SyncPoller} for polling of the Private Endpoint Connection resource.
*/
- @ServiceMethod(returns = ReturnType.SINGLE)
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, PrivateEndpointConnectionInner> beginPut(
String resourceGroupName,
String cacheName,
@@ -197,9 +203,9 @@ SyncPoller, PrivateEndpointConnection
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the Private Endpoint Connection resource.
+ * @return the {@link SyncPoller} for polling of the Private Endpoint Connection resource.
*/
- @ServiceMethod(returns = ReturnType.SINGLE)
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, PrivateEndpointConnectionInner> beginPut(
String resourceGroupName,
String cacheName,
@@ -218,7 +224,7 @@ SyncPoller, PrivateEndpointConnection
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the Private Endpoint Connection resource.
+ * @return the Private Endpoint Connection resource on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono putAsync(
@@ -279,7 +285,7 @@ PrivateEndpointConnectionInner put(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link Response} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono> deleteWithResponseAsync(
@@ -295,7 +301,7 @@ Mono> deleteWithResponseAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return A {@link Mono} that completes when a successful response is received.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono deleteAsync(String resourceGroupName, String cacheName, String privateEndpointConnectionName);
@@ -325,7 +331,7 @@ Mono> deleteWithResponseAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the response.
+ * @return the {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Response deleteWithResponse(
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/PrivateLinkResourcesClient.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/PrivateLinkResourcesClient.java
index 640ecb6134352..43e2fe3e4c3ed 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/PrivateLinkResourcesClient.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/PrivateLinkResourcesClient.java
@@ -21,7 +21,8 @@ public interface PrivateLinkResourcesClient {
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the private link resources that need to be created for a redis cache.
+ * @return the private link resources that need to be created for a redis cache as paginated response with {@link
+ * PagedFlux}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedFlux listByRedisCacheAsync(String resourceGroupName, String cacheName);
@@ -34,7 +35,8 @@ public interface PrivateLinkResourcesClient {
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the private link resources that need to be created for a redis cache.
+ * @return the private link resources that need to be created for a redis cache as paginated response with {@link
+ * PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable listByRedisCache(String resourceGroupName, String cacheName);
@@ -48,7 +50,8 @@ public interface PrivateLinkResourcesClient {
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the private link resources that need to be created for a redis cache.
+ * @return the private link resources that need to be created for a redis cache as paginated response with {@link
+ * PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable listByRedisCache(
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/RedisClient.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/RedisClient.java
index 5b634435a96f9..485dffeb94321 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/RedisClient.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/RedisClient.java
@@ -42,7 +42,7 @@ public interface RedisClient
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link Response} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono> checkNameAvailabilityWithResponseAsync(CheckNameAvailabilityParameters parameters);
@@ -55,7 +55,7 @@ public interface RedisClient
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return A {@link Mono} that completes when a successful response is received.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono checkNameAvailabilityAsync(CheckNameAvailabilityParameters parameters);
@@ -81,7 +81,7 @@ public interface RedisClient
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the response.
+ * @return the {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Response checkNameAvailabilityWithResponse(CheckNameAvailabilityParameters parameters, Context context);
@@ -95,7 +95,7 @@ public interface RedisClient
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return any upgrade notifications for a Redis cache.
+ * @return any upgrade notifications for a Redis cache as paginated response with {@link PagedFlux}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedFlux listUpgradeNotificationsAsync(
@@ -110,7 +110,7 @@ PagedFlux listUpgradeNotificationsAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return any upgrade notifications for a Redis cache.
+ * @return any upgrade notifications for a Redis cache as paginated response with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable listUpgradeNotifications(
@@ -126,7 +126,7 @@ PagedIterable listUpgradeNotifications(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return any upgrade notifications for a Redis cache.
+ * @return any upgrade notifications for a Redis cache as paginated response with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable listUpgradeNotifications(
@@ -141,7 +141,8 @@ PagedIterable listUpgradeNotifications(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a single Redis item in List or Get Operation.
+ * @return a single Redis item in List or Get Operation along with {@link Response} on successful completion of
+ * {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono>> createWithResponseAsync(
@@ -156,9 +157,9 @@ Mono>> createWithResponseAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a single Redis item in List or Get Operation.
+ * @return the {@link PollerFlux} for polling of a single Redis item in List or Get Operation.
*/
- @ServiceMethod(returns = ReturnType.SINGLE)
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
PollerFlux, RedisResourceInner> beginCreateAsync(
String resourceGroupName, String name, RedisCreateParameters parameters);
@@ -171,9 +172,9 @@ PollerFlux, RedisResourceInner> beginCreateAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a single Redis item in List or Get Operation.
+ * @return the {@link SyncPoller} for polling of a single Redis item in List or Get Operation.
*/
- @ServiceMethod(returns = ReturnType.SINGLE)
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, RedisResourceInner> beginCreate(
String resourceGroupName, String name, RedisCreateParameters parameters);
@@ -187,9 +188,9 @@ SyncPoller, RedisResourceInner> beginCreate(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a single Redis item in List or Get Operation.
+ * @return the {@link SyncPoller} for polling of a single Redis item in List or Get Operation.
*/
- @ServiceMethod(returns = ReturnType.SINGLE)
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, RedisResourceInner> beginCreate(
String resourceGroupName, String name, RedisCreateParameters parameters, Context context);
@@ -202,7 +203,7 @@ SyncPoller, RedisResourceInner> beginCreate(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a single Redis item in List or Get Operation.
+ * @return a single Redis item in List or Get Operation on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono createAsync(String resourceGroupName, String name, RedisCreateParameters parameters);
@@ -245,7 +246,8 @@ SyncPoller, RedisResourceInner> beginCreate(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a single Redis item in List or Get Operation.
+ * @return a single Redis item in List or Get Operation along with {@link Response} on successful completion of
+ * {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono> updateWithResponseAsync(
@@ -260,7 +262,7 @@ Mono> updateWithResponseAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a single Redis item in List or Get Operation.
+ * @return a single Redis item in List or Get Operation on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono updateAsync(String resourceGroupName, String name, RedisUpdateParameters parameters);
@@ -289,7 +291,7 @@ Mono> updateWithResponseAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a single Redis item in List or Get Operation.
+ * @return a single Redis item in List or Get Operation along with {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Response updateWithResponse(
@@ -303,7 +305,7 @@ Response updateWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link Response} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono>> deleteWithResponseAsync(String resourceGroupName, String name);
@@ -316,9 +318,9 @@ Response updateWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link PollerFlux} for polling of long-running operation.
*/
- @ServiceMethod(returns = ReturnType.SINGLE)
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
PollerFlux, Void> beginDeleteAsync(String resourceGroupName, String name);
/**
@@ -329,9 +331,9 @@ Response updateWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link SyncPoller} for polling of long-running operation.
*/
- @ServiceMethod(returns = ReturnType.SINGLE)
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, Void> beginDelete(String resourceGroupName, String name);
/**
@@ -343,9 +345,9 @@ Response updateWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link SyncPoller} for polling of long-running operation.
*/
- @ServiceMethod(returns = ReturnType.SINGLE)
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, Void> beginDelete(String resourceGroupName, String name, Context context);
/**
@@ -356,7 +358,7 @@ Response updateWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return A {@link Mono} that completes when a successful response is received.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono deleteAsync(String resourceGroupName, String name);
@@ -394,7 +396,8 @@ Response updateWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a Redis cache (resource description).
+ * @return a Redis cache (resource description) along with {@link Response} on successful completion of {@link
+ * Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono> getByResourceGroupWithResponseAsync(String resourceGroupName, String name);
@@ -407,7 +410,7 @@ Response updateWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a Redis cache (resource description).
+ * @return a Redis cache (resource description) on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono getByResourceGroupAsync(String resourceGroupName, String name);
@@ -434,7 +437,7 @@ Response updateWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a Redis cache (resource description).
+ * @return a Redis cache (resource description) along with {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Response getByResourceGroupWithResponse(String resourceGroupName, String name, Context context);
@@ -446,7 +449,7 @@ Response updateWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the response of list Redis operation.
+ * @return the response of list Redis operation as paginated response with {@link PagedFlux}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedFlux listByResourceGroupAsync(String resourceGroupName);
@@ -458,7 +461,7 @@ Response updateWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the response of list Redis operation.
+ * @return the response of list Redis operation as paginated response with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable listByResourceGroup(String resourceGroupName);
@@ -471,7 +474,7 @@ Response updateWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the response of list Redis operation.
+ * @return the response of list Redis operation as paginated response with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable listByResourceGroup(String resourceGroupName, Context context);
@@ -481,7 +484,7 @@ Response updateWithResponse(
*
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return all Redis caches in the specified subscription.
+ * @return all Redis caches in the specified subscription as paginated response with {@link PagedFlux}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedFlux listAsync();
@@ -491,7 +494,7 @@ Response updateWithResponse(
*
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return all Redis caches in the specified subscription.
+ * @return all Redis caches in the specified subscription as paginated response with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable list();
@@ -503,7 +506,7 @@ Response updateWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return all Redis caches in the specified subscription.
+ * @return all Redis caches in the specified subscription as paginated response with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable list(Context context);
@@ -516,7 +519,7 @@ Response updateWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return redis cache access keys.
+ * @return redis cache access keys along with {@link Response} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono> listKeysWithResponseAsync(String resourceGroupName, String name);
@@ -529,7 +532,7 @@ Response updateWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return redis cache access keys.
+ * @return redis cache access keys on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono listKeysAsync(String resourceGroupName, String name);
@@ -556,7 +559,7 @@ Response updateWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return redis cache access keys.
+ * @return redis cache access keys along with {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Response listKeysWithResponse(String resourceGroupName, String name, Context context);
@@ -570,7 +573,7 @@ Response updateWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return redis cache access keys.
+ * @return redis cache access keys along with {@link Response} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono> regenerateKeyWithResponseAsync(
@@ -585,7 +588,7 @@ Mono> regenerateKeyWithResponseAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return redis cache access keys.
+ * @return redis cache access keys on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono regenerateKeyAsync(
@@ -615,7 +618,7 @@ Mono regenerateKeyAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return redis cache access keys.
+ * @return redis cache access keys along with {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Response regenerateKeyWithResponse(
@@ -631,7 +634,8 @@ Response regenerateKeyWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return response to force reboot for Redis cache.
+ * @return response to force reboot for Redis cache along with {@link Response} on successful completion of {@link
+ * Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono> forceRebootWithResponseAsync(
@@ -647,7 +651,7 @@ Mono> forceRebootWithResponseAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return response to force reboot for Redis cache.
+ * @return response to force reboot for Redis cache on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono forceRebootAsync(
@@ -679,7 +683,7 @@ Mono forceRebootAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return response to force reboot for Redis cache.
+ * @return response to force reboot for Redis cache along with {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Response forceRebootWithResponse(
@@ -694,7 +698,7 @@ Response forceRebootWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link Response} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono>> importDataWithResponseAsync(
@@ -709,9 +713,9 @@ Mono>> importDataWithResponseAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link PollerFlux} for polling of long-running operation.
*/
- @ServiceMethod(returns = ReturnType.SINGLE)
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
PollerFlux, Void> beginImportDataAsync(
String resourceGroupName, String name, ImportRdbParameters parameters);
@@ -724,9 +728,9 @@ PollerFlux, Void> beginImportDataAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link SyncPoller} for polling of long-running operation.
*/
- @ServiceMethod(returns = ReturnType.SINGLE)
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, Void> beginImportData(
String resourceGroupName, String name, ImportRdbParameters parameters);
@@ -740,9 +744,9 @@ SyncPoller, Void> beginImportData(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link SyncPoller} for polling of long-running operation.
*/
- @ServiceMethod(returns = ReturnType.SINGLE)
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, Void> beginImportData(
String resourceGroupName, String name, ImportRdbParameters parameters, Context context);
@@ -755,7 +759,7 @@ SyncPoller, Void> beginImportData(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return A {@link Mono} that completes when a successful response is received.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono importDataAsync(String resourceGroupName, String name, ImportRdbParameters parameters);
@@ -796,7 +800,7 @@ SyncPoller, Void> beginImportData(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link Response} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono>> exportDataWithResponseAsync(
@@ -811,9 +815,9 @@ Mono>> exportDataWithResponseAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link PollerFlux} for polling of long-running operation.
*/
- @ServiceMethod(returns = ReturnType.SINGLE)
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
PollerFlux, Void> beginExportDataAsync(
String resourceGroupName, String name, ExportRdbParameters parameters);
@@ -826,9 +830,9 @@ PollerFlux, Void> beginExportDataAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link SyncPoller} for polling of long-running operation.
*/
- @ServiceMethod(returns = ReturnType.SINGLE)
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, Void> beginExportData(
String resourceGroupName, String name, ExportRdbParameters parameters);
@@ -842,9 +846,9 @@ SyncPoller, Void> beginExportData(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link SyncPoller} for polling of long-running operation.
*/
- @ServiceMethod(returns = ReturnType.SINGLE)
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller, Void> beginExportData(
String resourceGroupName, String name, ExportRdbParameters parameters, Context context);
@@ -857,7 +861,7 @@ SyncPoller, Void> beginExportData(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return A {@link Mono} that completes when a successful response is received.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Mono exportDataAsync(String resourceGroupName, String name, ExportRdbParameters parameters);
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/RedisManagementClient.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/RedisManagementClient.java
index 1e1ed262b97fc..86f609079acba 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/RedisManagementClient.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/RedisManagementClient.java
@@ -93,4 +93,11 @@ public interface RedisManagementClient {
* @return the PrivateLinkResourcesClient object.
*/
PrivateLinkResourcesClient getPrivateLinkResources();
+
+ /**
+ * Gets the AsyncOperationStatusClient object to access its operations.
+ *
+ * @return the AsyncOperationStatusClient object.
+ */
+ AsyncOperationStatusClient getAsyncOperationStatus();
}
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/OperationInner.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/OperationInner.java
index 8e94ffc2c008e..6da4252daf7f3 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/OperationInner.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/OperationInner.java
@@ -5,16 +5,12 @@
package com.azure.resourcemanager.redis.fluent.models;
import com.azure.core.annotation.Fluent;
-import com.azure.core.util.logging.ClientLogger;
import com.azure.resourcemanager.redis.models.OperationDisplay;
-import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonProperty;
/** REST API operation. */
@Fluent
public final class OperationInner {
- @JsonIgnore private final ClientLogger logger = new ClientLogger(OperationInner.class);
-
/*
* Operation name: {provider}/{resource}/{operation}
*/
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/OperationStatusInner.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/OperationStatusInner.java
new file mode 100644
index 0000000000000..124f04b22d48e
--- /dev/null
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/OperationStatusInner.java
@@ -0,0 +1,111 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) AutoRest Code Generator.
+
+package com.azure.resourcemanager.redis.fluent.models;
+
+import com.azure.core.annotation.Fluent;
+import com.azure.resourcemanager.redis.models.ErrorDetail;
+import com.azure.resourcemanager.redis.models.OperationStatusResult;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import java.time.OffsetDateTime;
+import java.util.List;
+import java.util.Map;
+
+/** Asynchronous operation status. */
+@Fluent
+public final class OperationStatusInner extends OperationStatusResult {
+ /*
+ * Additional properties from RP, only when operation is successful
+ */
+ @JsonProperty(value = "properties")
+ @JsonInclude(value = JsonInclude.Include.NON_NULL, content = JsonInclude.Include.ALWAYS)
+ private Map properties;
+
+ /**
+ * Get the properties property: Additional properties from RP, only when operation is successful.
+ *
+ * @return the properties value.
+ */
+ public Map properties() {
+ return this.properties;
+ }
+
+ /**
+ * Set the properties property: Additional properties from RP, only when operation is successful.
+ *
+ * @param properties the properties value to set.
+ * @return the OperationStatusInner object itself.
+ */
+ public OperationStatusInner withProperties(Map properties) {
+ this.properties = properties;
+ return this;
+ }
+
+ /** {@inheritDoc} */
+ @Override
+ public OperationStatusInner withId(String id) {
+ super.withId(id);
+ return this;
+ }
+
+ /** {@inheritDoc} */
+ @Override
+ public OperationStatusInner withName(String name) {
+ super.withName(name);
+ return this;
+ }
+
+ /** {@inheritDoc} */
+ @Override
+ public OperationStatusInner withStatus(String status) {
+ super.withStatus(status);
+ return this;
+ }
+
+ /** {@inheritDoc} */
+ @Override
+ public OperationStatusInner withPercentComplete(Float percentComplete) {
+ super.withPercentComplete(percentComplete);
+ return this;
+ }
+
+ /** {@inheritDoc} */
+ @Override
+ public OperationStatusInner withStartTime(OffsetDateTime startTime) {
+ super.withStartTime(startTime);
+ return this;
+ }
+
+ /** {@inheritDoc} */
+ @Override
+ public OperationStatusInner withEndTime(OffsetDateTime endTime) {
+ super.withEndTime(endTime);
+ return this;
+ }
+
+ /** {@inheritDoc} */
+ @Override
+ public OperationStatusInner withOperations(List operations) {
+ super.withOperations(operations);
+ return this;
+ }
+
+ /** {@inheritDoc} */
+ @Override
+ public OperationStatusInner withError(ErrorDetail error) {
+ super.withError(error);
+ return this;
+ }
+
+ /**
+ * Validates the instance.
+ *
+ * @throws IllegalArgumentException thrown if the instance is not valid.
+ */
+ @Override
+ public void validate() {
+ super.validate();
+ }
+}
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/PrivateEndpointConnectionInner.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/PrivateEndpointConnectionInner.java
index 23803373326e9..8021c7eb7004f 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/PrivateEndpointConnectionInner.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/PrivateEndpointConnectionInner.java
@@ -6,18 +6,14 @@
import com.azure.core.annotation.Fluent;
import com.azure.core.management.ProxyResource;
-import com.azure.core.util.logging.ClientLogger;
import com.azure.resourcemanager.redis.models.PrivateEndpoint;
import com.azure.resourcemanager.redis.models.PrivateEndpointConnectionProvisioningState;
import com.azure.resourcemanager.redis.models.PrivateLinkServiceConnectionState;
-import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonProperty;
/** The Private Endpoint Connection resource. */
@Fluent
public final class PrivateEndpointConnectionInner extends ProxyResource {
- @JsonIgnore private final ClientLogger logger = new ClientLogger(PrivateEndpointConnectionInner.class);
-
/*
* Resource properties.
*/
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/PrivateEndpointConnectionProperties.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/PrivateEndpointConnectionProperties.java
index 0db6937abbe83..d75db43cc0965 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/PrivateEndpointConnectionProperties.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/PrivateEndpointConnectionProperties.java
@@ -9,14 +9,11 @@
import com.azure.resourcemanager.redis.models.PrivateEndpoint;
import com.azure.resourcemanager.redis.models.PrivateEndpointConnectionProvisioningState;
import com.azure.resourcemanager.redis.models.PrivateLinkServiceConnectionState;
-import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonProperty;
/** Properties of the PrivateEndpointConnectProperties. */
@Fluent
public final class PrivateEndpointConnectionProperties {
- @JsonIgnore private final ClientLogger logger = new ClientLogger(PrivateEndpointConnectionProperties.class);
-
/*
* The resource of private end point.
*/
@@ -98,7 +95,7 @@ public void validate() {
privateEndpoint().validate();
}
if (privateLinkServiceConnectionState() == null) {
- throw logger
+ throw LOGGER
.logExceptionAsError(
new IllegalArgumentException(
"Missing required property privateLinkServiceConnectionState in model"
@@ -107,4 +104,6 @@ public void validate() {
privateLinkServiceConnectionState().validate();
}
}
+
+ private static final ClientLogger LOGGER = new ClientLogger(PrivateEndpointConnectionProperties.class);
}
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/PrivateLinkResourceInner.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/PrivateLinkResourceInner.java
index 2929661375542..edd58773cb956 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/PrivateLinkResourceInner.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/PrivateLinkResourceInner.java
@@ -6,16 +6,12 @@
import com.azure.core.annotation.Fluent;
import com.azure.core.management.ProxyResource;
-import com.azure.core.util.logging.ClientLogger;
-import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonProperty;
import java.util.List;
/** A private link resource. */
@Fluent
public final class PrivateLinkResourceInner extends ProxyResource {
- @JsonIgnore private final ClientLogger logger = new ClientLogger(PrivateLinkResourceInner.class);
-
/*
* Resource properties.
*/
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/PrivateLinkResourceProperties.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/PrivateLinkResourceProperties.java
index ea87e1f5db6fa..719ee86e15315 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/PrivateLinkResourceProperties.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/PrivateLinkResourceProperties.java
@@ -5,16 +5,12 @@
package com.azure.resourcemanager.redis.fluent.models;
import com.azure.core.annotation.Fluent;
-import com.azure.core.util.logging.ClientLogger;
-import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonProperty;
import java.util.List;
/** Properties of a private link resource. */
@Fluent
public final class PrivateLinkResourceProperties {
- @JsonIgnore private final ClientLogger logger = new ClientLogger(PrivateLinkResourceProperties.class);
-
/*
* The private link resource group id.
*/
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisAccessKeysInner.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisAccessKeysInner.java
index 58993cfeb4ec5..d3ae77f37473d 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisAccessKeysInner.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisAccessKeysInner.java
@@ -5,15 +5,11 @@
package com.azure.resourcemanager.redis.fluent.models;
import com.azure.core.annotation.Immutable;
-import com.azure.core.util.logging.ClientLogger;
-import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonProperty;
/** Redis cache access keys. */
@Immutable
public final class RedisAccessKeysInner {
- @JsonIgnore private final ClientLogger logger = new ClientLogger(RedisAccessKeysInner.class);
-
/*
* The current primary key that clients can use to authenticate with Redis
* cache.
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisCreateProperties.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisCreateProperties.java
index 0eb6caa136018..02a49741c1170 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisCreateProperties.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisCreateProperties.java
@@ -8,17 +8,15 @@
import com.azure.core.util.logging.ClientLogger;
import com.azure.resourcemanager.redis.models.PublicNetworkAccess;
import com.azure.resourcemanager.redis.models.RedisCommonProperties;
+import com.azure.resourcemanager.redis.models.RedisCommonPropertiesRedisConfiguration;
import com.azure.resourcemanager.redis.models.Sku;
import com.azure.resourcemanager.redis.models.TlsVersion;
-import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonProperty;
import java.util.Map;
/** Properties supplied to Create Redis operation. */
@Fluent
public class RedisCreateProperties extends RedisCommonProperties {
- @JsonIgnore private final ClientLogger logger = new ClientLogger(RedisCreateProperties.class);
-
/*
* The SKU of the Redis cache to deploy.
*/
@@ -34,8 +32,9 @@ public class RedisCreateProperties extends RedisCommonProperties {
private String subnetId;
/*
- * Static IP address. Required when deploying a Redis cache inside an
- * existing Azure Virtual Network.
+ * Static IP address. Optionally, may be specified when deploying a Redis
+ * cache inside an existing Azure Virtual Network; auto assigned by
+ * default.
*/
@JsonProperty(value = "staticIP")
private String staticIp;
@@ -85,8 +84,8 @@ public RedisCreateProperties withSubnetId(String subnetId) {
}
/**
- * Get the staticIp property: Static IP address. Required when deploying a Redis cache inside an existing Azure
- * Virtual Network.
+ * Get the staticIp property: Static IP address. Optionally, may be specified when deploying a Redis cache inside an
+ * existing Azure Virtual Network; auto assigned by default.
*
* @return the staticIp value.
*/
@@ -95,8 +94,8 @@ public String staticIp() {
}
/**
- * Set the staticIp property: Static IP address. Required when deploying a Redis cache inside an existing Azure
- * Virtual Network.
+ * Set the staticIp property: Static IP address. Optionally, may be specified when deploying a Redis cache inside an
+ * existing Azure Virtual Network; auto assigned by default.
*
* @param staticIp the staticIp value to set.
* @return the RedisCreateProperties object itself.
@@ -108,7 +107,7 @@ public RedisCreateProperties withStaticIp(String staticIp) {
/** {@inheritDoc} */
@Override
- public RedisCreateProperties withRedisConfiguration(Map redisConfiguration) {
+ public RedisCreateProperties withRedisConfiguration(RedisCommonPropertiesRedisConfiguration redisConfiguration) {
super.withRedisConfiguration(redisConfiguration);
return this;
}
@@ -178,11 +177,13 @@ public RedisCreateProperties withPublicNetworkAccess(PublicNetworkAccess publicN
public void validate() {
super.validate();
if (sku() == null) {
- throw logger
+ throw LOGGER
.logExceptionAsError(
new IllegalArgumentException("Missing required property sku in model RedisCreateProperties"));
} else {
sku().validate();
}
}
+
+ private static final ClientLogger LOGGER = new ClientLogger(RedisCreateProperties.class);
}
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisFirewallRuleInner.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisFirewallRuleInner.java
index d536f3c95a782..e9da7ae04d186 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisFirewallRuleInner.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisFirewallRuleInner.java
@@ -7,7 +7,6 @@
import com.azure.core.annotation.Fluent;
import com.azure.core.management.ProxyResource;
import com.azure.core.util.logging.ClientLogger;
-import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonProperty;
/**
@@ -15,8 +14,6 @@
*/
@Fluent
public class RedisFirewallRuleInner extends ProxyResource {
- @JsonIgnore private final ClientLogger logger = new ClientLogger(RedisFirewallRuleInner.class);
-
/*
* redis cache firewall rule properties
*/
@@ -85,7 +82,7 @@ public RedisFirewallRuleInner withEndIp(String endIp) {
*/
public void validate() {
if (innerProperties() == null) {
- throw logger
+ throw LOGGER
.logExceptionAsError(
new IllegalArgumentException(
"Missing required property innerProperties in model RedisFirewallRuleInner"));
@@ -93,4 +90,6 @@ public void validate() {
innerProperties().validate();
}
}
+
+ private static final ClientLogger LOGGER = new ClientLogger(RedisFirewallRuleInner.class);
}
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisFirewallRuleProperties.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisFirewallRuleProperties.java
index 23c8622361a3b..5f1ee762b3a5a 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisFirewallRuleProperties.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisFirewallRuleProperties.java
@@ -6,14 +6,11 @@
import com.azure.core.annotation.Fluent;
import com.azure.core.util.logging.ClientLogger;
-import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonProperty;
/** Specifies a range of IP addresses permitted to connect to the cache. */
@Fluent
public final class RedisFirewallRuleProperties {
- @JsonIgnore private final ClientLogger logger = new ClientLogger(RedisFirewallRuleProperties.class);
-
/*
* lowest IP address included in the range
*/
@@ -73,16 +70,18 @@ public RedisFirewallRuleProperties withEndIp(String endIp) {
*/
public void validate() {
if (startIp() == null) {
- throw logger
+ throw LOGGER
.logExceptionAsError(
new IllegalArgumentException(
"Missing required property startIp in model RedisFirewallRuleProperties"));
}
if (endIp() == null) {
- throw logger
+ throw LOGGER
.logExceptionAsError(
new IllegalArgumentException(
"Missing required property endIp in model RedisFirewallRuleProperties"));
}
}
+
+ private static final ClientLogger LOGGER = new ClientLogger(RedisFirewallRuleProperties.class);
}
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisForceRebootResponseInner.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisForceRebootResponseInner.java
index d09312934545b..e76c4d5845eb9 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisForceRebootResponseInner.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisForceRebootResponseInner.java
@@ -5,15 +5,11 @@
package com.azure.resourcemanager.redis.fluent.models;
import com.azure.core.annotation.Immutable;
-import com.azure.core.util.logging.ClientLogger;
-import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonProperty;
/** Response to force reboot for Redis cache. */
@Immutable
public final class RedisForceRebootResponseInner {
- @JsonIgnore private final ClientLogger logger = new ClientLogger(RedisForceRebootResponseInner.class);
-
/*
* Status message
*/
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisLinkedServerCreateProperties.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisLinkedServerCreateProperties.java
index 89e9eabfa07fd..1d0cf33a7a80c 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisLinkedServerCreateProperties.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisLinkedServerCreateProperties.java
@@ -7,14 +7,11 @@
import com.azure.core.annotation.Fluent;
import com.azure.core.util.logging.ClientLogger;
import com.azure.resourcemanager.redis.models.ReplicationRole;
-import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonProperty;
/** Create properties for a linked server. */
@Fluent
public class RedisLinkedServerCreateProperties {
- @JsonIgnore private final ClientLogger logger = new ClientLogger(RedisLinkedServerCreateProperties.class);
-
/*
* Fully qualified resourceId of the linked redis cache.
*/
@@ -100,23 +97,25 @@ public RedisLinkedServerCreateProperties withServerRole(ReplicationRole serverRo
*/
public void validate() {
if (linkedRedisCacheId() == null) {
- throw logger
+ throw LOGGER
.logExceptionAsError(
new IllegalArgumentException(
"Missing required property linkedRedisCacheId in model RedisLinkedServerCreateProperties"));
}
if (linkedRedisCacheLocation() == null) {
- throw logger
+ throw LOGGER
.logExceptionAsError(
new IllegalArgumentException(
"Missing required property linkedRedisCacheLocation in model"
+ " RedisLinkedServerCreateProperties"));
}
if (serverRole() == null) {
- throw logger
+ throw LOGGER
.logExceptionAsError(
new IllegalArgumentException(
"Missing required property serverRole in model RedisLinkedServerCreateProperties"));
}
}
+
+ private static final ClientLogger LOGGER = new ClientLogger(RedisLinkedServerCreateProperties.class);
}
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisLinkedServerProperties.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisLinkedServerProperties.java
index b9249eabdfb0f..658a466eb4084 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisLinkedServerProperties.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisLinkedServerProperties.java
@@ -5,16 +5,12 @@
package com.azure.resourcemanager.redis.fluent.models;
import com.azure.core.annotation.Fluent;
-import com.azure.core.util.logging.ClientLogger;
import com.azure.resourcemanager.redis.models.ReplicationRole;
-import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonProperty;
/** Properties of a linked server to be returned in get/put response. */
@Fluent
public final class RedisLinkedServerProperties extends RedisLinkedServerCreateProperties {
- @JsonIgnore private final ClientLogger logger = new ClientLogger(RedisLinkedServerProperties.class);
-
/*
* Terminal state of the link between primary and secondary redis cache.
*/
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisLinkedServerWithPropertiesInner.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisLinkedServerWithPropertiesInner.java
index d8240769b0456..d5509689ad08e 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisLinkedServerWithPropertiesInner.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisLinkedServerWithPropertiesInner.java
@@ -6,16 +6,12 @@
import com.azure.core.annotation.Fluent;
import com.azure.core.management.ProxyResource;
-import com.azure.core.util.logging.ClientLogger;
import com.azure.resourcemanager.redis.models.ReplicationRole;
-import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonProperty;
/** Response to put/get linked server (with properties) for Redis cache. */
@Fluent
public final class RedisLinkedServerWithPropertiesInner extends ProxyResource {
- @JsonIgnore private final ClientLogger logger = new ClientLogger(RedisLinkedServerWithPropertiesInner.class);
-
/*
* Properties of the linked server.
*/
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisPatchScheduleInner.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisPatchScheduleInner.java
index 5a165ce264f2b..fe92a79a20b08 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisPatchScheduleInner.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisPatchScheduleInner.java
@@ -8,21 +8,24 @@
import com.azure.core.management.ProxyResource;
import com.azure.core.util.logging.ClientLogger;
import com.azure.resourcemanager.redis.models.ScheduleEntry;
-import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonProperty;
import java.util.List;
/** Response to put/get patch schedules for Redis cache. */
@Fluent
public final class RedisPatchScheduleInner extends ProxyResource {
- @JsonIgnore private final ClientLogger logger = new ClientLogger(RedisPatchScheduleInner.class);
-
/*
* List of patch schedules for a Redis cache.
*/
@JsonProperty(value = "properties", required = true)
private ScheduleEntries innerProperties = new ScheduleEntries();
+ /*
+ * The geo-location where the resource lives
+ */
+ @JsonProperty(value = "location", access = JsonProperty.Access.WRITE_ONLY)
+ private String location;
+
/**
* Get the innerProperties property: List of patch schedules for a Redis cache.
*
@@ -32,6 +35,15 @@ private ScheduleEntries innerProperties() {
return this.innerProperties;
}
+ /**
+ * Get the location property: The geo-location where the resource lives.
+ *
+ * @return the location value.
+ */
+ public String location() {
+ return this.location;
+ }
+
/**
* Get the scheduleEntries property: List of patch schedules for a Redis cache.
*
@@ -62,7 +74,7 @@ public RedisPatchScheduleInner withScheduleEntries(List scheduleE
*/
public void validate() {
if (innerProperties() == null) {
- throw logger
+ throw LOGGER
.logExceptionAsError(
new IllegalArgumentException(
"Missing required property innerProperties in model RedisPatchScheduleInner"));
@@ -70,4 +82,6 @@ public void validate() {
innerProperties().validate();
}
}
+
+ private static final ClientLogger LOGGER = new ClientLogger(RedisPatchScheduleInner.class);
}
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisPropertiesInner.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisPropertiesInner.java
index d4fee19b7caa0..1b116fba01c4f 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisPropertiesInner.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisPropertiesInner.java
@@ -5,14 +5,13 @@
package com.azure.resourcemanager.redis.fluent.models;
import com.azure.core.annotation.Fluent;
-import com.azure.core.util.logging.ClientLogger;
import com.azure.resourcemanager.redis.models.ProvisioningState;
import com.azure.resourcemanager.redis.models.PublicNetworkAccess;
+import com.azure.resourcemanager.redis.models.RedisCommonPropertiesRedisConfiguration;
import com.azure.resourcemanager.redis.models.RedisInstanceDetails;
import com.azure.resourcemanager.redis.models.RedisLinkedServer;
import com.azure.resourcemanager.redis.models.Sku;
import com.azure.resourcemanager.redis.models.TlsVersion;
-import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonProperty;
import java.util.List;
import java.util.Map;
@@ -20,8 +19,6 @@
/** Properties of the redis cache. */
@Fluent
public final class RedisPropertiesInner extends RedisCreateProperties {
- @JsonIgnore private final ClientLogger logger = new ClientLogger(RedisPropertiesInner.class);
-
/*
* Redis instance provisioning status.
*/
@@ -169,7 +166,7 @@ public RedisPropertiesInner withStaticIp(String staticIp) {
/** {@inheritDoc} */
@Override
- public RedisPropertiesInner withRedisConfiguration(Map redisConfiguration) {
+ public RedisPropertiesInner withRedisConfiguration(RedisCommonPropertiesRedisConfiguration redisConfiguration) {
super.withRedisConfiguration(redisConfiguration);
return this;
}
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisResourceInner.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisResourceInner.java
index 23a4c564f8efc..d2153994c8abb 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisResourceInner.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisResourceInner.java
@@ -7,13 +7,14 @@
import com.azure.core.annotation.Fluent;
import com.azure.core.management.Resource;
import com.azure.core.util.logging.ClientLogger;
+import com.azure.resourcemanager.redis.models.ManagedServiceIdentity;
import com.azure.resourcemanager.redis.models.ProvisioningState;
import com.azure.resourcemanager.redis.models.PublicNetworkAccess;
+import com.azure.resourcemanager.redis.models.RedisCommonPropertiesRedisConfiguration;
import com.azure.resourcemanager.redis.models.RedisInstanceDetails;
import com.azure.resourcemanager.redis.models.RedisLinkedServer;
import com.azure.resourcemanager.redis.models.Sku;
import com.azure.resourcemanager.redis.models.TlsVersion;
-import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonProperty;
import java.util.List;
import java.util.Map;
@@ -21,8 +22,6 @@
/** A single Redis item in List or Get Operation. */
@Fluent
public final class RedisResourceInner extends Resource {
- @JsonIgnore private final ClientLogger logger = new ClientLogger(RedisResourceInner.class);
-
/*
* Redis cache properties.
*/
@@ -36,6 +35,12 @@ public final class RedisResourceInner extends Resource {
@JsonProperty(value = "zones")
private List zones;
+ /*
+ * The identity of the resource.
+ */
+ @JsonProperty(value = "identity")
+ private ManagedServiceIdentity identity;
+
/**
* Get the innerProperties property: Redis cache properties.
*
@@ -65,6 +70,26 @@ public RedisResourceInner withZones(List zones) {
return this;
}
+ /**
+ * Get the identity property: The identity of the resource.
+ *
+ * @return the identity value.
+ */
+ public ManagedServiceIdentity identity() {
+ return this.identity;
+ }
+
+ /**
+ * Set the identity property: The identity of the resource.
+ *
+ * @param identity the identity value to set.
+ * @return the RedisResourceInner object itself.
+ */
+ public RedisResourceInner withIdentity(ManagedServiceIdentity identity) {
+ this.identity = identity;
+ return this;
+ }
+
/** {@inheritDoc} */
@Override
public RedisResourceInner withLocation(String location) {
@@ -204,8 +229,8 @@ public RedisResourceInner withSubnetId(String subnetId) {
}
/**
- * Get the staticIp property: Static IP address. Required when deploying a Redis cache inside an existing Azure
- * Virtual Network.
+ * Get the staticIp property: Static IP address. Optionally, may be specified when deploying a Redis cache inside an
+ * existing Azure Virtual Network; auto assigned by default.
*
* @return the staticIp value.
*/
@@ -214,8 +239,8 @@ public String staticIp() {
}
/**
- * Set the staticIp property: Static IP address. Required when deploying a Redis cache inside an existing Azure
- * Virtual Network.
+ * Set the staticIp property: Static IP address. Optionally, may be specified when deploying a Redis cache inside an
+ * existing Azure Virtual Network; auto assigned by default.
*
* @param staticIp the staticIp value to set.
* @return the RedisResourceInner object itself.
@@ -235,7 +260,7 @@ public RedisResourceInner withStaticIp(String staticIp) {
*
* @return the redisConfiguration value.
*/
- public Map redisConfiguration() {
+ public RedisCommonPropertiesRedisConfiguration redisConfiguration() {
return this.innerProperties() == null ? null : this.innerProperties().redisConfiguration();
}
@@ -247,7 +272,7 @@ public Map redisConfiguration() {
* @param redisConfiguration the redisConfiguration value to set.
* @return the RedisResourceInner object itself.
*/
- public RedisResourceInner withRedisConfiguration(Map redisConfiguration) {
+ public RedisResourceInner withRedisConfiguration(RedisCommonPropertiesRedisConfiguration redisConfiguration) {
if (this.innerProperties() == null) {
this.innerProperties = new RedisPropertiesInner();
}
@@ -454,12 +479,17 @@ public RedisResourceInner withPublicNetworkAccess(PublicNetworkAccess publicNetw
*/
public void validate() {
if (innerProperties() == null) {
- throw logger
+ throw LOGGER
.logExceptionAsError(
new IllegalArgumentException(
"Missing required property innerProperties in model RedisResourceInner"));
} else {
innerProperties().validate();
}
+ if (identity() != null) {
+ identity().validate();
+ }
}
+
+ private static final ClientLogger LOGGER = new ClientLogger(RedisResourceInner.class);
}
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisUpdateProperties.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisUpdateProperties.java
index f40c9ca6d8132..f0ec4c8fdba7a 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisUpdateProperties.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/RedisUpdateProperties.java
@@ -5,20 +5,17 @@
package com.azure.resourcemanager.redis.fluent.models;
import com.azure.core.annotation.Fluent;
-import com.azure.core.util.logging.ClientLogger;
import com.azure.resourcemanager.redis.models.PublicNetworkAccess;
import com.azure.resourcemanager.redis.models.RedisCommonProperties;
+import com.azure.resourcemanager.redis.models.RedisCommonPropertiesRedisConfiguration;
import com.azure.resourcemanager.redis.models.Sku;
import com.azure.resourcemanager.redis.models.TlsVersion;
-import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonProperty;
import java.util.Map;
/** Patchable properties of the redis cache. */
@Fluent
public final class RedisUpdateProperties extends RedisCommonProperties {
- @JsonIgnore private final ClientLogger logger = new ClientLogger(RedisUpdateProperties.class);
-
/*
* The SKU of the Redis cache to deploy.
*/
@@ -47,7 +44,7 @@ public RedisUpdateProperties withSku(Sku sku) {
/** {@inheritDoc} */
@Override
- public RedisUpdateProperties withRedisConfiguration(Map redisConfiguration) {
+ public RedisUpdateProperties withRedisConfiguration(RedisCommonPropertiesRedisConfiguration redisConfiguration) {
super.withRedisConfiguration(redisConfiguration);
return this;
}
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/ScheduleEntries.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/ScheduleEntries.java
index 5e336cc7d8e89..44a2d617ef446 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/ScheduleEntries.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/ScheduleEntries.java
@@ -7,15 +7,12 @@
import com.azure.core.annotation.Fluent;
import com.azure.core.util.logging.ClientLogger;
import com.azure.resourcemanager.redis.models.ScheduleEntry;
-import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonProperty;
import java.util.List;
/** List of patch schedules for a Redis cache. */
@Fluent
public final class ScheduleEntries {
- @JsonIgnore private final ClientLogger logger = new ClientLogger(ScheduleEntries.class);
-
/*
* List of patch schedules for a Redis cache.
*/
@@ -49,11 +46,13 @@ public ScheduleEntries withScheduleEntries(List scheduleEntries)
*/
public void validate() {
if (scheduleEntries() == null) {
- throw logger
+ throw LOGGER
.logExceptionAsError(
new IllegalArgumentException("Missing required property scheduleEntries in model ScheduleEntries"));
} else {
scheduleEntries().forEach(e -> e.validate());
}
}
+
+ private static final ClientLogger LOGGER = new ClientLogger(ScheduleEntries.class);
}
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/UpgradeNotificationInner.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/UpgradeNotificationInner.java
index ff6132553f458..d276e148fcc3b 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/UpgradeNotificationInner.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/fluent/models/UpgradeNotificationInner.java
@@ -5,8 +5,6 @@
package com.azure.resourcemanager.redis.fluent.models;
import com.azure.core.annotation.Immutable;
-import com.azure.core.util.logging.ClientLogger;
-import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.annotation.JsonProperty;
import java.time.OffsetDateTime;
@@ -15,8 +13,6 @@
/** Properties of upgrade notification. */
@Immutable
public final class UpgradeNotificationInner {
- @JsonIgnore private final ClientLogger logger = new ClientLogger(UpgradeNotificationInner.class);
-
/*
* Name of upgrade notification.
*/
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/implementation/AsyncOperationStatusClientImpl.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/implementation/AsyncOperationStatusClientImpl.java
new file mode 100644
index 0000000000000..ee6bc55c79647
--- /dev/null
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/implementation/AsyncOperationStatusClientImpl.java
@@ -0,0 +1,215 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) AutoRest Code Generator.
+
+package com.azure.resourcemanager.redis.implementation;
+
+import com.azure.core.annotation.ExpectedResponses;
+import com.azure.core.annotation.Get;
+import com.azure.core.annotation.HeaderParam;
+import com.azure.core.annotation.Headers;
+import com.azure.core.annotation.Host;
+import com.azure.core.annotation.HostParam;
+import com.azure.core.annotation.PathParam;
+import com.azure.core.annotation.QueryParam;
+import com.azure.core.annotation.ReturnType;
+import com.azure.core.annotation.ServiceInterface;
+import com.azure.core.annotation.ServiceMethod;
+import com.azure.core.annotation.UnexpectedResponseExceptionType;
+import com.azure.core.http.rest.Response;
+import com.azure.core.http.rest.RestProxy;
+import com.azure.core.management.exception.ManagementException;
+import com.azure.core.util.Context;
+import com.azure.core.util.FluxUtil;
+import com.azure.resourcemanager.redis.fluent.AsyncOperationStatusClient;
+import com.azure.resourcemanager.redis.fluent.models.OperationStatusInner;
+import reactor.core.publisher.Mono;
+
+/** An instance of this class provides access to all the operations defined in AsyncOperationStatusClient. */
+public final class AsyncOperationStatusClientImpl implements AsyncOperationStatusClient {
+ /** The proxy service used to perform REST calls. */
+ private final AsyncOperationStatusService service;
+
+ /** The service client containing this operation class. */
+ private final RedisManagementClientImpl client;
+
+ /**
+ * Initializes an instance of AsyncOperationStatusClientImpl.
+ *
+ * @param client the instance of the service client containing this operation class.
+ */
+ AsyncOperationStatusClientImpl(RedisManagementClientImpl client) {
+ this.service =
+ RestProxy
+ .create(AsyncOperationStatusService.class, client.getHttpPipeline(), client.getSerializerAdapter());
+ this.client = client;
+ }
+
+ /**
+ * The interface defining all the services for RedisManagementClientAsyncOperationStatus to be used by the proxy
+ * service to perform REST calls.
+ */
+ @Host("{$host}")
+ @ServiceInterface(name = "RedisManagementClien")
+ private interface AsyncOperationStatusService {
+ @Headers({"Content-Type: application/json"})
+ @Get(
+ "/subscriptions/{subscriptionId}/providers/Microsoft.Cache/locations/{location}/asyncOperations"
+ + "/{operationId}")
+ @ExpectedResponses({200})
+ @UnexpectedResponseExceptionType(ManagementException.class)
+ Mono> get(
+ @HostParam("$host") String endpoint,
+ @PathParam("location") String location,
+ @PathParam("operationId") String operationId,
+ @QueryParam("api-version") String apiVersion,
+ @PathParam("subscriptionId") String subscriptionId,
+ @HeaderParam("Accept") String accept,
+ Context context);
+ }
+
+ /**
+ * For checking the ongoing status of an operation.
+ *
+ * @param location The location at which operation was triggered.
+ * @param operationId The ID of asynchronous operation.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws ManagementException thrown if the request is rejected by server.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return asynchronous operation status along with {@link Response} on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> getWithResponseAsync(String location, String operationId) {
+ if (this.client.getEndpoint() == null) {
+ return Mono
+ .error(
+ new IllegalArgumentException(
+ "Parameter this.client.getEndpoint() is required and cannot be null."));
+ }
+ if (location == null) {
+ return Mono.error(new IllegalArgumentException("Parameter location is required and cannot be null."));
+ }
+ if (operationId == null) {
+ return Mono.error(new IllegalArgumentException("Parameter operationId is required and cannot be null."));
+ }
+ if (this.client.getSubscriptionId() == null) {
+ return Mono
+ .error(
+ new IllegalArgumentException(
+ "Parameter this.client.getSubscriptionId() is required and cannot be null."));
+ }
+ final String accept = "application/json";
+ return FluxUtil
+ .withContext(
+ context ->
+ service
+ .get(
+ this.client.getEndpoint(),
+ location,
+ operationId,
+ this.client.getApiVersion(),
+ this.client.getSubscriptionId(),
+ accept,
+ context))
+ .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
+ }
+
+ /**
+ * For checking the ongoing status of an operation.
+ *
+ * @param location The location at which operation was triggered.
+ * @param operationId The ID of asynchronous operation.
+ * @param context The context to associate with this operation.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws ManagementException thrown if the request is rejected by server.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return asynchronous operation status along with {@link Response} on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private Mono> getWithResponseAsync(
+ String location, String operationId, Context context) {
+ if (this.client.getEndpoint() == null) {
+ return Mono
+ .error(
+ new IllegalArgumentException(
+ "Parameter this.client.getEndpoint() is required and cannot be null."));
+ }
+ if (location == null) {
+ return Mono.error(new IllegalArgumentException("Parameter location is required and cannot be null."));
+ }
+ if (operationId == null) {
+ return Mono.error(new IllegalArgumentException("Parameter operationId is required and cannot be null."));
+ }
+ if (this.client.getSubscriptionId() == null) {
+ return Mono
+ .error(
+ new IllegalArgumentException(
+ "Parameter this.client.getSubscriptionId() is required and cannot be null."));
+ }
+ final String accept = "application/json";
+ context = this.client.mergeContext(context);
+ return service
+ .get(
+ this.client.getEndpoint(),
+ location,
+ operationId,
+ this.client.getApiVersion(),
+ this.client.getSubscriptionId(),
+ accept,
+ context);
+ }
+
+ /**
+ * For checking the ongoing status of an operation.
+ *
+ * @param location The location at which operation was triggered.
+ * @param operationId The ID of asynchronous operation.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws ManagementException thrown if the request is rejected by server.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return asynchronous operation status on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono getAsync(String location, String operationId) {
+ return getWithResponseAsync(location, operationId)
+ .flatMap(
+ (Response res) -> {
+ if (res.getValue() != null) {
+ return Mono.just(res.getValue());
+ } else {
+ return Mono.empty();
+ }
+ });
+ }
+
+ /**
+ * For checking the ongoing status of an operation.
+ *
+ * @param location The location at which operation was triggered.
+ * @param operationId The ID of asynchronous operation.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws ManagementException thrown if the request is rejected by server.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return asynchronous operation status.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public OperationStatusInner get(String location, String operationId) {
+ return getAsync(location, operationId).block();
+ }
+
+ /**
+ * For checking the ongoing status of an operation.
+ *
+ * @param location The location at which operation was triggered.
+ * @param operationId The ID of asynchronous operation.
+ * @param context The context to associate with this operation.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws ManagementException thrown if the request is rejected by server.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return asynchronous operation status along with {@link Response}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response getWithResponse(String location, String operationId, Context context) {
+ return getWithResponseAsync(location, operationId, context).block();
+ }
+}
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/implementation/ConfigurationUtils.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/implementation/ConfigurationUtils.java
new file mode 100644
index 0000000000000..57ba46e46f59a
--- /dev/null
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/implementation/ConfigurationUtils.java
@@ -0,0 +1,160 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+
+package com.azure.resourcemanager.redis.implementation;
+
+import com.azure.resourcemanager.redis.models.RedisCommonPropertiesRedisConfiguration;
+
+import java.util.HashMap;
+import java.util.Map;
+
+class ConfigurationUtils {
+
+ static RedisCommonPropertiesRedisConfiguration toConfiguration(Map configuration) {
+ RedisCommonPropertiesRedisConfiguration c = new RedisCommonPropertiesRedisConfiguration();
+ if (configuration != null) {
+ configuration.forEach((k, v) -> putConfiguration(c, k, v));
+ }
+ return c;
+ }
+
+ static Map toMap(RedisCommonPropertiesRedisConfiguration configuration) {
+ Map map = new HashMap<>();
+ if (configuration != null) {
+ if (configuration.maxmemoryPolicy() != null) {
+ map.put("maxmemory-policy", configuration.maxmemoryPolicy());
+ }
+ if (configuration.rdbBackupEnabled() != null) {
+ map.put("rdb-backup-enabled", configuration.rdbBackupEnabled());
+ }
+ if (configuration.preferredDataPersistenceAuthMethod() != null) {
+ map.put("preferred-data-persistence-auth-method", configuration.preferredDataPersistenceAuthMethod());
+ }
+ if (configuration.rdbBackupMaxSnapshotCount() != null) {
+ map.put("rdb-backup-max-snapshot-count", configuration.rdbBackupMaxSnapshotCount());
+ }
+ if (configuration.aofStorageConnectionString0() != null) {
+ map.put("aof-storage-connection-string-0", configuration.aofStorageConnectionString0());
+ }
+ if (configuration.aofStorageConnectionString1() != null) {
+ map.put("aof-storage-connection-string-1", configuration.aofStorageConnectionString1());
+ }
+ if (configuration.maxclients() != null) {
+ map.put("maxclients", configuration.maxclients());
+ }
+ if (configuration.rdbStorageConnectionString() != null) {
+ map.put("rdb-storage-connection-string", configuration.rdbStorageConnectionString());
+ }
+ if (configuration.maxmemoryDelta() != null) {
+ map.put("maxmemory-delta", configuration.maxmemoryDelta());
+ }
+ if (configuration.maxfragmentationmemoryReserved() != null) {
+ map.put("maxfragmentationmemory-reserved", configuration.maxfragmentationmemoryReserved());
+ }
+ if (configuration.maxmemoryReserved() != null) {
+ map.put("maxmemory-reserved", configuration.maxmemoryReserved());
+ }
+ if (configuration.preferredDataArchiveAuthMethod() != null) {
+ map.put("preferred-data-archive-auth-method", configuration.preferredDataArchiveAuthMethod());
+ }
+ if (configuration.zonalConfiguration() != null) {
+ map.put("zonal-configuration", configuration.zonalConfiguration());
+ }
+ if (configuration.rdbBackupFrequency() != null) {
+ map.put("rdb-backup-frequency", configuration.rdbBackupFrequency());
+ }
+ if (configuration.additionalProperties() != null) {
+ configuration.additionalProperties().forEach((key1, value) -> map.put(key1, value.toString()));
+ }
+ }
+ return map;
+ }
+
+ static void putConfiguration(RedisCommonPropertiesRedisConfiguration configuration,
+ String key, String value) {
+ if (configuration == null) {
+ return;
+ }
+ switch (key) {
+ case "rdb-storage-connection-string":
+ configuration.withRdbStorageConnectionString(value);
+ break;
+ case "maxmemory-policy":
+ configuration.withMaxmemoryPolicy(value);
+ break;
+ case "maxmemory-delta":
+ configuration.withMaxmemoryDelta(value);
+ break;
+ case "rdb-backup-enabled":
+ configuration.withRdbBackupEnabled(value);
+ break;
+ case "maxfragmentationmemory-reserved":
+ configuration.withMaxfragmentationmemoryReserved(value);
+ break;
+ case "maxmemory-reserved":
+ configuration.withMaxmemoryReserved(value);
+ break;
+ case "rdb-backup-frequency":
+ configuration.withRdbBackupFrequency(value);
+ break;
+ case "rdb-backup-max-snapshot-count":
+ configuration.withRdbBackupMaxSnapshotCount(value);
+ break;
+ case "aof-storage-connection-string-0":
+ configuration.withAofStorageConnectionString0(value);
+ break;
+ case "aof-storage-connection-string-1":
+ configuration.withAofStorageConnectionString1(value);
+ break;
+ default:
+ if (configuration.additionalProperties() == null) {
+ configuration.withAdditionalProperties(new HashMap<>());
+ }
+ configuration.additionalProperties().put(key, value);
+ break;
+ }
+ }
+
+ static void removeConfiguration(RedisCommonPropertiesRedisConfiguration configuration, String key) {
+ if (configuration == null) {
+ return;
+ }
+ if (configuration.additionalProperties() != null) {
+ configuration.additionalProperties().remove(key);
+ }
+ switch (key) {
+ case "rdb-storage-connection-string":
+ configuration.withRdbStorageConnectionString(null);
+ break;
+ case "maxmemory-policy":
+ configuration.withMaxmemoryPolicy(null);
+ break;
+ case "maxmemory-delta":
+ configuration.withMaxmemoryDelta(null);
+ break;
+ case "rdb-backup-enabled":
+ configuration.withRdbBackupEnabled(null);
+ break;
+ case "maxfragmentationmemory-reserved":
+ configuration.withMaxfragmentationmemoryReserved(null);
+ break;
+ case "maxmemory-reserved":
+ configuration.withMaxmemoryReserved(null);
+ break;
+ case "rdb-backup-frequency":
+ configuration.withRdbBackupFrequency(null);
+ break;
+ case "rdb-backup-max-snapshot-count":
+ configuration.withRdbBackupMaxSnapshotCount(null);
+ break;
+ case "aof-storage-connection-string-0":
+ configuration.withAofStorageConnectionString0(null);
+ break;
+ case "aof-storage-connection-string-1":
+ configuration.withAofStorageConnectionString1(null);
+ break;
+ default:
+ break;
+ }
+ }
+}
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/implementation/FirewallRulesClientImpl.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/implementation/FirewallRulesClientImpl.java
index 798c4d9227576..c446a8490cd9d 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/implementation/FirewallRulesClientImpl.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/implementation/FirewallRulesClientImpl.java
@@ -28,7 +28,6 @@
import com.azure.core.management.exception.ManagementException;
import com.azure.core.util.Context;
import com.azure.core.util.FluxUtil;
-import com.azure.core.util.logging.ClientLogger;
import com.azure.resourcemanager.redis.fluent.FirewallRulesClient;
import com.azure.resourcemanager.redis.fluent.models.RedisFirewallRuleInner;
import com.azure.resourcemanager.redis.models.RedisFirewallRuleListResult;
@@ -36,8 +35,6 @@
/** An instance of this class provides access to all the operations defined in FirewallRulesClient. */
public final class FirewallRulesClientImpl implements FirewallRulesClient {
- private final ClientLogger logger = new ClientLogger(FirewallRulesClientImpl.class);
-
/** The proxy service used to perform REST calls. */
private final FirewallRulesService service;
@@ -145,7 +142,8 @@ Mono> listNext(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return all firewall rules in the specified redis cache.
+ * @return all firewall rules in the specified redis cache along with {@link PagedResponse} on successful completion
+ * of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono> listSinglePageAsync(
@@ -203,7 +201,8 @@ private Mono> listSinglePageAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return all firewall rules in the specified redis cache.
+ * @return all firewall rules in the specified redis cache along with {@link PagedResponse} on successful completion
+ * of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono> listSinglePageAsync(
@@ -257,7 +256,7 @@ private Mono> listSinglePageAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return all firewall rules in the specified redis cache.
+ * @return all firewall rules in the specified redis cache as paginated response with {@link PagedFlux}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedFlux listAsync(String resourceGroupName, String cacheName) {
@@ -274,7 +273,7 @@ public PagedFlux listAsync(String resourceGroupName, Str
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return all firewall rules in the specified redis cache.
+ * @return all firewall rules in the specified redis cache as paginated response with {@link PagedFlux}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
private PagedFlux listAsync(String resourceGroupName, String cacheName, Context context) {
@@ -291,7 +290,7 @@ private PagedFlux listAsync(String resourceGroupName, St
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return all firewall rules in the specified redis cache.
+ * @return all firewall rules in the specified redis cache as paginated response with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedIterable list(String resourceGroupName, String cacheName) {
@@ -307,7 +306,7 @@ public PagedIterable list(String resourceGroupName, Stri
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return all firewall rules in the specified redis cache.
+ * @return all firewall rules in the specified redis cache as paginated response with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedIterable list(String resourceGroupName, String cacheName, Context context) {
@@ -325,7 +324,7 @@ public PagedIterable list(String resourceGroupName, Stri
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return a firewall rule on a redis cache has a name, and describes a contiguous range of IP addresses permitted
- * to connect.
+ * to connect along with {@link Response} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono> createOrUpdateWithResponseAsync(
@@ -387,7 +386,7 @@ public Mono> createOrUpdateWithResponseAsync(
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return a firewall rule on a redis cache has a name, and describes a contiguous range of IP addresses permitted
- * to connect.
+ * to connect along with {@link Response} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono> createOrUpdateWithResponseAsync(
@@ -449,7 +448,7 @@ private Mono> createOrUpdateWithResponseAsync(
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return a firewall rule on a redis cache has a name, and describes a contiguous range of IP addresses permitted
- * to connect.
+ * to connect on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono createOrUpdateAsync(
@@ -496,7 +495,7 @@ public RedisFirewallRuleInner createOrUpdate(
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return a firewall rule on a redis cache has a name, and describes a contiguous range of IP addresses permitted
- * to connect.
+ * to connect along with {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Response createOrUpdateWithResponse(
@@ -517,7 +516,8 @@ public Response createOrUpdateWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a single firewall rule in a specified redis cache.
+ * @return a single firewall rule in a specified redis cache along with {@link Response} on successful completion of
+ * {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono> getWithResponseAsync(
@@ -571,7 +571,8 @@ public Mono> getWithResponseAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a single firewall rule in a specified redis cache.
+ * @return a single firewall rule in a specified redis cache along with {@link Response} on successful completion of
+ * {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono> getWithResponseAsync(
@@ -621,7 +622,7 @@ private Mono> getWithResponseAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a single firewall rule in a specified redis cache.
+ * @return a single firewall rule in a specified redis cache on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono getAsync(String resourceGroupName, String cacheName, String ruleName) {
@@ -662,7 +663,7 @@ public RedisFirewallRuleInner get(String resourceGroupName, String cacheName, St
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a single firewall rule in a specified redis cache.
+ * @return a single firewall rule in a specified redis cache along with {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Response getWithResponse(
@@ -679,7 +680,7 @@ public Response getWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link Response} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono> deleteWithResponseAsync(String resourceGroupName, String cacheName, String ruleName) {
@@ -732,7 +733,7 @@ public Mono> deleteWithResponseAsync(String resourceGroupName, St
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return the {@link Response} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono> deleteWithResponseAsync(
@@ -782,7 +783,7 @@ private Mono> deleteWithResponseAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the completion.
+ * @return A {@link Mono} that completes when a successful response is received.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono deleteAsync(String resourceGroupName, String cacheName, String ruleName) {
@@ -815,7 +816,7 @@ public void delete(String resourceGroupName, String cacheName, String ruleName)
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the response.
+ * @return the {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Response deleteWithResponse(
@@ -830,7 +831,8 @@ public Response deleteWithResponse(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the response of list firewall rules Redis operation.
+ * @return the response of list firewall rules Redis operation along with {@link PagedResponse} on successful
+ * completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono> listNextSinglePageAsync(String nextLink) {
@@ -866,7 +868,8 @@ private Mono> listNextSinglePageAsync(Stri
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the response of list firewall rules Redis operation.
+ * @return the response of list firewall rules Redis operation along with {@link PagedResponse} on successful
+ * completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono> listNextSinglePageAsync(String nextLink, Context context) {
diff --git a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/implementation/LinkedServersClientImpl.java b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/implementation/LinkedServersClientImpl.java
index addf057d7885c..bf8d016854a80 100644
--- a/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/implementation/LinkedServersClientImpl.java
+++ b/sdk/resourcemanager/azure-resourcemanager-redis/src/main/java/com/azure/resourcemanager/redis/implementation/LinkedServersClientImpl.java
@@ -29,7 +29,6 @@
import com.azure.core.management.polling.PollResult;
import com.azure.core.util.Context;
import com.azure.core.util.FluxUtil;
-import com.azure.core.util.logging.ClientLogger;
import com.azure.core.util.polling.PollerFlux;
import com.azure.core.util.polling.SyncPoller;
import com.azure.resourcemanager.redis.fluent.LinkedServersClient;
@@ -42,8 +41,6 @@
/** An instance of this class provides access to all the operations defined in LinkedServersClient. */
public final class LinkedServersClientImpl implements LinkedServersClient {
- private final ClientLogger logger = new ClientLogger(LinkedServersClientImpl.class);
-
/** The proxy service used to perform REST calls. */
private final LinkedServersService service;
@@ -153,7 +150,8 @@ Mono> listNext(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return response to put/get linked server (with properties) for Redis cache.
+ * @return response to put/get linked server (with properties) for Redis cache along with {@link Response} on
+ * successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono>> createWithResponseAsync(
@@ -215,7 +213,8 @@ public Mono>> createWithResponseAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return response to put/get linked server (with properties) for Redis cache.
+ * @return response to put/get linked server (with properties) for Redis cache along with {@link Response} on
+ * successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono>> createWithResponseAsync(
@@ -277,9 +276,10 @@ private Mono>> createWithResponseAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return response to put/get linked server (with properties) for Redis cache.
+ * @return the {@link PollerFlux} for polling of response to put/get linked server (with properties) for Redis
+ * cache.
*/
- @ServiceMethod(returns = ReturnType.SINGLE)
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
public PollerFlux, RedisLinkedServerWithPropertiesInner>
beginCreateAsync(
String resourceGroupName,
@@ -309,9 +309,10 @@ private Mono>> createWithResponseAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return response to put/get linked server (with properties) for Redis cache.
+ * @return the {@link PollerFlux} for polling of response to put/get linked server (with properties) for Redis
+ * cache.
*/
- @ServiceMethod(returns = ReturnType.SINGLE)
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
private PollerFlux, RedisLinkedServerWithPropertiesInner>
beginCreateAsync(
String resourceGroupName,
@@ -342,9 +343,10 @@ private Mono>> createWithResponseAsync(
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return response to put/get linked server (with properties) for Redis cache.
+ * @return the {@link SyncPoller} for polling of response to put/get linked server (with properties) for Redis
+ * cache.
*/
- @ServiceMethod(returns = ReturnType.SINGLE)
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
public SyncPoller, RedisLinkedServerWithPropertiesInner>
beginCreate(
String resourceGroupName,
@@ -365,9 +367,10 @@ private Mono