updateAsync(
+ String resourceGroupName,
+ String registryName,
+ String cacheRuleName,
+ CacheRuleUpdateParameters cacheRuleUpdateParameters,
+ Context context) {
+ return beginUpdateAsync(resourceGroupName, registryName, cacheRuleName, cacheRuleUpdateParameters, context)
+ .last()
+ .flatMap(this.client::getLroFinalResultOrError);
+ }
+
+ /**
+ * Updates a cache rule for a container registry with the specified parameters.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param cacheRuleName The name of the cache rule.
+ * @param cacheRuleUpdateParameters The parameters for updating a cache rule.
+ * @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 an object that represents a cache rule for a container registry.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public CacheRuleInner update(
+ String resourceGroupName,
+ String registryName,
+ String cacheRuleName,
+ CacheRuleUpdateParameters cacheRuleUpdateParameters) {
+ return updateAsync(resourceGroupName, registryName, cacheRuleName, cacheRuleUpdateParameters).block();
+ }
+
+ /**
+ * Updates a cache rule for a container registry with the specified parameters.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param cacheRuleName The name of the cache rule.
+ * @param cacheRuleUpdateParameters The parameters for updating a cache rule.
+ * @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 an object that represents a cache rule for a container registry.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public CacheRuleInner update(
+ String resourceGroupName,
+ String registryName,
+ String cacheRuleName,
+ CacheRuleUpdateParameters cacheRuleUpdateParameters,
+ Context context) {
+ return updateAsync(resourceGroupName, registryName, cacheRuleName, cacheRuleUpdateParameters, context).block();
+ }
+
+ /**
+ * Get the next page of items.
+ *
+ * @param nextLink The URL to get the next list of items
+ * The nextLink parameter.
+ * @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 result of a request to list cache rules for a container registry along with {@link PagedResponse} on
+ * successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private Mono> listNextSinglePageAsync(String nextLink) {
+ if (nextLink == null) {
+ return Mono.error(new IllegalArgumentException("Parameter nextLink is required and cannot be null."));
+ }
+ if (this.client.getEndpoint() == null) {
+ return Mono
+ .error(
+ new IllegalArgumentException(
+ "Parameter this.client.getEndpoint() is required and cannot be null."));
+ }
+ final String accept = "application/json";
+ return FluxUtil
+ .withContext(context -> service.listNext(nextLink, this.client.getEndpoint(), accept, context))
+ .>map(
+ res ->
+ new PagedResponseBase<>(
+ res.getRequest(),
+ res.getStatusCode(),
+ res.getHeaders(),
+ res.getValue().value(),
+ res.getValue().nextLink(),
+ null))
+ .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
+ }
+
+ /**
+ * Get the next page of items.
+ *
+ * @param nextLink The URL to get the next list of items
+ * The nextLink parameter.
+ * @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 the result of a request to list cache rules for a container registry along with {@link PagedResponse} on
+ * successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private Mono> listNextSinglePageAsync(String nextLink, Context context) {
+ if (nextLink == null) {
+ return Mono.error(new IllegalArgumentException("Parameter nextLink is required and cannot be null."));
+ }
+ if (this.client.getEndpoint() == null) {
+ return Mono
+ .error(
+ new IllegalArgumentException(
+ "Parameter this.client.getEndpoint() is required and cannot be null."));
+ }
+ final String accept = "application/json";
+ context = this.client.mergeContext(context);
+ return service
+ .listNext(nextLink, this.client.getEndpoint(), accept, context)
+ .map(
+ res ->
+ new PagedResponseBase<>(
+ res.getRequest(),
+ res.getStatusCode(),
+ res.getHeaders(),
+ res.getValue().value(),
+ res.getValue().nextLink(),
+ null));
+ }
+}
diff --git a/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/ContainerRegistryManagementClientImpl.java b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/ContainerRegistryManagementClientImpl.java
index fd75280d4b087..ede99cda6e960 100644
--- a/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/ContainerRegistryManagementClientImpl.java
+++ b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/ContainerRegistryManagementClientImpl.java
@@ -9,7 +9,9 @@
import com.azure.core.management.AzureEnvironment;
import com.azure.core.util.serializer.SerializerAdapter;
import com.azure.resourcemanager.containerregistry.fluent.AgentPoolsClient;
+import com.azure.resourcemanager.containerregistry.fluent.CacheRulesClient;
import com.azure.resourcemanager.containerregistry.fluent.ContainerRegistryManagementClient;
+import com.azure.resourcemanager.containerregistry.fluent.CredentialSetsClient;
import com.azure.resourcemanager.containerregistry.fluent.OperationsClient;
import com.azure.resourcemanager.containerregistry.fluent.PrivateEndpointConnectionsClient;
import com.azure.resourcemanager.containerregistry.fluent.RegistriesClient;
@@ -87,6 +89,30 @@ public Duration getDefaultPollInterval() {
return this.defaultPollInterval;
}
+ /** The CacheRulesClient object to access its operations. */
+ private final CacheRulesClient cacheRules;
+
+ /**
+ * Gets the CacheRulesClient object to access its operations.
+ *
+ * @return the CacheRulesClient object.
+ */
+ public CacheRulesClient getCacheRules() {
+ return this.cacheRules;
+ }
+
+ /** The CredentialSetsClient object to access its operations. */
+ private final CredentialSetsClient credentialSets;
+
+ /**
+ * Gets the CredentialSetsClient object to access its operations.
+ *
+ * @return the CredentialSetsClient object.
+ */
+ public CredentialSetsClient getCredentialSets() {
+ return this.credentialSets;
+ }
+
/** The RegistriesClient object to access its operations. */
private final RegistriesClient registries;
@@ -242,6 +268,8 @@ public TasksClient getTasks() {
this.defaultPollInterval = defaultPollInterval;
this.subscriptionId = subscriptionId;
this.endpoint = endpoint;
+ this.cacheRules = new CacheRulesClientImpl(this);
+ this.credentialSets = new CredentialSetsClientImpl(this);
this.registries = new RegistriesClientImpl(this);
this.operations = new OperationsClientImpl(this);
this.privateEndpointConnections = new PrivateEndpointConnectionsClientImpl(this);
diff --git a/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/CredentialSetsClientImpl.java b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/CredentialSetsClientImpl.java
new file mode 100644
index 0000000000000..9f5a8de13569a
--- /dev/null
+++ b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/CredentialSetsClientImpl.java
@@ -0,0 +1,1524 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) AutoRest Code Generator.
+
+package com.azure.resourcemanager.containerregistry.implementation;
+
+import com.azure.core.annotation.BodyParam;
+import com.azure.core.annotation.Delete;
+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.Patch;
+import com.azure.core.annotation.PathParam;
+import com.azure.core.annotation.Put;
+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.PagedFlux;
+import com.azure.core.http.rest.PagedIterable;
+import com.azure.core.http.rest.PagedResponse;
+import com.azure.core.http.rest.PagedResponseBase;
+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.management.polling.PollResult;
+import com.azure.core.util.Context;
+import com.azure.core.util.FluxUtil;
+import com.azure.core.util.polling.PollerFlux;
+import com.azure.core.util.polling.SyncPoller;
+import com.azure.resourcemanager.containerregistry.fluent.CredentialSetsClient;
+import com.azure.resourcemanager.containerregistry.fluent.models.CredentialSetInner;
+import com.azure.resourcemanager.containerregistry.models.CredentialSetListResult;
+import com.azure.resourcemanager.containerregistry.models.CredentialSetUpdateParameters;
+import java.nio.ByteBuffer;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+/** An instance of this class provides access to all the operations defined in CredentialSetsClient. */
+public final class CredentialSetsClientImpl implements CredentialSetsClient {
+ /** The proxy service used to perform REST calls. */
+ private final CredentialSetsService service;
+
+ /** The service client containing this operation class. */
+ private final ContainerRegistryManagementClientImpl client;
+
+ /**
+ * Initializes an instance of CredentialSetsClientImpl.
+ *
+ * @param client the instance of the service client containing this operation class.
+ */
+ CredentialSetsClientImpl(ContainerRegistryManagementClientImpl client) {
+ this.service =
+ RestProxy.create(CredentialSetsService.class, client.getHttpPipeline(), client.getSerializerAdapter());
+ this.client = client;
+ }
+
+ /**
+ * The interface defining all the services for ContainerRegistryManagementClientCredentialSets to be used by the
+ * proxy service to perform REST calls.
+ */
+ @Host("{$host}")
+ @ServiceInterface(name = "ContainerRegistryMan")
+ public interface CredentialSetsService {
+ @Headers({"Content-Type: application/json"})
+ @Get(
+ "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.ContainerRegistry/registries/{registryName}/credentialSets")
+ @ExpectedResponses({200})
+ @UnexpectedResponseExceptionType(ManagementException.class)
+ Mono> list(
+ @HostParam("$host") String endpoint,
+ @QueryParam("api-version") String apiVersion,
+ @PathParam("subscriptionId") String subscriptionId,
+ @PathParam("resourceGroupName") String resourceGroupName,
+ @PathParam("registryName") String registryName,
+ @HeaderParam("Accept") String accept,
+ Context context);
+
+ @Headers({"Content-Type: application/json"})
+ @Get(
+ "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.ContainerRegistry/registries/{registryName}/credentialSets/{credentialSetName}")
+ @ExpectedResponses({200})
+ @UnexpectedResponseExceptionType(ManagementException.class)
+ Mono> get(
+ @HostParam("$host") String endpoint,
+ @QueryParam("api-version") String apiVersion,
+ @PathParam("subscriptionId") String subscriptionId,
+ @PathParam("resourceGroupName") String resourceGroupName,
+ @PathParam("registryName") String registryName,
+ @PathParam("credentialSetName") String credentialSetName,
+ @HeaderParam("Accept") String accept,
+ Context context);
+
+ @Headers({"Content-Type: application/json"})
+ @Put(
+ "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.ContainerRegistry/registries/{registryName}/credentialSets/{credentialSetName}")
+ @ExpectedResponses({200, 201})
+ @UnexpectedResponseExceptionType(ManagementException.class)
+ Mono>> create(
+ @HostParam("$host") String endpoint,
+ @QueryParam("api-version") String apiVersion,
+ @PathParam("subscriptionId") String subscriptionId,
+ @PathParam("resourceGroupName") String resourceGroupName,
+ @PathParam("registryName") String registryName,
+ @PathParam("credentialSetName") String credentialSetName,
+ @BodyParam("application/json") CredentialSetInner credentialSetCreateParameters,
+ @HeaderParam("Accept") String accept,
+ Context context);
+
+ @Headers({"Content-Type: application/json"})
+ @Delete(
+ "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.ContainerRegistry/registries/{registryName}/credentialSets/{credentialSetName}")
+ @ExpectedResponses({202, 204})
+ @UnexpectedResponseExceptionType(ManagementException.class)
+ Mono>> delete(
+ @HostParam("$host") String endpoint,
+ @QueryParam("api-version") String apiVersion,
+ @PathParam("subscriptionId") String subscriptionId,
+ @PathParam("resourceGroupName") String resourceGroupName,
+ @PathParam("registryName") String registryName,
+ @PathParam("credentialSetName") String credentialSetName,
+ @HeaderParam("Accept") String accept,
+ Context context);
+
+ @Headers({"Content-Type: application/json"})
+ @Patch(
+ "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.ContainerRegistry/registries/{registryName}/credentialSets/{credentialSetName}")
+ @ExpectedResponses({200, 201})
+ @UnexpectedResponseExceptionType(ManagementException.class)
+ Mono>> update(
+ @HostParam("$host") String endpoint,
+ @QueryParam("api-version") String apiVersion,
+ @PathParam("subscriptionId") String subscriptionId,
+ @PathParam("resourceGroupName") String resourceGroupName,
+ @PathParam("registryName") String registryName,
+ @PathParam("credentialSetName") String credentialSetName,
+ @BodyParam("application/json") CredentialSetUpdateParameters credentialSetUpdateParameters,
+ @HeaderParam("Accept") String accept,
+ Context context);
+
+ @Headers({"Content-Type: application/json"})
+ @Get("{nextLink}")
+ @ExpectedResponses({200})
+ @UnexpectedResponseExceptionType(ManagementException.class)
+ Mono> listNext(
+ @PathParam(value = "nextLink", encoded = true) String nextLink,
+ @HostParam("$host") String endpoint,
+ @HeaderParam("Accept") String accept,
+ Context context);
+ }
+
+ /**
+ * Lists all credential set resources for the specified container registry.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @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 result of a request to list credential sets for a container registry along with {@link PagedResponse}
+ * on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private Mono> listSinglePageAsync(String resourceGroupName, String registryName) {
+ if (this.client.getEndpoint() == null) {
+ return Mono
+ .error(
+ new IllegalArgumentException(
+ "Parameter this.client.getEndpoint() 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."));
+ }
+ if (resourceGroupName == null) {
+ return Mono
+ .error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
+ }
+ if (registryName == null) {
+ return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
+ }
+ final String apiVersion = "2023-07-01";
+ final String accept = "application/json";
+ return FluxUtil
+ .withContext(
+ context ->
+ service
+ .list(
+ this.client.getEndpoint(),
+ apiVersion,
+ this.client.getSubscriptionId(),
+ resourceGroupName,
+ registryName,
+ accept,
+ context))
+ .>map(
+ res ->
+ new PagedResponseBase<>(
+ res.getRequest(),
+ res.getStatusCode(),
+ res.getHeaders(),
+ res.getValue().value(),
+ res.getValue().nextLink(),
+ null))
+ .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
+ }
+
+ /**
+ * Lists all credential set resources for the specified container registry.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @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 the result of a request to list credential sets for a container registry along with {@link PagedResponse}
+ * on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private Mono> listSinglePageAsync(
+ String resourceGroupName, String registryName, Context context) {
+ if (this.client.getEndpoint() == null) {
+ return Mono
+ .error(
+ new IllegalArgumentException(
+ "Parameter this.client.getEndpoint() 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."));
+ }
+ if (resourceGroupName == null) {
+ return Mono
+ .error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
+ }
+ if (registryName == null) {
+ return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
+ }
+ final String apiVersion = "2023-07-01";
+ final String accept = "application/json";
+ context = this.client.mergeContext(context);
+ return service
+ .list(
+ this.client.getEndpoint(),
+ apiVersion,
+ this.client.getSubscriptionId(),
+ resourceGroupName,
+ registryName,
+ accept,
+ context)
+ .map(
+ res ->
+ new PagedResponseBase<>(
+ res.getRequest(),
+ res.getStatusCode(),
+ res.getHeaders(),
+ res.getValue().value(),
+ res.getValue().nextLink(),
+ null));
+ }
+
+ /**
+ * Lists all credential set resources for the specified container registry.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @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 result of a request to list credential sets for a container registry as paginated response with
+ * {@link PagedFlux}.
+ */
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux listAsync(String resourceGroupName, String registryName) {
+ return new PagedFlux<>(
+ () -> listSinglePageAsync(resourceGroupName, registryName), nextLink -> listNextSinglePageAsync(nextLink));
+ }
+
+ /**
+ * Lists all credential set resources for the specified container registry.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @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 the result of a request to list credential sets for a container registry as paginated response with
+ * {@link PagedFlux}.
+ */
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ private PagedFlux listAsync(String resourceGroupName, String registryName, Context context) {
+ return new PagedFlux<>(
+ () -> listSinglePageAsync(resourceGroupName, registryName, context),
+ nextLink -> listNextSinglePageAsync(nextLink, context));
+ }
+
+ /**
+ * Lists all credential set resources for the specified container registry.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @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 result of a request to list credential sets for a container registry as paginated response with
+ * {@link PagedIterable}.
+ */
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedIterable list(String resourceGroupName, String registryName) {
+ return new PagedIterable<>(listAsync(resourceGroupName, registryName));
+ }
+
+ /**
+ * Lists all credential set resources for the specified container registry.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @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 the result of a request to list credential sets for a container registry as paginated response with
+ * {@link PagedIterable}.
+ */
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedIterable list(String resourceGroupName, String registryName, Context context) {
+ return new PagedIterable<>(listAsync(resourceGroupName, registryName, context));
+ }
+
+ /**
+ * Gets the properties of the specified credential set resource.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @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 properties of the specified credential set resource along with {@link Response} on successful
+ * completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> getWithResponseAsync(
+ String resourceGroupName, String registryName, String credentialSetName) {
+ if (this.client.getEndpoint() == null) {
+ return Mono
+ .error(
+ new IllegalArgumentException(
+ "Parameter this.client.getEndpoint() 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."));
+ }
+ if (resourceGroupName == null) {
+ return Mono
+ .error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
+ }
+ if (registryName == null) {
+ return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
+ }
+ if (credentialSetName == null) {
+ return Mono
+ .error(new IllegalArgumentException("Parameter credentialSetName is required and cannot be null."));
+ }
+ final String apiVersion = "2023-07-01";
+ final String accept = "application/json";
+ return FluxUtil
+ .withContext(
+ context ->
+ service
+ .get(
+ this.client.getEndpoint(),
+ apiVersion,
+ this.client.getSubscriptionId(),
+ resourceGroupName,
+ registryName,
+ credentialSetName,
+ accept,
+ context))
+ .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
+ }
+
+ /**
+ * Gets the properties of the specified credential set resource.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @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 the properties of the specified credential set resource along with {@link Response} on successful
+ * completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private Mono> getWithResponseAsync(
+ String resourceGroupName, String registryName, String credentialSetName, Context context) {
+ if (this.client.getEndpoint() == null) {
+ return Mono
+ .error(
+ new IllegalArgumentException(
+ "Parameter this.client.getEndpoint() 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."));
+ }
+ if (resourceGroupName == null) {
+ return Mono
+ .error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
+ }
+ if (registryName == null) {
+ return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
+ }
+ if (credentialSetName == null) {
+ return Mono
+ .error(new IllegalArgumentException("Parameter credentialSetName is required and cannot be null."));
+ }
+ final String apiVersion = "2023-07-01";
+ final String accept = "application/json";
+ context = this.client.mergeContext(context);
+ return service
+ .get(
+ this.client.getEndpoint(),
+ apiVersion,
+ this.client.getSubscriptionId(),
+ resourceGroupName,
+ registryName,
+ credentialSetName,
+ accept,
+ context);
+ }
+
+ /**
+ * Gets the properties of the specified credential set resource.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @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 properties of the specified credential set resource on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono getAsync(String resourceGroupName, String registryName, String credentialSetName) {
+ return getWithResponseAsync(resourceGroupName, registryName, credentialSetName)
+ .flatMap(res -> Mono.justOrEmpty(res.getValue()));
+ }
+
+ /**
+ * Gets the properties of the specified credential set resource.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @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 the properties of the specified credential set resource along with {@link Response}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response getWithResponse(
+ String resourceGroupName, String registryName, String credentialSetName, Context context) {
+ return getWithResponseAsync(resourceGroupName, registryName, credentialSetName, context).block();
+ }
+
+ /**
+ * Gets the properties of the specified credential set resource.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @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 properties of the specified credential set resource.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public CredentialSetInner get(String resourceGroupName, String registryName, String credentialSetName) {
+ return getWithResponse(resourceGroupName, registryName, credentialSetName, Context.NONE).getValue();
+ }
+
+ /**
+ * Creates a credential set for a container registry with the specified parameters.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @param credentialSetCreateParameters The parameters for creating a credential set.
+ * @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 an object that represents a credential set resource for a container registry along with {@link Response}
+ * on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono>> createWithResponseAsync(
+ String resourceGroupName,
+ String registryName,
+ String credentialSetName,
+ CredentialSetInner credentialSetCreateParameters) {
+ if (this.client.getEndpoint() == null) {
+ return Mono
+ .error(
+ new IllegalArgumentException(
+ "Parameter this.client.getEndpoint() 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."));
+ }
+ if (resourceGroupName == null) {
+ return Mono
+ .error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
+ }
+ if (registryName == null) {
+ return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
+ }
+ if (credentialSetName == null) {
+ return Mono
+ .error(new IllegalArgumentException("Parameter credentialSetName is required and cannot be null."));
+ }
+ if (credentialSetCreateParameters == null) {
+ return Mono
+ .error(
+ new IllegalArgumentException(
+ "Parameter credentialSetCreateParameters is required and cannot be null."));
+ } else {
+ credentialSetCreateParameters.validate();
+ }
+ final String apiVersion = "2023-07-01";
+ final String accept = "application/json";
+ return FluxUtil
+ .withContext(
+ context ->
+ service
+ .create(
+ this.client.getEndpoint(),
+ apiVersion,
+ this.client.getSubscriptionId(),
+ resourceGroupName,
+ registryName,
+ credentialSetName,
+ credentialSetCreateParameters,
+ accept,
+ context))
+ .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
+ }
+
+ /**
+ * Creates a credential set for a container registry with the specified parameters.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @param credentialSetCreateParameters The parameters for creating a credential set.
+ * @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 an object that represents a credential set resource for a container registry along with {@link Response}
+ * on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private Mono>> createWithResponseAsync(
+ String resourceGroupName,
+ String registryName,
+ String credentialSetName,
+ CredentialSetInner credentialSetCreateParameters,
+ Context context) {
+ if (this.client.getEndpoint() == null) {
+ return Mono
+ .error(
+ new IllegalArgumentException(
+ "Parameter this.client.getEndpoint() 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."));
+ }
+ if (resourceGroupName == null) {
+ return Mono
+ .error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
+ }
+ if (registryName == null) {
+ return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
+ }
+ if (credentialSetName == null) {
+ return Mono
+ .error(new IllegalArgumentException("Parameter credentialSetName is required and cannot be null."));
+ }
+ if (credentialSetCreateParameters == null) {
+ return Mono
+ .error(
+ new IllegalArgumentException(
+ "Parameter credentialSetCreateParameters is required and cannot be null."));
+ } else {
+ credentialSetCreateParameters.validate();
+ }
+ final String apiVersion = "2023-07-01";
+ final String accept = "application/json";
+ context = this.client.mergeContext(context);
+ return service
+ .create(
+ this.client.getEndpoint(),
+ apiVersion,
+ this.client.getSubscriptionId(),
+ resourceGroupName,
+ registryName,
+ credentialSetName,
+ credentialSetCreateParameters,
+ accept,
+ context);
+ }
+
+ /**
+ * Creates a credential set for a container registry with the specified parameters.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @param credentialSetCreateParameters The parameters for creating a credential set.
+ * @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 {@link PollerFlux} for polling of an object that represents a credential set resource for a container
+ * registry.
+ */
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
+ public PollerFlux, CredentialSetInner> beginCreateAsync(
+ String resourceGroupName,
+ String registryName,
+ String credentialSetName,
+ CredentialSetInner credentialSetCreateParameters) {
+ Mono>> mono =
+ createWithResponseAsync(resourceGroupName, registryName, credentialSetName, credentialSetCreateParameters);
+ return this
+ .client
+ .getLroResult(
+ mono,
+ this.client.getHttpPipeline(),
+ CredentialSetInner.class,
+ CredentialSetInner.class,
+ this.client.getContext());
+ }
+
+ /**
+ * Creates a credential set for a container registry with the specified parameters.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @param credentialSetCreateParameters The parameters for creating a credential set.
+ * @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 the {@link PollerFlux} for polling of an object that represents a credential set resource for a container
+ * registry.
+ */
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
+ private PollerFlux, CredentialSetInner> beginCreateAsync(
+ String resourceGroupName,
+ String registryName,
+ String credentialSetName,
+ CredentialSetInner credentialSetCreateParameters,
+ Context context) {
+ context = this.client.mergeContext(context);
+ Mono>> mono =
+ createWithResponseAsync(
+ resourceGroupName, registryName, credentialSetName, credentialSetCreateParameters, context);
+ return this
+ .client
+ .getLroResult(
+ mono, this.client.getHttpPipeline(), CredentialSetInner.class, CredentialSetInner.class, context);
+ }
+
+ /**
+ * Creates a credential set for a container registry with the specified parameters.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @param credentialSetCreateParameters The parameters for creating a credential set.
+ * @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 {@link SyncPoller} for polling of an object that represents a credential set resource for a container
+ * registry.
+ */
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
+ public SyncPoller, CredentialSetInner> beginCreate(
+ String resourceGroupName,
+ String registryName,
+ String credentialSetName,
+ CredentialSetInner credentialSetCreateParameters) {
+ return this
+ .beginCreateAsync(resourceGroupName, registryName, credentialSetName, credentialSetCreateParameters)
+ .getSyncPoller();
+ }
+
+ /**
+ * Creates a credential set for a container registry with the specified parameters.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @param credentialSetCreateParameters The parameters for creating a credential set.
+ * @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 the {@link SyncPoller} for polling of an object that represents a credential set resource for a container
+ * registry.
+ */
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
+ public SyncPoller, CredentialSetInner> beginCreate(
+ String resourceGroupName,
+ String registryName,
+ String credentialSetName,
+ CredentialSetInner credentialSetCreateParameters,
+ Context context) {
+ return this
+ .beginCreateAsync(
+ resourceGroupName, registryName, credentialSetName, credentialSetCreateParameters, context)
+ .getSyncPoller();
+ }
+
+ /**
+ * Creates a credential set for a container registry with the specified parameters.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @param credentialSetCreateParameters The parameters for creating a credential set.
+ * @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 an object that represents a credential set resource for a container registry on successful completion of
+ * {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono createAsync(
+ String resourceGroupName,
+ String registryName,
+ String credentialSetName,
+ CredentialSetInner credentialSetCreateParameters) {
+ return beginCreateAsync(resourceGroupName, registryName, credentialSetName, credentialSetCreateParameters)
+ .last()
+ .flatMap(this.client::getLroFinalResultOrError);
+ }
+
+ /**
+ * Creates a credential set for a container registry with the specified parameters.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @param credentialSetCreateParameters The parameters for creating a credential set.
+ * @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 an object that represents a credential set resource for a container registry on successful completion of
+ * {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private Mono createAsync(
+ String resourceGroupName,
+ String registryName,
+ String credentialSetName,
+ CredentialSetInner credentialSetCreateParameters,
+ Context context) {
+ return beginCreateAsync(
+ resourceGroupName, registryName, credentialSetName, credentialSetCreateParameters, context)
+ .last()
+ .flatMap(this.client::getLroFinalResultOrError);
+ }
+
+ /**
+ * Creates a credential set for a container registry with the specified parameters.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @param credentialSetCreateParameters The parameters for creating a credential set.
+ * @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 an object that represents a credential set resource for a container registry.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public CredentialSetInner create(
+ String resourceGroupName,
+ String registryName,
+ String credentialSetName,
+ CredentialSetInner credentialSetCreateParameters) {
+ return createAsync(resourceGroupName, registryName, credentialSetName, credentialSetCreateParameters).block();
+ }
+
+ /**
+ * Creates a credential set for a container registry with the specified parameters.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @param credentialSetCreateParameters The parameters for creating a credential set.
+ * @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 an object that represents a credential set resource for a container registry.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public CredentialSetInner create(
+ String resourceGroupName,
+ String registryName,
+ String credentialSetName,
+ CredentialSetInner credentialSetCreateParameters,
+ Context context) {
+ return createAsync(resourceGroupName, registryName, credentialSetName, credentialSetCreateParameters, context)
+ .block();
+ }
+
+ /**
+ * Deletes a credential set from a container registry.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @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 {@link Response} on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono>> deleteWithResponseAsync(
+ String resourceGroupName, String registryName, String credentialSetName) {
+ if (this.client.getEndpoint() == null) {
+ return Mono
+ .error(
+ new IllegalArgumentException(
+ "Parameter this.client.getEndpoint() 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."));
+ }
+ if (resourceGroupName == null) {
+ return Mono
+ .error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
+ }
+ if (registryName == null) {
+ return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
+ }
+ if (credentialSetName == null) {
+ return Mono
+ .error(new IllegalArgumentException("Parameter credentialSetName is required and cannot be null."));
+ }
+ final String apiVersion = "2023-07-01";
+ final String accept = "application/json";
+ return FluxUtil
+ .withContext(
+ context ->
+ service
+ .delete(
+ this.client.getEndpoint(),
+ apiVersion,
+ this.client.getSubscriptionId(),
+ resourceGroupName,
+ registryName,
+ credentialSetName,
+ accept,
+ context))
+ .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
+ }
+
+ /**
+ * Deletes a credential set from a container registry.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @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 the {@link Response} on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private Mono>> deleteWithResponseAsync(
+ String resourceGroupName, String registryName, String credentialSetName, Context context) {
+ if (this.client.getEndpoint() == null) {
+ return Mono
+ .error(
+ new IllegalArgumentException(
+ "Parameter this.client.getEndpoint() 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."));
+ }
+ if (resourceGroupName == null) {
+ return Mono
+ .error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
+ }
+ if (registryName == null) {
+ return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
+ }
+ if (credentialSetName == null) {
+ return Mono
+ .error(new IllegalArgumentException("Parameter credentialSetName is required and cannot be null."));
+ }
+ final String apiVersion = "2023-07-01";
+ final String accept = "application/json";
+ context = this.client.mergeContext(context);
+ return service
+ .delete(
+ this.client.getEndpoint(),
+ apiVersion,
+ this.client.getSubscriptionId(),
+ resourceGroupName,
+ registryName,
+ credentialSetName,
+ accept,
+ context);
+ }
+
+ /**
+ * Deletes a credential set from a container registry.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @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 {@link PollerFlux} for polling of long-running operation.
+ */
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
+ public PollerFlux, Void> beginDeleteAsync(
+ String resourceGroupName, String registryName, String credentialSetName) {
+ Mono>> mono =
+ deleteWithResponseAsync(resourceGroupName, registryName, credentialSetName);
+ return this
+ .client
+ .getLroResult(
+ mono, this.client.getHttpPipeline(), Void.class, Void.class, this.client.getContext());
+ }
+
+ /**
+ * Deletes a credential set from a container registry.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @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 the {@link PollerFlux} for polling of long-running operation.
+ */
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
+ private PollerFlux, Void> beginDeleteAsync(
+ String resourceGroupName, String registryName, String credentialSetName, Context context) {
+ context = this.client.mergeContext(context);
+ Mono>> mono =
+ deleteWithResponseAsync(resourceGroupName, registryName, credentialSetName, context);
+ return this
+ .client
+ .getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, context);
+ }
+
+ /**
+ * Deletes a credential set from a container registry.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @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 {@link SyncPoller} for polling of long-running operation.
+ */
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
+ public SyncPoller, Void> beginDelete(
+ String resourceGroupName, String registryName, String credentialSetName) {
+ return this.beginDeleteAsync(resourceGroupName, registryName, credentialSetName).getSyncPoller();
+ }
+
+ /**
+ * Deletes a credential set from a container registry.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @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 the {@link SyncPoller} for polling of long-running operation.
+ */
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
+ public SyncPoller, Void> beginDelete(
+ String resourceGroupName, String registryName, String credentialSetName, Context context) {
+ return this.beginDeleteAsync(resourceGroupName, registryName, credentialSetName, context).getSyncPoller();
+ }
+
+ /**
+ * Deletes a credential set from a container registry.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @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 {@link Mono} that completes when a successful response is received.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono deleteAsync(String resourceGroupName, String registryName, String credentialSetName) {
+ return beginDeleteAsync(resourceGroupName, registryName, credentialSetName)
+ .last()
+ .flatMap(this.client::getLroFinalResultOrError);
+ }
+
+ /**
+ * Deletes a credential set from a container registry.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @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 A {@link Mono} that completes when a successful response is received.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private Mono deleteAsync(
+ String resourceGroupName, String registryName, String credentialSetName, Context context) {
+ return beginDeleteAsync(resourceGroupName, registryName, credentialSetName, context)
+ .last()
+ .flatMap(this.client::getLroFinalResultOrError);
+ }
+
+ /**
+ * Deletes a credential set from a container registry.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @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.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public void delete(String resourceGroupName, String registryName, String credentialSetName) {
+ deleteAsync(resourceGroupName, registryName, credentialSetName).block();
+ }
+
+ /**
+ * Deletes a credential set from a container registry.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @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.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public void delete(String resourceGroupName, String registryName, String credentialSetName, Context context) {
+ deleteAsync(resourceGroupName, registryName, credentialSetName, context).block();
+ }
+
+ /**
+ * Updates a credential set for a container registry with the specified parameters.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @param credentialSetUpdateParameters The parameters for updating a credential set.
+ * @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 an object that represents a credential set resource for a container registry along with {@link Response}
+ * on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono>> updateWithResponseAsync(
+ String resourceGroupName,
+ String registryName,
+ String credentialSetName,
+ CredentialSetUpdateParameters credentialSetUpdateParameters) {
+ if (this.client.getEndpoint() == null) {
+ return Mono
+ .error(
+ new IllegalArgumentException(
+ "Parameter this.client.getEndpoint() 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."));
+ }
+ if (resourceGroupName == null) {
+ return Mono
+ .error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
+ }
+ if (registryName == null) {
+ return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
+ }
+ if (credentialSetName == null) {
+ return Mono
+ .error(new IllegalArgumentException("Parameter credentialSetName is required and cannot be null."));
+ }
+ if (credentialSetUpdateParameters == null) {
+ return Mono
+ .error(
+ new IllegalArgumentException(
+ "Parameter credentialSetUpdateParameters is required and cannot be null."));
+ } else {
+ credentialSetUpdateParameters.validate();
+ }
+ final String apiVersion = "2023-07-01";
+ final String accept = "application/json";
+ return FluxUtil
+ .withContext(
+ context ->
+ service
+ .update(
+ this.client.getEndpoint(),
+ apiVersion,
+ this.client.getSubscriptionId(),
+ resourceGroupName,
+ registryName,
+ credentialSetName,
+ credentialSetUpdateParameters,
+ accept,
+ context))
+ .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
+ }
+
+ /**
+ * Updates a credential set for a container registry with the specified parameters.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @param credentialSetUpdateParameters The parameters for updating a credential set.
+ * @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 an object that represents a credential set resource for a container registry along with {@link Response}
+ * on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private Mono>> updateWithResponseAsync(
+ String resourceGroupName,
+ String registryName,
+ String credentialSetName,
+ CredentialSetUpdateParameters credentialSetUpdateParameters,
+ Context context) {
+ if (this.client.getEndpoint() == null) {
+ return Mono
+ .error(
+ new IllegalArgumentException(
+ "Parameter this.client.getEndpoint() 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."));
+ }
+ if (resourceGroupName == null) {
+ return Mono
+ .error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
+ }
+ if (registryName == null) {
+ return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
+ }
+ if (credentialSetName == null) {
+ return Mono
+ .error(new IllegalArgumentException("Parameter credentialSetName is required and cannot be null."));
+ }
+ if (credentialSetUpdateParameters == null) {
+ return Mono
+ .error(
+ new IllegalArgumentException(
+ "Parameter credentialSetUpdateParameters is required and cannot be null."));
+ } else {
+ credentialSetUpdateParameters.validate();
+ }
+ final String apiVersion = "2023-07-01";
+ final String accept = "application/json";
+ context = this.client.mergeContext(context);
+ return service
+ .update(
+ this.client.getEndpoint(),
+ apiVersion,
+ this.client.getSubscriptionId(),
+ resourceGroupName,
+ registryName,
+ credentialSetName,
+ credentialSetUpdateParameters,
+ accept,
+ context);
+ }
+
+ /**
+ * Updates a credential set for a container registry with the specified parameters.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @param credentialSetUpdateParameters The parameters for updating a credential set.
+ * @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 {@link PollerFlux} for polling of an object that represents a credential set resource for a container
+ * registry.
+ */
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
+ public PollerFlux, CredentialSetInner> beginUpdateAsync(
+ String resourceGroupName,
+ String registryName,
+ String credentialSetName,
+ CredentialSetUpdateParameters credentialSetUpdateParameters) {
+ Mono>> mono =
+ updateWithResponseAsync(resourceGroupName, registryName, credentialSetName, credentialSetUpdateParameters);
+ return this
+ .client
+ .getLroResult(
+ mono,
+ this.client.getHttpPipeline(),
+ CredentialSetInner.class,
+ CredentialSetInner.class,
+ this.client.getContext());
+ }
+
+ /**
+ * Updates a credential set for a container registry with the specified parameters.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @param credentialSetUpdateParameters The parameters for updating a credential set.
+ * @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 the {@link PollerFlux} for polling of an object that represents a credential set resource for a container
+ * registry.
+ */
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
+ private PollerFlux, CredentialSetInner> beginUpdateAsync(
+ String resourceGroupName,
+ String registryName,
+ String credentialSetName,
+ CredentialSetUpdateParameters credentialSetUpdateParameters,
+ Context context) {
+ context = this.client.mergeContext(context);
+ Mono>> mono =
+ updateWithResponseAsync(
+ resourceGroupName, registryName, credentialSetName, credentialSetUpdateParameters, context);
+ return this
+ .client
+ .getLroResult(
+ mono, this.client.getHttpPipeline(), CredentialSetInner.class, CredentialSetInner.class, context);
+ }
+
+ /**
+ * Updates a credential set for a container registry with the specified parameters.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @param credentialSetUpdateParameters The parameters for updating a credential set.
+ * @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 {@link SyncPoller} for polling of an object that represents a credential set resource for a container
+ * registry.
+ */
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
+ public SyncPoller, CredentialSetInner> beginUpdate(
+ String resourceGroupName,
+ String registryName,
+ String credentialSetName,
+ CredentialSetUpdateParameters credentialSetUpdateParameters) {
+ return this
+ .beginUpdateAsync(resourceGroupName, registryName, credentialSetName, credentialSetUpdateParameters)
+ .getSyncPoller();
+ }
+
+ /**
+ * Updates a credential set for a container registry with the specified parameters.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @param credentialSetUpdateParameters The parameters for updating a credential set.
+ * @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 the {@link SyncPoller} for polling of an object that represents a credential set resource for a container
+ * registry.
+ */
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
+ public SyncPoller, CredentialSetInner> beginUpdate(
+ String resourceGroupName,
+ String registryName,
+ String credentialSetName,
+ CredentialSetUpdateParameters credentialSetUpdateParameters,
+ Context context) {
+ return this
+ .beginUpdateAsync(
+ resourceGroupName, registryName, credentialSetName, credentialSetUpdateParameters, context)
+ .getSyncPoller();
+ }
+
+ /**
+ * Updates a credential set for a container registry with the specified parameters.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @param credentialSetUpdateParameters The parameters for updating a credential set.
+ * @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 an object that represents a credential set resource for a container registry on successful completion of
+ * {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono updateAsync(
+ String resourceGroupName,
+ String registryName,
+ String credentialSetName,
+ CredentialSetUpdateParameters credentialSetUpdateParameters) {
+ return beginUpdateAsync(resourceGroupName, registryName, credentialSetName, credentialSetUpdateParameters)
+ .last()
+ .flatMap(this.client::getLroFinalResultOrError);
+ }
+
+ /**
+ * Updates a credential set for a container registry with the specified parameters.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @param credentialSetUpdateParameters The parameters for updating a credential set.
+ * @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 an object that represents a credential set resource for a container registry on successful completion of
+ * {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private Mono updateAsync(
+ String resourceGroupName,
+ String registryName,
+ String credentialSetName,
+ CredentialSetUpdateParameters credentialSetUpdateParameters,
+ Context context) {
+ return beginUpdateAsync(
+ resourceGroupName, registryName, credentialSetName, credentialSetUpdateParameters, context)
+ .last()
+ .flatMap(this.client::getLroFinalResultOrError);
+ }
+
+ /**
+ * Updates a credential set for a container registry with the specified parameters.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @param credentialSetUpdateParameters The parameters for updating a credential set.
+ * @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 an object that represents a credential set resource for a container registry.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public CredentialSetInner update(
+ String resourceGroupName,
+ String registryName,
+ String credentialSetName,
+ CredentialSetUpdateParameters credentialSetUpdateParameters) {
+ return updateAsync(resourceGroupName, registryName, credentialSetName, credentialSetUpdateParameters).block();
+ }
+
+ /**
+ * Updates a credential set for a container registry with the specified parameters.
+ *
+ * @param resourceGroupName The name of the resource group. The name is case insensitive.
+ * @param registryName The name of the container registry.
+ * @param credentialSetName The name of the credential set.
+ * @param credentialSetUpdateParameters The parameters for updating a credential set.
+ * @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 an object that represents a credential set resource for a container registry.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public CredentialSetInner update(
+ String resourceGroupName,
+ String registryName,
+ String credentialSetName,
+ CredentialSetUpdateParameters credentialSetUpdateParameters,
+ Context context) {
+ return updateAsync(resourceGroupName, registryName, credentialSetName, credentialSetUpdateParameters, context)
+ .block();
+ }
+
+ /**
+ * Get the next page of items.
+ *
+ * @param nextLink The URL to get the next list of items
+ * The nextLink parameter.
+ * @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 result of a request to list credential sets for a container registry along with {@link PagedResponse}
+ * on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private Mono> listNextSinglePageAsync(String nextLink) {
+ if (nextLink == null) {
+ return Mono.error(new IllegalArgumentException("Parameter nextLink is required and cannot be null."));
+ }
+ if (this.client.getEndpoint() == null) {
+ return Mono
+ .error(
+ new IllegalArgumentException(
+ "Parameter this.client.getEndpoint() is required and cannot be null."));
+ }
+ final String accept = "application/json";
+ return FluxUtil
+ .withContext(context -> service.listNext(nextLink, this.client.getEndpoint(), accept, context))
+ .>map(
+ res ->
+ new PagedResponseBase<>(
+ res.getRequest(),
+ res.getStatusCode(),
+ res.getHeaders(),
+ res.getValue().value(),
+ res.getValue().nextLink(),
+ null))
+ .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
+ }
+
+ /**
+ * Get the next page of items.
+ *
+ * @param nextLink The URL to get the next list of items
+ * The nextLink parameter.
+ * @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 the result of a request to list credential sets for a container registry along with {@link PagedResponse}
+ * on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private Mono> listNextSinglePageAsync(String nextLink, Context context) {
+ if (nextLink == null) {
+ return Mono.error(new IllegalArgumentException("Parameter nextLink is required and cannot be null."));
+ }
+ if (this.client.getEndpoint() == null) {
+ return Mono
+ .error(
+ new IllegalArgumentException(
+ "Parameter this.client.getEndpoint() is required and cannot be null."));
+ }
+ final String accept = "application/json";
+ context = this.client.mergeContext(context);
+ return service
+ .listNext(nextLink, this.client.getEndpoint(), accept, context)
+ .map(
+ res ->
+ new PagedResponseBase<>(
+ res.getRequest(),
+ res.getStatusCode(),
+ res.getHeaders(),
+ res.getValue().value(),
+ res.getValue().nextLink(),
+ null));
+ }
+}
diff --git a/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/OperationsClientImpl.java b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/OperationsClientImpl.java
index 969318547e1f9..34642aeb64e1e 100644
--- a/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/OperationsClientImpl.java
+++ b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/OperationsClientImpl.java
@@ -93,7 +93,7 @@ private Mono> listSinglePageAsync() {
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(context -> service.list(this.client.getEndpoint(), apiVersion, accept, context))
@@ -127,7 +127,7 @@ private Mono> listSinglePageAsync(Contex
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
diff --git a/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/PrivateEndpointConnectionsClientImpl.java b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/PrivateEndpointConnectionsClientImpl.java
index bd339d6df0f44..5a4a75eb4f2d0 100644
--- a/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/PrivateEndpointConnectionsClientImpl.java
+++ b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/PrivateEndpointConnectionsClientImpl.java
@@ -169,7 +169,7 @@ private Mono> listSinglePageAsync(
if (registryName == null) {
return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -229,7 +229,7 @@ private Mono> listSinglePageAsync(
if (registryName == null) {
return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -363,7 +363,7 @@ public Mono> getWithResponseAsync(
new IllegalArgumentException(
"Parameter privateEndpointConnectionName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -422,7 +422,7 @@ private Mono> getWithResponseAsync(
new IllegalArgumentException(
"Parameter privateEndpointConnectionName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -544,7 +544,7 @@ public Mono>> createOrUpdateWithResponseAsync(
} else {
privateEndpointConnection.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -617,7 +617,7 @@ private Mono>> createOrUpdateWithResponseAsync(
} else {
privateEndpointConnection.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -893,7 +893,7 @@ public Mono>> deleteWithResponseAsync(
new IllegalArgumentException(
"Parameter privateEndpointConnectionName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
return FluxUtil
.withContext(
context ->
@@ -949,7 +949,7 @@ private Mono>> deleteWithResponseAsync(
new IllegalArgumentException(
"Parameter privateEndpointConnectionName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
context = this.client.mergeContext(context);
return service
.delete(
diff --git a/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/RegistriesClientImpl.java b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/RegistriesClientImpl.java
index 553daba85c411..57fc4b934921f 100644
--- a/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/RegistriesClientImpl.java
+++ b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/RegistriesClientImpl.java
@@ -379,7 +379,7 @@ public Mono>> importImageWithResponseAsync(
} else {
parameters.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
return FluxUtil
.withContext(
context ->
@@ -434,7 +434,7 @@ private Mono>> importImageWithResponseAsync(
} else {
parameters.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
context = this.client.mergeContext(context);
return service
.importImage(
@@ -631,7 +631,7 @@ public Mono> checkNameAvailabilityWithResponse
} else {
registryNameCheckRequest.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -681,7 +681,7 @@ private Mono> checkNameAvailabilityWithRespons
} else {
registryNameCheckRequest.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -766,7 +766,7 @@ private Mono> listSinglePageAsync() {
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -809,7 +809,7 @@ private Mono> listSinglePageAsync(Context context)
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -906,7 +906,7 @@ private Mono> listByResourceGroupSinglePageAsync(St
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -961,7 +961,7 @@ private Mono> listByResourceGroupSinglePageAsync(
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -1078,7 +1078,7 @@ public Mono> getByResourceGroupWithResponseAsync(
if (registryName == null) {
return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -1129,7 +1129,7 @@ private Mono> getByResourceGroupWithResponseAsync(
if (registryName == null) {
return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -1230,7 +1230,7 @@ public Mono>> createWithResponseAsync(
} else {
registry.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -1288,7 +1288,7 @@ private Mono>> createWithResponseAsync(
} else {
registry.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -1490,7 +1490,7 @@ public Mono>> deleteWithResponseAsync(String resourceG
if (registryName == null) {
return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
return FluxUtil
.withContext(
context ->
@@ -1538,7 +1538,7 @@ private Mono>> deleteWithResponseAsync(
if (registryName == null) {
return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
context = this.client.mergeContext(context);
return service
.delete(
@@ -1725,7 +1725,7 @@ public Mono>> updateWithResponseAsync(
} else {
registryUpdateParameters.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -1788,7 +1788,7 @@ private Mono>> updateWithResponseAsync(
} else {
registryUpdateParameters.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -2009,7 +2009,7 @@ public Mono> listUsagesWithResponseAsync(
if (registryName == null) {
return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -2060,7 +2060,7 @@ private Mono> listUsagesWithResponseAsync
if (registryName == null) {
return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -2155,7 +2155,7 @@ private Mono> listPrivateLinkResourcesSi
if (registryName == null) {
return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -2215,7 +2215,7 @@ private Mono> listPrivateLinkResourcesSi
if (registryName == null) {
return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -2349,7 +2349,7 @@ public Mono> getPrivateLinkResourceWithRespon
if (groupName == null) {
return Mono.error(new IllegalArgumentException("Parameter groupName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -2405,7 +2405,7 @@ private Mono> getPrivateLinkResourceWithRespo
if (groupName == null) {
return Mono.error(new IllegalArgumentException("Parameter groupName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -2507,7 +2507,7 @@ public Mono> listCredentialsWithRes
if (registryName == null) {
return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -2558,7 +2558,7 @@ private Mono> listCredentialsWithRe
if (registryName == null) {
return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -2664,7 +2664,7 @@ public Mono> regenerateCredentialWi
} else {
regenerateCredentialParameters.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -2729,7 +2729,7 @@ private Mono> regenerateCredentialW
} else {
regenerateCredentialParameters.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -2849,7 +2849,7 @@ public Mono>> generateCredentialsWithResponseAsync(
} else {
generateCredentialsParameters.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -2913,7 +2913,7 @@ private Mono>> generateCredentialsWithResponseAsync(
} else {
generateCredentialsParameters.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
diff --git a/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/ReplicationsClientImpl.java b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/ReplicationsClientImpl.java
index dcc7fe5d5ec4d..74df17e8b09d0 100644
--- a/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/ReplicationsClientImpl.java
+++ b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/ReplicationsClientImpl.java
@@ -184,7 +184,7 @@ private Mono> listSinglePageAsync(String resourc
if (registryName == null) {
return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -244,7 +244,7 @@ private Mono> listSinglePageAsync(
if (registryName == null) {
return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -374,7 +374,7 @@ public Mono> getWithResponseAsync(
return Mono
.error(new IllegalArgumentException("Parameter replicationName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -431,7 +431,7 @@ private Mono> getWithResponseAsync(
return Mono
.error(new IllegalArgumentException("Parameter replicationName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -541,7 +541,7 @@ public Mono>> createWithResponseAsync(
} else {
replication.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -609,7 +609,7 @@ private Mono>> createWithResponseAsync(
} else {
replication.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -849,7 +849,7 @@ public Mono>> deleteWithResponseAsync(
return Mono
.error(new IllegalArgumentException("Parameter replicationName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
return FluxUtil
.withContext(
context ->
@@ -903,7 +903,7 @@ private Mono>> deleteWithResponseAsync(
return Mono
.error(new IllegalArgumentException("Parameter replicationName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
context = this.client.mergeContext(context);
return service
.delete(
@@ -1115,7 +1115,7 @@ public Mono>> updateWithResponseAsync(
} else {
replicationUpdateParameters.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -1186,7 +1186,7 @@ private Mono>> updateWithResponseAsync(
} else {
replicationUpdateParameters.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
diff --git a/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/ScopeMapsClientImpl.java b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/ScopeMapsClientImpl.java
index 29f8b4baa12df..3e49103006b7e 100644
--- a/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/ScopeMapsClientImpl.java
+++ b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/ScopeMapsClientImpl.java
@@ -185,7 +185,7 @@ private Mono> listSinglePageAsync(String resourceGr
if (registryName == null) {
return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -245,7 +245,7 @@ private Mono> listSinglePageAsync(
if (registryName == null) {
return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -374,7 +374,7 @@ public Mono> getWithResponseAsync(
if (scopeMapName == null) {
return Mono.error(new IllegalArgumentException("Parameter scopeMapName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -430,7 +430,7 @@ private Mono> getWithResponseAsync(
if (scopeMapName == null) {
return Mono.error(new IllegalArgumentException("Parameter scopeMapName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -541,7 +541,7 @@ public Mono>> createWithResponseAsync(
} else {
scopeMapCreateParameters.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -610,7 +610,7 @@ private Mono>> createWithResponseAsync(
} else {
scopeMapCreateParameters.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -849,7 +849,7 @@ public Mono>> deleteWithResponseAsync(
if (scopeMapName == null) {
return Mono.error(new IllegalArgumentException("Parameter scopeMapName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -904,7 +904,7 @@ private Mono>> deleteWithResponseAsync(
if (scopeMapName == null) {
return Mono.error(new IllegalArgumentException("Parameter scopeMapName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -1115,7 +1115,7 @@ public Mono>> updateWithResponseAsync(
} else {
scopeMapUpdateParameters.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -1184,7 +1184,7 @@ private Mono>> updateWithResponseAsync(
} else {
scopeMapUpdateParameters.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
diff --git a/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/TokensClientImpl.java b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/TokensClientImpl.java
index 202abcfe8d42f..fe3e3c50a8ade 100644
--- a/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/TokensClientImpl.java
+++ b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/TokensClientImpl.java
@@ -184,7 +184,7 @@ private Mono> listSinglePageAsync(String resourceGroup
if (registryName == null) {
return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -244,7 +244,7 @@ private Mono> listSinglePageAsync(
if (registryName == null) {
return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -373,7 +373,7 @@ public Mono> getWithResponseAsync(
if (tokenName == null) {
return Mono.error(new IllegalArgumentException("Parameter tokenName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -429,7 +429,7 @@ private Mono> getWithResponseAsync(
if (tokenName == null) {
return Mono.error(new IllegalArgumentException("Parameter tokenName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -539,7 +539,7 @@ public Mono>> createWithResponseAsync(
} else {
tokenCreateParameters.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -607,7 +607,7 @@ private Mono>> createWithResponseAsync(
} else {
tokenCreateParameters.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -840,7 +840,7 @@ public Mono>> deleteWithResponseAsync(
if (tokenName == null) {
return Mono.error(new IllegalArgumentException("Parameter tokenName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -895,7 +895,7 @@ private Mono>> deleteWithResponseAsync(
if (tokenName == null) {
return Mono.error(new IllegalArgumentException("Parameter tokenName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -1101,7 +1101,7 @@ public Mono>> updateWithResponseAsync(
} else {
tokenUpdateParameters.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -1169,7 +1169,7 @@ private Mono>> updateWithResponseAsync(
} else {
tokenUpdateParameters.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
diff --git a/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/WebhooksClientImpl.java b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/WebhooksClientImpl.java
index bf612aa5fc234..d911336a147f5 100644
--- a/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/WebhooksClientImpl.java
+++ b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/implementation/WebhooksClientImpl.java
@@ -244,7 +244,7 @@ private Mono> listSinglePageAsync(String resourceGro
if (registryName == null) {
return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -304,7 +304,7 @@ private Mono> listSinglePageAsync(
if (registryName == null) {
return Mono.error(new IllegalArgumentException("Parameter registryName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -433,7 +433,7 @@ public Mono> getWithResponseAsync(
if (webhookName == null) {
return Mono.error(new IllegalArgumentException("Parameter webhookName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -489,7 +489,7 @@ private Mono> getWithResponseAsync(
if (webhookName == null) {
return Mono.error(new IllegalArgumentException("Parameter webhookName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -603,7 +603,7 @@ public Mono>> createWithResponseAsync(
} else {
webhookCreateParameters.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -672,7 +672,7 @@ private Mono>> createWithResponseAsync(
} else {
webhookCreateParameters.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -919,7 +919,7 @@ public Mono>> deleteWithResponseAsync(
if (webhookName == null) {
return Mono.error(new IllegalArgumentException("Parameter webhookName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
return FluxUtil
.withContext(
context ->
@@ -972,7 +972,7 @@ private Mono>> deleteWithResponseAsync(
if (webhookName == null) {
return Mono.error(new IllegalArgumentException("Parameter webhookName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
context = this.client.mergeContext(context);
return service
.delete(
@@ -1180,7 +1180,7 @@ public Mono>> updateWithResponseAsync(
} else {
webhookUpdateParameters.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -1249,7 +1249,7 @@ private Mono>> updateWithResponseAsync(
} else {
webhookUpdateParameters.validate();
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -1496,7 +1496,7 @@ public Mono> pingWithResponseAsync(
if (webhookName == null) {
return Mono.error(new IllegalArgumentException("Parameter webhookName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -1551,7 +1551,7 @@ private Mono> pingWithResponseAsync(
if (webhookName == null) {
return Mono.error(new IllegalArgumentException("Parameter webhookName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -1654,7 +1654,7 @@ private Mono> listEventsSinglePageAsync(
if (webhookName == null) {
return Mono.error(new IllegalArgumentException("Parameter webhookName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -1719,7 +1719,7 @@ private Mono> listEventsSinglePageAsync(
if (webhookName == null) {
return Mono.error(new IllegalArgumentException("Parameter webhookName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
@@ -1852,7 +1852,7 @@ public Mono> getCallbackConfigWithResponseAsync(
if (webhookName == null) {
return Mono.error(new IllegalArgumentException("Parameter webhookName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
return FluxUtil
.withContext(
@@ -1908,7 +1908,7 @@ private Mono> getCallbackConfigWithResponseAsync(
if (webhookName == null) {
return Mono.error(new IllegalArgumentException("Parameter webhookName is required and cannot be null."));
}
- final String apiVersion = "2022-12-01";
+ final String apiVersion = "2023-07-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
diff --git a/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/models/AuthCredential.java b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/models/AuthCredential.java
new file mode 100644
index 0000000000000..8d09b022e7c21
--- /dev/null
+++ b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/models/AuthCredential.java
@@ -0,0 +1,120 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) AutoRest Code Generator.
+
+package com.azure.resourcemanager.containerregistry.models;
+
+import com.azure.core.annotation.Fluent;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/** Authentication credential stored for an upstream. */
+@Fluent
+public final class AuthCredential {
+ /*
+ * The name of the credential.
+ */
+ @JsonProperty(value = "name")
+ private CredentialName name;
+
+ /*
+ * KeyVault Secret URI for accessing the username.
+ */
+ @JsonProperty(value = "usernameSecretIdentifier")
+ private String usernameSecretIdentifier;
+
+ /*
+ * KeyVault Secret URI for accessing the password.
+ */
+ @JsonProperty(value = "passwordSecretIdentifier")
+ private String passwordSecretIdentifier;
+
+ /*
+ * This provides data pertaining to the health of the auth credential.
+ */
+ @JsonProperty(value = "credentialHealth", access = JsonProperty.Access.WRITE_ONLY)
+ private CredentialHealth credentialHealth;
+
+ /** Creates an instance of AuthCredential class. */
+ public AuthCredential() {
+ }
+
+ /**
+ * Get the name property: The name of the credential.
+ *
+ * @return the name value.
+ */
+ public CredentialName name() {
+ return this.name;
+ }
+
+ /**
+ * Set the name property: The name of the credential.
+ *
+ * @param name the name value to set.
+ * @return the AuthCredential object itself.
+ */
+ public AuthCredential withName(CredentialName name) {
+ this.name = name;
+ return this;
+ }
+
+ /**
+ * Get the usernameSecretIdentifier property: KeyVault Secret URI for accessing the username.
+ *
+ * @return the usernameSecretIdentifier value.
+ */
+ public String usernameSecretIdentifier() {
+ return this.usernameSecretIdentifier;
+ }
+
+ /**
+ * Set the usernameSecretIdentifier property: KeyVault Secret URI for accessing the username.
+ *
+ * @param usernameSecretIdentifier the usernameSecretIdentifier value to set.
+ * @return the AuthCredential object itself.
+ */
+ public AuthCredential withUsernameSecretIdentifier(String usernameSecretIdentifier) {
+ this.usernameSecretIdentifier = usernameSecretIdentifier;
+ return this;
+ }
+
+ /**
+ * Get the passwordSecretIdentifier property: KeyVault Secret URI for accessing the password.
+ *
+ * @return the passwordSecretIdentifier value.
+ */
+ public String passwordSecretIdentifier() {
+ return this.passwordSecretIdentifier;
+ }
+
+ /**
+ * Set the passwordSecretIdentifier property: KeyVault Secret URI for accessing the password.
+ *
+ * @param passwordSecretIdentifier the passwordSecretIdentifier value to set.
+ * @return the AuthCredential object itself.
+ */
+ public AuthCredential withPasswordSecretIdentifier(String passwordSecretIdentifier) {
+ this.passwordSecretIdentifier = passwordSecretIdentifier;
+ return this;
+ }
+
+ /**
+ * Get the credentialHealth property: This provides data pertaining to the health of the auth credential.
+ *
+ * @return the credentialHealth value.
+ */
+ public CredentialHealth credentialHealth() {
+ return this.credentialHealth;
+ }
+
+ /**
+ * Validates the instance.
+ *
+ * @throws IllegalArgumentException thrown if the instance is not valid.
+ */
+ public void validate() {
+ if (credentialHealth() != null) {
+ credentialHealth().validate();
+ }
+ }
+}
diff --git a/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/models/CacheRuleUpdateParameters.java b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/models/CacheRuleUpdateParameters.java
new file mode 100644
index 0000000000000..66f376cc3a745
--- /dev/null
+++ b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/models/CacheRuleUpdateParameters.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.containerregistry.models;
+
+import com.azure.core.annotation.Fluent;
+import com.azure.resourcemanager.containerregistry.fluent.models.CacheRuleUpdateProperties;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/** The parameters for updating a cache rule. */
+@Fluent
+public final class CacheRuleUpdateParameters {
+ /*
+ * The properties of the cache rule update parameters.
+ */
+ @JsonProperty(value = "properties")
+ private CacheRuleUpdateProperties innerProperties;
+
+ /** Creates an instance of CacheRuleUpdateParameters class. */
+ public CacheRuleUpdateParameters() {
+ }
+
+ /**
+ * Get the innerProperties property: The properties of the cache rule update parameters.
+ *
+ * @return the innerProperties value.
+ */
+ private CacheRuleUpdateProperties innerProperties() {
+ return this.innerProperties;
+ }
+
+ /**
+ * Get the credentialSetResourceId property: The ARM resource ID of the credential store which is associated with
+ * the Cache rule.
+ *
+ * @return the credentialSetResourceId value.
+ */
+ public String credentialSetResourceId() {
+ return this.innerProperties() == null ? null : this.innerProperties().credentialSetResourceId();
+ }
+
+ /**
+ * Set the credentialSetResourceId property: The ARM resource ID of the credential store which is associated with
+ * the Cache rule.
+ *
+ * @param credentialSetResourceId the credentialSetResourceId value to set.
+ * @return the CacheRuleUpdateParameters object itself.
+ */
+ public CacheRuleUpdateParameters withCredentialSetResourceId(String credentialSetResourceId) {
+ if (this.innerProperties() == null) {
+ this.innerProperties = new CacheRuleUpdateProperties();
+ }
+ this.innerProperties().withCredentialSetResourceId(credentialSetResourceId);
+ return this;
+ }
+
+ /**
+ * Validates the instance.
+ *
+ * @throws IllegalArgumentException thrown if the instance is not valid.
+ */
+ public void validate() {
+ if (innerProperties() != null) {
+ innerProperties().validate();
+ }
+ }
+}
diff --git a/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/models/CacheRulesListResult.java b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/models/CacheRulesListResult.java
new file mode 100644
index 0000000000000..8b093fd0fd39e
--- /dev/null
+++ b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/models/CacheRulesListResult.java
@@ -0,0 +1,81 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) AutoRest Code Generator.
+
+package com.azure.resourcemanager.containerregistry.models;
+
+import com.azure.core.annotation.Fluent;
+import com.azure.resourcemanager.containerregistry.fluent.models.CacheRuleInner;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import java.util.List;
+
+/** The result of a request to list cache rules for a container registry. */
+@Fluent
+public final class CacheRulesListResult {
+ /*
+ * The list of cache rules.
+ */
+ @JsonProperty(value = "value")
+ private List value;
+
+ /*
+ * If provided, client must use NextLink URI to request next list of cache rules.
+ */
+ @JsonProperty(value = "nextLink")
+ private String nextLink;
+
+ /** Creates an instance of CacheRulesListResult class. */
+ public CacheRulesListResult() {
+ }
+
+ /**
+ * Get the value property: The list of cache rules.
+ *
+ * @return the value value.
+ */
+ public List value() {
+ return this.value;
+ }
+
+ /**
+ * Set the value property: The list of cache rules.
+ *
+ * @param value the value value to set.
+ * @return the CacheRulesListResult object itself.
+ */
+ public CacheRulesListResult withValue(List value) {
+ this.value = value;
+ return this;
+ }
+
+ /**
+ * Get the nextLink property: If provided, client must use NextLink URI to request next list of cache rules.
+ *
+ * @return the nextLink value.
+ */
+ public String nextLink() {
+ return this.nextLink;
+ }
+
+ /**
+ * Set the nextLink property: If provided, client must use NextLink URI to request next list of cache rules.
+ *
+ * @param nextLink the nextLink value to set.
+ * @return the CacheRulesListResult object itself.
+ */
+ public CacheRulesListResult withNextLink(String nextLink) {
+ this.nextLink = nextLink;
+ return this;
+ }
+
+ /**
+ * Validates the instance.
+ *
+ * @throws IllegalArgumentException thrown if the instance is not valid.
+ */
+ public void validate() {
+ if (value() != null) {
+ value().forEach(e -> e.validate());
+ }
+ }
+}
diff --git a/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/models/CredentialHealth.java b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/models/CredentialHealth.java
new file mode 100644
index 0000000000000..31cd94d24aa2c
--- /dev/null
+++ b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/models/CredentialHealth.java
@@ -0,0 +1,102 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) AutoRest Code Generator.
+
+package com.azure.resourcemanager.containerregistry.models;
+
+import com.azure.core.annotation.Fluent;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/** The health of the auth credential. */
+@Fluent
+public final class CredentialHealth {
+ /*
+ * The health status of credential.
+ */
+ @JsonProperty(value = "status")
+ private CredentialHealthStatus status;
+
+ /*
+ * Error code representing the health check error.
+ */
+ @JsonProperty(value = "errorCode")
+ private String errorCode;
+
+ /*
+ * Descriptive message representing the health check error.
+ */
+ @JsonProperty(value = "errorMessage")
+ private String errorMessage;
+
+ /** Creates an instance of CredentialHealth class. */
+ public CredentialHealth() {
+ }
+
+ /**
+ * Get the status property: The health status of credential.
+ *
+ * @return the status value.
+ */
+ public CredentialHealthStatus status() {
+ return this.status;
+ }
+
+ /**
+ * Set the status property: The health status of credential.
+ *
+ * @param status the status value to set.
+ * @return the CredentialHealth object itself.
+ */
+ public CredentialHealth withStatus(CredentialHealthStatus status) {
+ this.status = status;
+ return this;
+ }
+
+ /**
+ * Get the errorCode property: Error code representing the health check error.
+ *
+ * @return the errorCode value.
+ */
+ public String errorCode() {
+ return this.errorCode;
+ }
+
+ /**
+ * Set the errorCode property: Error code representing the health check error.
+ *
+ * @param errorCode the errorCode value to set.
+ * @return the CredentialHealth object itself.
+ */
+ public CredentialHealth withErrorCode(String errorCode) {
+ this.errorCode = errorCode;
+ return this;
+ }
+
+ /**
+ * Get the errorMessage property: Descriptive message representing the health check error.
+ *
+ * @return the errorMessage value.
+ */
+ public String errorMessage() {
+ return this.errorMessage;
+ }
+
+ /**
+ * Set the errorMessage property: Descriptive message representing the health check error.
+ *
+ * @param errorMessage the errorMessage value to set.
+ * @return the CredentialHealth object itself.
+ */
+ public CredentialHealth withErrorMessage(String errorMessage) {
+ this.errorMessage = errorMessage;
+ return this;
+ }
+
+ /**
+ * Validates the instance.
+ *
+ * @throws IllegalArgumentException thrown if the instance is not valid.
+ */
+ public void validate() {
+ }
+}
diff --git a/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/models/CredentialHealthStatus.java b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/models/CredentialHealthStatus.java
new file mode 100644
index 0000000000000..abc572cf34cd4
--- /dev/null
+++ b/sdk/resourcemanager/azure-resourcemanager-containerregistry/src/main/java/com/azure/resourcemanager/containerregistry/models/CredentialHealthStatus.java
@@ -0,0 +1,47 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) AutoRest Code Generator.
+
+package com.azure.resourcemanager.containerregistry.models;
+
+import com.azure.core.util.ExpandableStringEnum;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import java.util.Collection;
+
+/** The health status of credential. */
+public final class CredentialHealthStatus extends ExpandableStringEnum