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

Merge 081541a616837b589d1908baad8aabcea8ccc00c into 9d92b4dae0a6ac2f23afeffecce650bb008ed688

Author: SDKAuto

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

@@ -1,14 +1,59 @@
 # Release History
 
-## 1.1.0-beta.1 (Unreleased)
+## 1.1.0-beta.1 (2025-04-09)
+
+- Azure Resource Manager IoT Operations client library for Java. This package contains Microsoft Azure SDK for IoT Operations Management SDK. Microsoft.IoTOperations Resource Provider management API. For documentation on how to use this package, please see [Azure Management Libraries for Java](https://aka.ms/azsdk/java/mgmt).
 
 ### Features Added
 
-### Breaking Changes
+* `models.InstanceFeature` was added
+
+* `models.StateStoreRetainmentPolicy` was added
+
+* `models.CustomTopicRetainmentPolicy` was added
+
+* `models.SubscriberQueueRetainmentPolicy` was added
+
+* `models.SubscriberQueueRetainmentSettings` was added
+
+* `models.VolumeClaimResourceRequirementsClaims` was added
+
+* `models.TopicRetainmentPolicy` was added
+
+* `models.Persistence` was added
+
+* `models.DynamicPersistenceSettings` was added
+
+* `models.TopicRetainmentSettings` was added
+
+* `models.InstanceFeatureMode` was added
+
+* `models.RetainmentPolicyMode` was added
+
+* `models.DynamicRetainmentSettings` was added
+
+* `models.CustomSubscriberQueueRetainmentPolicy` was added
+
+* `models.StateStoreRetainmentSettings` was added
+
+* `models.StateStoreRetainmentResources` was added
+
+* `models.CustomStateStoreRetainmentPolicy` was added
+
+#### `models.BrokerProperties` was modified
+
+* `withPersistence(models.Persistence)` was added
+* `persistence()` was added
+
+#### `models.VolumeClaimResourceRequirements` was modified
+
+* `withClaims(java.util.List)` was added
+* `claims()` was added
 
-### Bugs Fixed
+#### `models.InstanceProperties` was modified
 
-### Other Changes
+* `withFeatures(java.util.Map)` was added
+* `features()` was added
 
 ## 1.0.0 (2024-12-16)
 

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

@@ -52,15 +52,15 @@ Azure subscription ID can be configured via `AZURE_SUBSCRIPTION_ID` environment
 Assuming the use of the `DefaultAzureCredential` credential class, the client can be authenticated using the following code:
 
 ```java
-AzureProfile profile = new AzureProfile(AzureEnvironment.AZURE);
+AzureProfile profile = new AzureProfile(AzureCloud.AZURE_PUBLIC_CLOUD);
 TokenCredential credential = new DefaultAzureCredentialBuilder()
     .authorityHost(profile.getEnvironment().getActiveDirectoryEndpoint())
     .build();
 IoTOperationsManager manager = IoTOperationsManager
     .authenticate(credential, profile);
 ```
 
-The sample code assumes global Azure. Please change `AzureEnvironment.AZURE` variable if otherwise.
+The sample code assumes global Azure. Please change the `AzureCloud.AZURE_PUBLIC_CLOUD` variable if otherwise.
 
 See [Authentication][authenticate] for more options.
 
@@ -100,5 +100,3 @@ This project has adopted the [Microsoft Open Source Code of Conduct][coc]. For m
 [cg]: https://github.com/Azure/azure-sdk-for-java/blob/main/CONTRIBUTING.md
 [coc]: https://opensource.microsoft.com/codeofconduct/
 [coc_faq]: https://opensource.microsoft.com/codeofconduct/faq/
-
-

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

@@ -46,7 +46,6 @@
     <jacoco.min.linecoverage>0</jacoco.min.linecoverage>
     <jacoco.min.branchcoverage>0</jacoco.min.branchcoverage>
     <revapi.skip>true</revapi.skip>
-    <spotless.skip>false</spotless.skip>
   </properties>
   <dependencies>
     <dependency>

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

@@ -274,7 +274,7 @@ public DataflowEndpointsClient getDataflowEndpoints() {
         this.defaultPollInterval = defaultPollInterval;
         this.endpoint = endpoint;
         this.subscriptionId = subscriptionId;
-        this.apiVersion = "2025-04-01";
+        this.apiVersion = "2025-07-01-preview";
         this.operations = new OperationsClientImpl(this);
         this.instances = new InstancesClientImpl(this);
         this.brokers = new BrokersClientImpl(this);

sdk/iotoperations/azure-resourcemanager-iotoperations/src/main/java/com/azure/resourcemanager/iotoperations/implementation/IoTOperationsManagementClientImpl.java

@@ -48,6 +48,11 @@ public final class BrokerProperties implements JsonSerializable<BrokerProperties
      */
     private BrokerMemoryProfile memoryProfile;
 
+    /*
+     * The persistence settings of the Broker.
+     */
+    private Persistence persistence;
+
     /*
      * The status of the last operation.
      */
@@ -183,6 +188,26 @@ public BrokerProperties withMemoryProfile(BrokerMemoryProfile memoryProfile) {
         return this;
     }
 
+    /**
+     * Get the persistence property: The persistence settings of the Broker.
+     * 
+     * @return the persistence value.
+     */
+    public Persistence persistence() {
+        return this.persistence;
+    }
+
+    /**
+     * Set the persistence property: The persistence settings of the Broker.
+     * 
+     * @param persistence the persistence value to set.
+     * @return the BrokerProperties object itself.
+     */
+    public BrokerProperties withPersistence(Persistence persistence) {
+        this.persistence = persistence;
+        return this;
+    }
+
     /**
      * Get the provisioningState property: The status of the last operation.
      * 
@@ -213,6 +238,9 @@ public void validate() {
         if (generateResourceLimits() != null) {
             generateResourceLimits().validate();
         }
+        if (persistence() != null) {
+            persistence().validate();
+        }
     }
 
     /**
@@ -227,6 +255,7 @@ public JsonWriter toJson(JsonWriter jsonWriter) throws IOException {
         jsonWriter.writeJsonField("diskBackedMessageBuffer", this.diskBackedMessageBuffer);
         jsonWriter.writeJsonField("generateResourceLimits", this.generateResourceLimits);
         jsonWriter.writeStringField("memoryProfile", this.memoryProfile == null ? null : this.memoryProfile.toString());
+        jsonWriter.writeJsonField("persistence", this.persistence);
         return jsonWriter.writeEndObject();
     }
 
@@ -257,6 +286,8 @@ public static BrokerProperties fromJson(JsonReader jsonReader) throws IOExceptio
                     deserializedBrokerProperties.generateResourceLimits = GenerateResourceLimits.fromJson(reader);
                 } else if ("memoryProfile".equals(fieldName)) {
                     deserializedBrokerProperties.memoryProfile = BrokerMemoryProfile.fromString(reader.getString());
+                } else if ("persistence".equals(fieldName)) {
+                    deserializedBrokerProperties.persistence = Persistence.fromJson(reader);
                 } else if ("provisioningState".equals(fieldName)) {
                     deserializedBrokerProperties.provisioningState = ProvisioningState.fromString(reader.getString());
                 } else {

sdk/iotoperations/azure-resourcemanager-iotoperations/src/main/java/com/azure/resourcemanager/iotoperations/models/BrokerProperties.java

@@ -0,0 +1,121 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) TypeSpec Code Generator.
+
+package com.azure.resourcemanager.iotoperations.models;
+
+import com.azure.core.annotation.Fluent;
+import com.azure.json.JsonReader;
+import com.azure.json.JsonToken;
+import com.azure.json.JsonWriter;
+import java.io.IOException;
+
+/**
+ * Custom State Store Retainment Policy.
+ */
+@Fluent
+public final class CustomStateStoreRetainmentPolicy extends StateStoreRetainmentPolicy {
+    /*
+     * The mode of the retainment policy.
+     */
+    private RetainmentPolicyMode mode = RetainmentPolicyMode.CUSTOM;
+
+    /*
+     * Settings for the retainment policy.
+     */
+    private StateStoreRetainmentSettings stateStoreSettings;
+
+    /**
+     * Creates an instance of CustomStateStoreRetainmentPolicy class.
+     */
+    public CustomStateStoreRetainmentPolicy() {
+    }
+
+    /**
+     * Get the mode property: The mode of the retainment policy.
+     * 
+     * @return the mode value.
+     */
+    @Override
+    public RetainmentPolicyMode mode() {
+        return this.mode;
+    }
+
+    /**
+     * Get the stateStoreSettings property: Settings for the retainment policy.
+     * 
+     * @return the stateStoreSettings value.
+     */
+    public StateStoreRetainmentSettings stateStoreSettings() {
+        return this.stateStoreSettings;
+    }
+
+    /**
+     * Set the stateStoreSettings property: Settings for the retainment policy.
+     * 
+     * @param stateStoreSettings the stateStoreSettings value to set.
+     * @return the CustomStateStoreRetainmentPolicy object itself.
+     */
+    public CustomStateStoreRetainmentPolicy withStateStoreSettings(StateStoreRetainmentSettings stateStoreSettings) {
+        this.stateStoreSettings = stateStoreSettings;
+        return this;
+    }
+
+    /**
+     * Validates the instance.
+     * 
+     * @throws IllegalArgumentException thrown if the instance is not valid.
+     */
+    @Override
+    public void validate() {
+        if (stateStoreSettings() != null) {
+            stateStoreSettings().validate();
+        }
+        if (stateStoreSettings() != null) {
+            stateStoreSettings().validate();
+        }
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    @Override
+    public JsonWriter toJson(JsonWriter jsonWriter) throws IOException {
+        jsonWriter.writeStartObject();
+        jsonWriter.writeJsonField("stateStoreSettings", stateStoreSettings());
+        jsonWriter.writeStringField("mode", this.mode == null ? null : this.mode.toString());
+        jsonWriter.writeJsonField("stateStoreSettings", this.stateStoreSettings);
+        return jsonWriter.writeEndObject();
+    }
+
+    /**
+     * Reads an instance of CustomStateStoreRetainmentPolicy from the JsonReader.
+     * 
+     * @param jsonReader The JsonReader being read.
+     * @return An instance of CustomStateStoreRetainmentPolicy if the JsonReader was pointing to an instance of it, or
+     * null if it was pointing to JSON null.
+     * @throws IOException If an error occurs while reading the CustomStateStoreRetainmentPolicy.
+     */
+    public static CustomStateStoreRetainmentPolicy fromJson(JsonReader jsonReader) throws IOException {
+        return jsonReader.readObject(reader -> {
+            CustomStateStoreRetainmentPolicy deserializedCustomStateStoreRetainmentPolicy
+                = new CustomStateStoreRetainmentPolicy();
+            while (reader.nextToken() != JsonToken.END_OBJECT) {
+                String fieldName = reader.getFieldName();
+                reader.nextToken();
+
+                if ("mode".equals(fieldName)) {
+                    deserializedCustomStateStoreRetainmentPolicy.mode
+                        = RetainmentPolicyMode.fromString(reader.getString());
+                } else if ("stateStoreSettings".equals(fieldName)) {
+                    deserializedCustomStateStoreRetainmentPolicy.stateStoreSettings
+                        = StateStoreRetainmentSettings.fromJson(reader);
+                } else {
+                    reader.skipChildren();
+                }
+            }
+
+            return deserializedCustomStateStoreRetainmentPolicy;
+        });
+    }
+}