AzureSDKAutomation · openapi-sdkautomation · May 6, 2021
diff --git a/sdk/storagecache/azure-resourcemanager-storagecache/CHANGELOG.md b/sdk/storagecache/azure-resourcemanager-storagecache/CHANGELOG.md
@@ -1,7 +1,8 @@
 # Release History
 
-## 1.0.0-beta.3 (Unreleased)
+## 1.0.0-beta.1 (2021-05-06)
 
+- Azure Resource Manager StorageCache client library for Java. This package contains Microsoft Azure SDK for StorageCache Management SDK. A Storage Cache provides scalable caching service for NAS clients, serving data from either NFSv3 or Blob at-rest storage (referred to as "Storage Targets"). These operations allow you to manage Caches. Package tag package-2021-03. For documentation on how to use this package, please see [Azure Management Libraries for Java](https://aka.ms/azsdk/java/mgmt).
 
 ## 1.0.0-beta.2 (2021-03-08)
 

diff --git a/sdk/storagecache/azure-resourcemanager-storagecache/README.md b/sdk/storagecache/azure-resourcemanager-storagecache/README.md
@@ -32,7 +32,7 @@ Various documentation is available to help you get started
 <dependency>
     <groupId>com.azure.resourcemanager</groupId>
     <artifactId>azure-resourcemanager-storagecache</artifactId>
-    <version>1.0.0-beta.2</version>
+    <version>1.0.0-beta.3</version>
 </dependency>
 ```
 [//]: # ({x-version-update-end})

diff --git a/...toragecache/src/main/java/com/azure/resourcemanager/storagecache/StorageCacheManager.java b/...toragecache/src/main/java/com/azure/resourcemanager/storagecache/StorageCacheManager.java
@@ -182,7 +182,7 @@ public StorageCacheManager authenticate(TokenCredential credential, AzureProfile
                 .append("-")
                 .append("com.azure.resourcemanager.storagecache")
                 .append("/")
-                .append("1.0.0-beta.2");
+                .append("1.0.0-beta.1");
             if (!Configuration.getGlobalConfiguration().get("AZURE_TELEMETRY_DISABLED", false)) {
                 userAgentBuilder
                     .append(" (")
@@ -209,6 +209,7 @@ public StorageCacheManager authenticate(TokenCredential credential, AzureProfile
                 .add(
                     new BearerTokenAuthenticationPolicy(
                         credential, profile.getEnvironment().getManagementEndpoint() + "/.default"));
+            policies.addAll(this.policies);
             HttpPolicyProviders.addAfterRetryPolicies(policies);
             policies.add(new HttpLoggingPolicy(httpLogOptions));
             HttpPipeline httpPipeline =

diff --git a/...ecache/src/main/java/com/azure/resourcemanager/storagecache/fluent/models/CacheInner.java b/...ecache/src/main/java/com/azure/resourcemanager/storagecache/fluent/models/CacheInner.java
@@ -7,6 +7,7 @@
 import com.azure.core.annotation.Fluent;
 import com.azure.core.annotation.JsonFlatten;
 import com.azure.core.management.Resource;
+import com.azure.core.management.SystemData;
 import com.azure.core.util.logging.ClientLogger;
 import com.azure.resourcemanager.storagecache.models.CacheDirectorySettings;
 import com.azure.resourcemanager.storagecache.models.CacheEncryptionSettings;
@@ -17,7 +18,6 @@
 import com.azure.resourcemanager.storagecache.models.CacheSku;
 import com.azure.resourcemanager.storagecache.models.CacheUpgradeStatus;
 import com.azure.resourcemanager.storagecache.models.ProvisioningStateType;
-import com.azure.resourcemanager.storagecache.models.SystemData;
 import com.fasterxml.jackson.annotation.JsonIgnore;
 import com.fasterxml.jackson.annotation.JsonProperty;
 import java.util.List;
@@ -363,9 +363,6 @@ public void validate() {
         if (identity() != null) {
             identity().validate();
         }
-        if (systemData() != null) {
-            systemData().validate();
-        }
         if (sku() != null) {
             sku().validate();
         }

diff --git a/...n/java/com/azure/resourcemanager/storagecache/implementation/AscOperationsClientImpl.java b/...n/java/com/azure/resourcemanager/storagecache/implementation/AscOperationsClientImpl.java
@@ -113,7 +113,7 @@ private Mono<Response<AscOperationInner>> getWithResponseAsync(String location,
                             operationId,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**

diff --git a/...ecache/src/main/java/com/azure/resourcemanager/storagecache/implementation/CacheImpl.java b/...ecache/src/main/java/com/azure/resourcemanager/storagecache/implementation/CacheImpl.java
@@ -5,6 +5,7 @@
 package com.azure.resourcemanager.storagecache.implementation;
 
 import com.azure.core.management.Region;
+import com.azure.core.management.SystemData;
 import com.azure.core.util.Context;
 import com.azure.resourcemanager.storagecache.fluent.models.CacheInner;
 import com.azure.resourcemanager.storagecache.models.Cache;
@@ -17,7 +18,6 @@
 import com.azure.resourcemanager.storagecache.models.CacheSku;
 import com.azure.resourcemanager.storagecache.models.CacheUpgradeStatus;
 import com.azure.resourcemanager.storagecache.models.ProvisioningStateType;
-import com.azure.resourcemanager.storagecache.models.SystemData;
 import java.util.Collections;
 import java.util.List;
 import java.util.Map;

diff --git a/...src/main/java/com/azure/resourcemanager/storagecache/implementation/CachesClientImpl.java b/...src/main/java/com/azure/resourcemanager/storagecache/implementation/CachesClientImpl.java
@@ -292,7 +292,7 @@ private Mono<PagedResponse<CacheInner>> listSinglePageAsync() {
                         res.getValue().value(),
                         res.getValue().nextLink(),
                         null))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -439,7 +439,7 @@ private Mono<PagedResponse<CacheInner>> listByResourceGroupSinglePageAsync(Strin
                         res.getValue().value(),
                         res.getValue().nextLink(),
                         null))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -599,7 +599,7 @@ private Mono<Response<Flux<ByteBuffer>>> deleteWithResponseAsync(String resource
                             this.client.getSubscriptionId(),
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -834,7 +834,7 @@ private Mono<Response<CacheInner>> getByResourceGroupWithResponseAsync(String re
                             this.client.getSubscriptionId(),
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -994,7 +994,7 @@ private Mono<Response<Flux<ByteBuffer>>> createOrUpdateWithResponseAsync(
                             cache,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -1305,7 +1305,7 @@ private Mono<Response<CacheInner>> updateWithResponseAsync(
                             cache,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -1494,7 +1494,7 @@ private Mono<Response<Flux<ByteBuffer>>> debugInfoWithResponseAsync(String resou
                             cacheName,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -1731,7 +1731,7 @@ private Mono<Response<Flux<ByteBuffer>>> flushWithResponseAsync(String resourceG
                             cacheName,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -1975,7 +1975,7 @@ private Mono<Response<Flux<ByteBuffer>>> startWithResponseAsync(String resourceG
                             cacheName,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -2210,7 +2210,7 @@ private Mono<Response<Flux<ByteBuffer>>> stopWithResponseAsync(String resourceGr
                             cacheName,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -2446,7 +2446,7 @@ private Mono<Response<Flux<ByteBuffer>>> upgradeFirmwareWithResponseAsync(
                             cacheName,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -2671,7 +2671,7 @@ private Mono<PagedResponse<CacheInner>> listNextSinglePageAsync(String nextLink)
                         res.getValue().value(),
                         res.getValue().nextLink(),
                         null))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -2743,7 +2743,7 @@ private Mono<PagedResponse<CacheInner>> listByResourceGroupNextSinglePageAsync(S
                         res.getValue().value(),
                         res.getValue().nextLink(),
                         null))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**

diff --git a/...main/java/com/azure/resourcemanager/storagecache/implementation/OperationsClientImpl.java b/...main/java/com/azure/resourcemanager/storagecache/implementation/OperationsClientImpl.java
@@ -108,7 +108,7 @@ private Mono<PagedResponse<ApiOperationInner>> listSinglePageAsync() {
                         res.getValue().value(),
                         res.getValue().nextLink(),
                         null))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -228,7 +228,7 @@ private Mono<PagedResponse<ApiOperationInner>> listNextSinglePageAsync(String ne
                         res.getValue().value(),
                         res.getValue().nextLink(),
                         null))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**

diff --git a/...e/src/main/java/com/azure/resourcemanager/storagecache/implementation/SkusClientImpl.java b/...e/src/main/java/com/azure/resourcemanager/storagecache/implementation/SkusClientImpl.java
@@ -121,7 +121,7 @@ private Mono<PagedResponse<ResourceSkuInner>> listSinglePageAsync() {
                         res.getValue().value(),
                         res.getValue().nextLink(),
                         null))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -252,7 +252,7 @@ private Mono<PagedResponse<ResourceSkuInner>> listNextSinglePageAsync(String nex
                         res.getValue().value(),
                         res.getValue().nextLink(),
                         null))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**

diff --git a/...rc/main/java/com/azure/resourcemanager/storagecache/implementation/StorageTargetImpl.java b/...rc/main/java/com/azure/resourcemanager/storagecache/implementation/StorageTargetImpl.java
@@ -5,6 +5,7 @@
 package com.azure.resourcemanager.storagecache.implementation;
 
 import com.azure.core.management.Region;
+import com.azure.core.management.SystemData;
 import com.azure.core.util.Context;
 import com.azure.resourcemanager.storagecache.fluent.models.StorageTargetInner;
 import com.azure.resourcemanager.storagecache.models.BlobNfsTarget;
@@ -14,7 +15,6 @@
 import com.azure.resourcemanager.storagecache.models.ProvisioningStateType;
 import com.azure.resourcemanager.storagecache.models.StorageTarget;
 import com.azure.resourcemanager.storagecache.models.StorageTargetType;
-import com.azure.resourcemanager.storagecache.models.SystemData;
 import com.azure.resourcemanager.storagecache.models.UnknownTarget;
 import java.util.Collections;
 import java.util.List;

diff --git a/.../java/com/azure/resourcemanager/storagecache/implementation/StorageTargetsClientImpl.java b/.../java/com/azure/resourcemanager/storagecache/implementation/StorageTargetsClientImpl.java
@@ -211,7 +211,7 @@ private Mono<Response<Flux<ByteBuffer>>> dnsRefreshWithResponseAsync(
                             storageTargetName,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -478,7 +478,7 @@ private Mono<PagedResponse<StorageTargetInner>> listByCacheSinglePageAsync(
                         res.getValue().value(),
                         res.getValue().nextLink(),
                         null))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -663,7 +663,7 @@ private Mono<Response<Flux<ByteBuffer>>> deleteWithResponseAsync(
                             storageTargetName,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -954,7 +954,7 @@ private Mono<Response<StorageTargetInner>> getWithResponseAsync(
                             storageTargetName,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -1129,7 +1129,7 @@ private Mono<Response<Flux<ByteBuffer>>> createOrUpdateWithResponseAsync(
                             storagetarget,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -1464,7 +1464,7 @@ private Mono<PagedResponse<StorageTargetInner>> listByCacheNextSinglePageAsync(S
                         res.getValue().value(),
                         res.getValue().nextLink(),
                         null))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**

diff --git a/...ain/java/com/azure/resourcemanager/storagecache/implementation/UsageModelsClientImpl.java b/...ain/java/com/azure/resourcemanager/storagecache/implementation/UsageModelsClientImpl.java
@@ -122,7 +122,7 @@ private Mono<PagedResponse<UsageModelInner>> listSinglePageAsync() {
                         res.getValue().value(),
                         res.getValue().nextLink(),
                         null))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -253,7 +253,7 @@ private Mono<PagedResponse<UsageModelInner>> listNextSinglePageAsync(String next
                         res.getValue().value(),
                         res.getValue().nextLink(),
                         null))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**

diff --git a/...nager-storagecache/src/main/java/com/azure/resourcemanager/storagecache/models/Cache.java b/...nager-storagecache/src/main/java/com/azure/resourcemanager/storagecache/models/Cache.java
@@ -5,6 +5,7 @@
 package com.azure.resourcemanager.storagecache.models;
 
 import com.azure.core.management.Region;
+import com.azure.core.management.SystemData;
 import com.azure.core.util.Context;
 import com.azure.resourcemanager.storagecache.fluent.models.CacheInner;
 import java.util.List;

diff --git a/...oragecache/src/main/java/com/azure/resourcemanager/storagecache/models/CreatedByType.java b/...oragecache/src/main/java/com/azure/resourcemanager/storagecache/models/CreatedByType.java
diff --git a/...oragecache/src/main/java/com/azure/resourcemanager/storagecache/models/StorageTarget.java b/...oragecache/src/main/java/com/azure/resourcemanager/storagecache/models/StorageTarget.java
@@ -5,6 +5,7 @@
 package com.azure.resourcemanager.storagecache.models;
 
 import com.azure.core.management.Region;
+import com.azure.core.management.SystemData;
 import com.azure.core.util.Context;
 import com.azure.resourcemanager.storagecache.fluent.models.StorageTargetInner;
 import java.util.List;