deleteAsync(
+ String deviceName, String roleName, String addonName, String resourceGroupName, Context context) {
+ return beginDeleteAsync(deviceName, roleName, addonName, resourceGroupName, context)
+ .last()
+ .flatMap(this.client::getLroFinalResultOrError);
+ }
+
+ /**
+ * Deletes the addon on the device.
+ *
+ * @param deviceName The device name.
+ * @param roleName The role name.
+ * @param addonName The addon name.
+ * @param resourceGroupName The resource group name.
+ * @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 deviceName, String roleName, String addonName, String resourceGroupName) {
+ deleteAsync(deviceName, roleName, addonName, resourceGroupName).block();
+ }
+
+ /**
+ * Deletes the addon on the device.
+ *
+ * @param deviceName The device name.
+ * @param roleName The role name.
+ * @param addonName The addon name.
+ * @param resourceGroupName The resource group name.
+ * @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 deviceName, String roleName, String addonName, String resourceGroupName, Context context) {
+ deleteAsync(deviceName, roleName, addonName, resourceGroupName, 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 collection of all the Role addon on the Azure Stack Edge device along with {@link PagedResponse} on
+ * successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private Mono> listByRoleNextSinglePageAsync(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.listByRoleNext(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 collection of all the Role addon on the Azure Stack Edge device along with {@link PagedResponse} on
+ * successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private Mono> listByRoleNextSinglePageAsync(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
+ .listByRoleNext(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/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/AddonsImpl.java b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/AddonsImpl.java
new file mode 100644
index 000000000000..87e2017d4398
--- /dev/null
+++ b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/AddonsImpl.java
@@ -0,0 +1,109 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) AutoRest Code Generator.
+
+package com.azure.resourcemanager.databoxedge.implementation;
+
+import com.azure.core.http.rest.PagedIterable;
+import com.azure.core.http.rest.Response;
+import com.azure.core.http.rest.SimpleResponse;
+import com.azure.core.util.Context;
+import com.azure.core.util.logging.ClientLogger;
+import com.azure.resourcemanager.databoxedge.fluent.AddonsClient;
+import com.azure.resourcemanager.databoxedge.fluent.models.AddonInner;
+import com.azure.resourcemanager.databoxedge.models.Addon;
+import com.azure.resourcemanager.databoxedge.models.Addons;
+
+public final class AddonsImpl implements Addons {
+ private static final ClientLogger LOGGER = new ClientLogger(AddonsImpl.class);
+
+ private final AddonsClient innerClient;
+
+ private final com.azure.resourcemanager.databoxedge.DataBoxEdgeManager serviceManager;
+
+ public AddonsImpl(
+ AddonsClient innerClient, com.azure.resourcemanager.databoxedge.DataBoxEdgeManager serviceManager) {
+ this.innerClient = innerClient;
+ this.serviceManager = serviceManager;
+ }
+
+ public PagedIterable listByRole(String deviceName, String roleName, String resourceGroupName) {
+ PagedIterable inner = this.serviceClient().listByRole(deviceName, roleName, resourceGroupName);
+ return Utils.mapPage(inner, inner1 -> new AddonImpl(inner1, this.manager()));
+ }
+
+ public PagedIterable listByRole(
+ String deviceName, String roleName, String resourceGroupName, Context context) {
+ PagedIterable inner =
+ this.serviceClient().listByRole(deviceName, roleName, resourceGroupName, context);
+ return Utils.mapPage(inner, inner1 -> new AddonImpl(inner1, this.manager()));
+ }
+
+ public Response getWithResponse(
+ String deviceName, String roleName, String addonName, String resourceGroupName, Context context) {
+ Response inner =
+ this.serviceClient().getWithResponse(deviceName, roleName, addonName, resourceGroupName, context);
+ if (inner != null) {
+ return new SimpleResponse<>(
+ inner.getRequest(),
+ inner.getStatusCode(),
+ inner.getHeaders(),
+ new AddonImpl(inner.getValue(), this.manager()));
+ } else {
+ return null;
+ }
+ }
+
+ public Addon get(String deviceName, String roleName, String addonName, String resourceGroupName) {
+ AddonInner inner = this.serviceClient().get(deviceName, roleName, addonName, resourceGroupName);
+ if (inner != null) {
+ return new AddonImpl(inner, this.manager());
+ } else {
+ return null;
+ }
+ }
+
+ public Addon createOrUpdate(
+ String deviceName, String roleName, String addonName, String resourceGroupName, AddonInner addon) {
+ AddonInner inner =
+ this.serviceClient().createOrUpdate(deviceName, roleName, addonName, resourceGroupName, addon);
+ if (inner != null) {
+ return new AddonImpl(inner, this.manager());
+ } else {
+ return null;
+ }
+ }
+
+ public Addon createOrUpdate(
+ String deviceName,
+ String roleName,
+ String addonName,
+ String resourceGroupName,
+ AddonInner addon,
+ Context context) {
+ AddonInner inner =
+ this.serviceClient().createOrUpdate(deviceName, roleName, addonName, resourceGroupName, addon, context);
+ if (inner != null) {
+ return new AddonImpl(inner, this.manager());
+ } else {
+ return null;
+ }
+ }
+
+ public void delete(String deviceName, String roleName, String addonName, String resourceGroupName) {
+ this.serviceClient().delete(deviceName, roleName, addonName, resourceGroupName);
+ }
+
+ public void delete(
+ String deviceName, String roleName, String addonName, String resourceGroupName, Context context) {
+ this.serviceClient().delete(deviceName, roleName, addonName, resourceGroupName, context);
+ }
+
+ private AddonsClient serviceClient() {
+ return this.innerClient;
+ }
+
+ private com.azure.resourcemanager.databoxedge.DataBoxEdgeManager manager() {
+ return this.serviceManager;
+ }
+}
diff --git a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/AlertImpl.java b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/AlertImpl.java
index a2a300d70750..5a72fc29ea83 100644
--- a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/AlertImpl.java
+++ b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/AlertImpl.java
@@ -4,6 +4,7 @@
package com.azure.resourcemanager.databoxedge.implementation;
+import com.azure.core.management.SystemData;
import com.azure.resourcemanager.databoxedge.fluent.models.AlertInner;
import com.azure.resourcemanager.databoxedge.models.Alert;
import com.azure.resourcemanager.databoxedge.models.AlertErrorDetails;
@@ -34,6 +35,10 @@ public String type() {
return this.innerModel().type();
}
+ public SystemData systemData() {
+ return this.innerModel().systemData();
+ }
+
public String title() {
return this.innerModel().title();
}
diff --git a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/AlertsClientImpl.java b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/AlertsClientImpl.java
index 6b8a74482c6c..8065889c3996 100644
--- a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/AlertsClientImpl.java
+++ b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/AlertsClientImpl.java
@@ -57,8 +57,7 @@ public final class AlertsClientImpl implements AlertsClient {
public interface AlertsService {
@Headers({"Content-Type: application/json"})
@Get(
- "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataBoxEdge"
- + "/dataBoxEdgeDevices/{deviceName}/alerts")
+ "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataBoxEdge/dataBoxEdgeDevices/{deviceName}/alerts")
@ExpectedResponses({200})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono> listByDataBoxEdgeDevice(
@@ -72,8 +71,7 @@ Mono> listByDataBoxEdgeDevice(
@Headers({"Content-Type: application/json"})
@Get(
- "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataBoxEdge"
- + "/dataBoxEdgeDevices/{deviceName}/alerts/{name}")
+ "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataBoxEdge/dataBoxEdgeDevices/{deviceName}/alerts/{name}")
@ExpectedResponses({200})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono> get(
diff --git a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/SkusClientImpl.java b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/AvailableSkusClientImpl.java
similarity index 54%
rename from sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/SkusClientImpl.java
rename to sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/AvailableSkusClientImpl.java
index 9f2a903fba01..1ef1fe5230e4 100644
--- a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/SkusClientImpl.java
+++ b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/AvailableSkusClientImpl.java
@@ -25,61 +25,69 @@
import com.azure.core.management.exception.ManagementException;
import com.azure.core.util.Context;
import com.azure.core.util.FluxUtil;
-import com.azure.resourcemanager.databoxedge.fluent.SkusClient;
-import com.azure.resourcemanager.databoxedge.fluent.models.ResourceTypeSkuInner;
-import com.azure.resourcemanager.databoxedge.models.SkuInformationList;
+import com.azure.resourcemanager.databoxedge.fluent.AvailableSkusClient;
+import com.azure.resourcemanager.databoxedge.fluent.models.DataBoxEdgeSkuInner;
+import com.azure.resourcemanager.databoxedge.models.DataBoxEdgeSkuList;
import reactor.core.publisher.Mono;
-/** An instance of this class provides access to all the operations defined in SkusClient. */
-public final class SkusClientImpl implements SkusClient {
+/** An instance of this class provides access to all the operations defined in AvailableSkusClient. */
+public final class AvailableSkusClientImpl implements AvailableSkusClient {
/** The proxy service used to perform REST calls. */
- private final SkusService service;
+ private final AvailableSkusService service;
/** The service client containing this operation class. */
private final DataBoxEdgeManagementClientImpl client;
/**
- * Initializes an instance of SkusClientImpl.
+ * Initializes an instance of AvailableSkusClientImpl.
*
* @param client the instance of the service client containing this operation class.
*/
- SkusClientImpl(DataBoxEdgeManagementClientImpl client) {
- this.service = RestProxy.create(SkusService.class, client.getHttpPipeline(), client.getSerializerAdapter());
+ AvailableSkusClientImpl(DataBoxEdgeManagementClientImpl client) {
+ this.service =
+ RestProxy.create(AvailableSkusService.class, client.getHttpPipeline(), client.getSerializerAdapter());
this.client = client;
}
/**
- * The interface defining all the services for DataBoxEdgeManagementClientSkus to be used by the proxy service to
- * perform REST calls.
+ * The interface defining all the services for DataBoxEdgeManagementClientAvailableSkus to be used by the proxy
+ * service to perform REST calls.
*/
@Host("{$host}")
@ServiceInterface(name = "DataBoxEdgeManagemen")
- public interface SkusService {
+ public interface AvailableSkusService {
@Headers({"Content-Type: application/json"})
- @Get("/subscriptions/{subscriptionId}/providers/Microsoft.DataBoxEdge/skus")
+ @Get("/subscriptions/{subscriptionId}/providers/Microsoft.DataBoxEdge/availableSkus")
@ExpectedResponses({200})
@UnexpectedResponseExceptionType(ManagementException.class)
- Mono> list(
+ Mono> list(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@QueryParam("api-version") String apiVersion,
- @QueryParam("$filter") String filter,
+ @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);
}
/**
- * List all the available Skus in the region and information related to them.
+ * List all the available Skus and information related to them.
*
- * @param filter Specify $filter='location eq <location>' to filter on location.
- * @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 list of SKU Information objects along with {@link PagedResponse} on successful completion of {@link
* Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
- private Mono> listSinglePageAsync(String filter) {
+ private Mono> listSinglePageAsync() {
if (this.client.getEndpoint() == null) {
return Mono
.error(
@@ -101,20 +109,23 @@ private Mono> listSinglePageAsync(String fil
this.client.getEndpoint(),
this.client.getSubscriptionId(),
this.client.getApiVersion(),
- filter,
accept,
context))
- .>map(
+ .>map(
res ->
new PagedResponseBase<>(
- res.getRequest(), res.getStatusCode(), res.getHeaders(), res.getValue().value(), null, null))
+ res.getRequest(),
+ res.getStatusCode(),
+ res.getHeaders(),
+ res.getValue().value(),
+ res.getValue().nextLink(),
+ null))
.contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
}
/**
- * List all the available Skus in the region and information related to them.
+ * List all the available Skus and information related to them.
*
- * @param filter Specify $filter='location eq <location>' to filter on location.
* @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.
@@ -123,7 +134,7 @@ private Mono> listSinglePageAsync(String fil
* Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
- private Mono> listSinglePageAsync(String filter, Context context) {
+ private Mono> listSinglePageAsync(Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
@@ -143,82 +154,144 @@ private Mono> listSinglePageAsync(String fil
this.client.getEndpoint(),
this.client.getSubscriptionId(),
this.client.getApiVersion(),
- filter,
accept,
context)
.map(
res ->
new PagedResponseBase<>(
- res.getRequest(), res.getStatusCode(), res.getHeaders(), res.getValue().value(), null, null));
+ res.getRequest(),
+ res.getStatusCode(),
+ res.getHeaders(),
+ res.getValue().value(),
+ res.getValue().nextLink(),
+ null));
}
/**
- * List all the available Skus in the region and information related to them.
+ * List all the available Skus and information related to them.
*
- * @param filter Specify $filter='location eq <location>' to filter on location.
- * @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 list of SKU Information objects as paginated response with {@link PagedFlux}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
- private PagedFlux listAsync(String filter) {
- return new PagedFlux<>(() -> listSinglePageAsync(filter));
+ private PagedFlux listAsync() {
+ return new PagedFlux<>(() -> listSinglePageAsync(), nextLink -> listNextSinglePageAsync(nextLink));
}
/**
- * List all the available Skus in the region and information related to them.
+ * List all the available Skus and information related to them.
*
+ * @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 list of SKU Information objects as paginated response with {@link PagedFlux}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
- private PagedFlux listAsync() {
- final String filter = null;
- return new PagedFlux<>(() -> listSinglePageAsync(filter));
+ private PagedFlux listAsync(Context context) {
+ return new PagedFlux<>(
+ () -> listSinglePageAsync(context), nextLink -> listNextSinglePageAsync(nextLink, context));
}
/**
- * List all the available Skus in the region and information related to them.
+ * List all the available Skus and information related to them.
*
- * @param filter Specify $filter='location eq <location>' to filter on location.
- * @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 list of SKU Information objects as paginated response with {@link PagedFlux}.
+ * @return list of SKU Information objects as paginated response with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
- private PagedFlux listAsync(String filter, Context context) {
- return new PagedFlux<>(() -> listSinglePageAsync(filter, context));
+ public PagedIterable list() {
+ return new PagedIterable<>(listAsync());
}
/**
- * List all the available Skus in the region and information related to them.
+ * List all the available Skus and information related to them.
*
+ * @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 list of SKU Information objects as paginated response with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
- public PagedIterable list() {
- final String filter = null;
- return new PagedIterable<>(listAsync(filter));
+ public PagedIterable list(Context context) {
+ return new PagedIterable<>(listAsync(context));
+ }
+
+ /**
+ * 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 list of SKU Information objects 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()));
}
/**
- * List all the available Skus in the region and information related to them.
+ * Get the next page of items.
*
- * @param filter Specify $filter='location eq <location>' to filter on location.
+ * @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 list of SKU Information objects as paginated response with {@link PagedIterable}.
+ * @return list of SKU Information objects along with {@link PagedResponse} on successful completion of {@link
+ * Mono}.
*/
- @ServiceMethod(returns = ReturnType.COLLECTION)
- public PagedIterable list(String filter, Context context) {
- return new PagedIterable<>(listAsync(filter, context));
+ @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/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/AvailableSkusImpl.java b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/AvailableSkusImpl.java
new file mode 100644
index 000000000000..7130a764c9e8
--- /dev/null
+++ b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/AvailableSkusImpl.java
@@ -0,0 +1,45 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) AutoRest Code Generator.
+
+package com.azure.resourcemanager.databoxedge.implementation;
+
+import com.azure.core.http.rest.PagedIterable;
+import com.azure.core.util.Context;
+import com.azure.core.util.logging.ClientLogger;
+import com.azure.resourcemanager.databoxedge.fluent.AvailableSkusClient;
+import com.azure.resourcemanager.databoxedge.fluent.models.DataBoxEdgeSkuInner;
+import com.azure.resourcemanager.databoxedge.models.AvailableSkus;
+import com.azure.resourcemanager.databoxedge.models.DataBoxEdgeSku;
+
+public final class AvailableSkusImpl implements AvailableSkus {
+ private static final ClientLogger LOGGER = new ClientLogger(AvailableSkusImpl.class);
+
+ private final AvailableSkusClient innerClient;
+
+ private final com.azure.resourcemanager.databoxedge.DataBoxEdgeManager serviceManager;
+
+ public AvailableSkusImpl(
+ AvailableSkusClient innerClient, com.azure.resourcemanager.databoxedge.DataBoxEdgeManager serviceManager) {
+ this.innerClient = innerClient;
+ this.serviceManager = serviceManager;
+ }
+
+ public PagedIterable list() {
+ PagedIterable inner = this.serviceClient().list();
+ return Utils.mapPage(inner, inner1 -> new DataBoxEdgeSkuImpl(inner1, this.manager()));
+ }
+
+ public PagedIterable list(Context context) {
+ PagedIterable inner = this.serviceClient().list(context);
+ return Utils.mapPage(inner, inner1 -> new DataBoxEdgeSkuImpl(inner1, this.manager()));
+ }
+
+ private AvailableSkusClient serviceClient() {
+ return this.innerClient;
+ }
+
+ private com.azure.resourcemanager.databoxedge.DataBoxEdgeManager manager() {
+ return this.serviceManager;
+ }
+}
diff --git a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/BandwidthScheduleImpl.java b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/BandwidthScheduleImpl.java
index 41065fd948fd..37fe8d812f08 100644
--- a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/BandwidthScheduleImpl.java
+++ b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/BandwidthScheduleImpl.java
@@ -4,6 +4,7 @@
package com.azure.resourcemanager.databoxedge.implementation;
+import com.azure.core.management.SystemData;
import com.azure.core.util.Context;
import com.azure.resourcemanager.databoxedge.fluent.models.BandwidthScheduleInner;
import com.azure.resourcemanager.databoxedge.models.BandwidthSchedule;
@@ -29,6 +30,10 @@ public String type() {
return this.innerModel().type();
}
+ public SystemData systemData() {
+ return this.innerModel().systemData();
+ }
+
public String start() {
return this.innerModel().start();
}
diff --git a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/BandwidthSchedulesClientImpl.java b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/BandwidthSchedulesClientImpl.java
index 4509586d8778..49ccdfe434e3 100644
--- a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/BandwidthSchedulesClientImpl.java
+++ b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/BandwidthSchedulesClientImpl.java
@@ -66,8 +66,7 @@ public final class BandwidthSchedulesClientImpl implements BandwidthSchedulesCli
public interface BandwidthSchedulesService {
@Headers({"Content-Type: application/json"})
@Get(
- "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataBoxEdge"
- + "/dataBoxEdgeDevices/{deviceName}/bandwidthSchedules")
+ "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataBoxEdge/dataBoxEdgeDevices/{deviceName}/bandwidthSchedules")
@ExpectedResponses({200})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono> listByDataBoxEdgeDevice(
@@ -81,8 +80,7 @@ Mono> listByDataBoxEdgeDevice(
@Headers({"Content-Type: application/json"})
@Get(
- "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataBoxEdge"
- + "/dataBoxEdgeDevices/{deviceName}/bandwidthSchedules/{name}")
+ "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataBoxEdge/dataBoxEdgeDevices/{deviceName}/bandwidthSchedules/{name}")
@ExpectedResponses({200})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono> get(
@@ -97,8 +95,7 @@ Mono> get(
@Headers({"Content-Type: application/json"})
@Put(
- "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataBoxEdge"
- + "/dataBoxEdgeDevices/{deviceName}/bandwidthSchedules/{name}")
+ "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataBoxEdge/dataBoxEdgeDevices/{deviceName}/bandwidthSchedules/{name}")
@ExpectedResponses({200, 202})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono>> createOrUpdate(
@@ -114,8 +111,7 @@ Mono>> createOrUpdate(
@Headers({"Content-Type: application/json"})
@Delete(
- "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataBoxEdge"
- + "/dataBoxEdgeDevices/{deviceName}/bandwidthSchedules/{name}")
+ "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataBoxEdge/dataBoxEdgeDevices/{deviceName}/bandwidthSchedules/{name}")
@ExpectedResponses({200, 202, 204})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono>> delete(
diff --git a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/ContainerImpl.java b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/ContainerImpl.java
index 28e0532ada95..cee791508a73 100644
--- a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/ContainerImpl.java
+++ b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/ContainerImpl.java
@@ -4,6 +4,7 @@
package com.azure.resourcemanager.databoxedge.implementation;
+import com.azure.core.management.SystemData;
import com.azure.core.util.Context;
import com.azure.resourcemanager.databoxedge.fluent.models.ContainerInner;
import com.azure.resourcemanager.databoxedge.models.AzureContainerDataFormat;
@@ -29,6 +30,10 @@ public String type() {
return this.innerModel().type();
}
+ public SystemData systemData() {
+ return this.innerModel().systemData();
+ }
+
public ContainerStatus containerStatus() {
return this.innerModel().containerStatus();
}
diff --git a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/ContainersClientImpl.java b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/ContainersClientImpl.java
index 4b8c8bbfe16e..bc525ae4c2aa 100644
--- a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/ContainersClientImpl.java
+++ b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/ContainersClientImpl.java
@@ -67,8 +67,7 @@ public final class ContainersClientImpl implements ContainersClient {
public interface ContainersService {
@Headers({"Content-Type: application/json"})
@Get(
- "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataBoxEdge"
- + "/dataBoxEdgeDevices/{deviceName}/storageAccounts/{storageAccountName}/containers")
+ "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataBoxEdge/dataBoxEdgeDevices/{deviceName}/storageAccounts/{storageAccountName}/containers")
@ExpectedResponses({200})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono> listByStorageAccount(
@@ -83,8 +82,7 @@ Mono> listByStorageAccount(
@Headers({"Content-Type: application/json"})
@Get(
- "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataBoxEdge"
- + "/dataBoxEdgeDevices/{deviceName}/storageAccounts/{storageAccountName}/containers/{containerName}")
+ "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataBoxEdge/dataBoxEdgeDevices/{deviceName}/storageAccounts/{storageAccountName}/containers/{containerName}")
@ExpectedResponses({200})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono> get(
@@ -100,8 +98,7 @@ Mono> get(
@Headers({"Content-Type: application/json"})
@Put(
- "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataBoxEdge"
- + "/dataBoxEdgeDevices/{deviceName}/storageAccounts/{storageAccountName}/containers/{containerName}")
+ "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataBoxEdge/dataBoxEdgeDevices/{deviceName}/storageAccounts/{storageAccountName}/containers/{containerName}")
@ExpectedResponses({200, 202})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono>> createOrUpdate(
@@ -118,8 +115,7 @@ Mono>> createOrUpdate(
@Headers({"Content-Type: application/json"})
@Delete(
- "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataBoxEdge"
- + "/dataBoxEdgeDevices/{deviceName}/storageAccounts/{storageAccountName}/containers/{containerName}")
+ "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataBoxEdge/dataBoxEdgeDevices/{deviceName}/storageAccounts/{storageAccountName}/containers/{containerName}")
@ExpectedResponses({202, 204})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono>> delete(
@@ -135,9 +131,7 @@ Mono>> delete(
@Headers({"Content-Type: application/json"})
@Post(
- "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataBoxEdge"
- + "/dataBoxEdgeDevices/{deviceName}/storageAccounts/{storageAccountName}/containers/{containerName}"
- + "/refresh")
+ "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataBoxEdge/dataBoxEdgeDevices/{deviceName}/storageAccounts/{storageAccountName}/containers/{containerName}/refresh")
@ExpectedResponses({200, 202})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono>> refresh(
diff --git a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DCAccessCodeImpl.java b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DCAccessCodeImpl.java
new file mode 100644
index 000000000000..4f1fe4896297
--- /dev/null
+++ b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DCAccessCodeImpl.java
@@ -0,0 +1,32 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) AutoRest Code Generator.
+
+package com.azure.resourcemanager.databoxedge.implementation;
+
+import com.azure.resourcemanager.databoxedge.fluent.models.DCAccessCodeInner;
+import com.azure.resourcemanager.databoxedge.models.DCAccessCode;
+
+public final class DCAccessCodeImpl implements DCAccessCode {
+ private DCAccessCodeInner innerObject;
+
+ private final com.azure.resourcemanager.databoxedge.DataBoxEdgeManager serviceManager;
+
+ DCAccessCodeImpl(
+ DCAccessCodeInner innerObject, com.azure.resourcemanager.databoxedge.DataBoxEdgeManager serviceManager) {
+ this.innerObject = innerObject;
+ this.serviceManager = serviceManager;
+ }
+
+ public String authCode() {
+ return this.innerModel().authCode();
+ }
+
+ public DCAccessCodeInner innerModel() {
+ return this.innerObject;
+ }
+
+ private com.azure.resourcemanager.databoxedge.DataBoxEdgeManager manager() {
+ return this.serviceManager;
+ }
+}
diff --git a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DataBoxEdgeDeviceExtendedInfoImpl.java b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DataBoxEdgeDeviceExtendedInfoImpl.java
index 9951f5372aee..9d78e1437ccb 100644
--- a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DataBoxEdgeDeviceExtendedInfoImpl.java
+++ b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DataBoxEdgeDeviceExtendedInfoImpl.java
@@ -4,8 +4,14 @@
package com.azure.resourcemanager.databoxedge.implementation;
+import com.azure.core.management.SystemData;
import com.azure.resourcemanager.databoxedge.fluent.models.DataBoxEdgeDeviceExtendedInfoInner;
+import com.azure.resourcemanager.databoxedge.models.ClusterWitnessType;
import com.azure.resourcemanager.databoxedge.models.DataBoxEdgeDeviceExtendedInfo;
+import com.azure.resourcemanager.databoxedge.models.KeyVaultSyncStatus;
+import com.azure.resourcemanager.databoxedge.models.Secret;
+import java.util.Collections;
+import java.util.Map;
public final class DataBoxEdgeDeviceExtendedInfoImpl implements DataBoxEdgeDeviceExtendedInfo {
private DataBoxEdgeDeviceExtendedInfoInner innerObject;
@@ -31,6 +37,10 @@ public String type() {
return this.innerModel().type();
}
+ public SystemData systemData() {
+ return this.innerModel().systemData();
+ }
+
public String encryptionKeyThumbprint() {
return this.innerModel().encryptionKeyThumbprint();
}
@@ -43,6 +53,59 @@ public String resourceKey() {
return this.innerModel().resourceKey();
}
+ public String clientSecretStoreId() {
+ return this.innerModel().clientSecretStoreId();
+ }
+
+ public String clientSecretStoreUrl() {
+ return this.innerModel().clientSecretStoreUrl();
+ }
+
+ public String channelIntegrityKeyName() {
+ return this.innerModel().channelIntegrityKeyName();
+ }
+
+ public String channelIntegrityKeyVersion() {
+ return this.innerModel().channelIntegrityKeyVersion();
+ }
+
+ public KeyVaultSyncStatus keyVaultSyncStatus() {
+ return this.innerModel().keyVaultSyncStatus();
+ }
+
+ public Map deviceSecrets() {
+ Map inner = this.innerModel().deviceSecrets();
+ if (inner != null) {
+ return Collections.unmodifiableMap(inner);
+ } else {
+ return Collections.emptyMap();
+ }
+ }
+
+ public ClusterWitnessType clusterWitnessType() {
+ return this.innerModel().clusterWitnessType();
+ }
+
+ public String fileShareWitnessLocation() {
+ return this.innerModel().fileShareWitnessLocation();
+ }
+
+ public String fileShareWitnessUsername() {
+ return this.innerModel().fileShareWitnessUsername();
+ }
+
+ public String cloudWitnessStorageAccountName() {
+ return this.innerModel().cloudWitnessStorageAccountName();
+ }
+
+ public String cloudWitnessContainerName() {
+ return this.innerModel().cloudWitnessContainerName();
+ }
+
+ public String cloudWitnessStorageEndpoint() {
+ return this.innerModel().cloudWitnessStorageEndpoint();
+ }
+
public DataBoxEdgeDeviceExtendedInfoInner innerModel() {
return this.innerObject;
}
diff --git a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DataBoxEdgeDeviceImpl.java b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DataBoxEdgeDeviceImpl.java
index bd75c3405b34..060606e94f67 100644
--- a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DataBoxEdgeDeviceImpl.java
+++ b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DataBoxEdgeDeviceImpl.java
@@ -6,13 +6,22 @@
import com.azure.core.http.rest.Response;
import com.azure.core.management.Region;
+import com.azure.core.management.SystemData;
import com.azure.core.util.Context;
import com.azure.resourcemanager.databoxedge.fluent.models.DataBoxEdgeDeviceInner;
import com.azure.resourcemanager.databoxedge.models.DataBoxEdgeDevice;
import com.azure.resourcemanager.databoxedge.models.DataBoxEdgeDeviceExtendedInfo;
+import com.azure.resourcemanager.databoxedge.models.DataBoxEdgeDeviceExtendedInfoPatch;
+import com.azure.resourcemanager.databoxedge.models.DataBoxEdgeDeviceKind;
import com.azure.resourcemanager.databoxedge.models.DataBoxEdgeDevicePatch;
import com.azure.resourcemanager.databoxedge.models.DataBoxEdgeDeviceStatus;
+import com.azure.resourcemanager.databoxedge.models.DataResidency;
import com.azure.resourcemanager.databoxedge.models.DeviceType;
+import com.azure.resourcemanager.databoxedge.models.EdgeProfile;
+import com.azure.resourcemanager.databoxedge.models.EdgeProfilePatch;
+import com.azure.resourcemanager.databoxedge.models.GenerateCertResponse;
+import com.azure.resourcemanager.databoxedge.models.ResourceIdentity;
+import com.azure.resourcemanager.databoxedge.models.ResourceMoveDetails;
import com.azure.resourcemanager.databoxedge.models.RoleTypes;
import com.azure.resourcemanager.databoxedge.models.Sku;
import com.azure.resourcemanager.databoxedge.models.UploadCertificateRequest;
@@ -60,6 +69,22 @@ public String etag() {
return this.innerModel().etag();
}
+ public ResourceIdentity identity() {
+ return this.innerModel().identity();
+ }
+
+ public DataBoxEdgeDeviceKind kind() {
+ return this.innerModel().kind();
+ }
+
+ public SystemData systemData() {
+ return this.innerModel().systemData();
+ }
+
+ public SystemData systemDataPropertiesSystemData() {
+ return this.innerModel().systemDataPropertiesSystemData();
+ }
+
public DataBoxEdgeDeviceStatus dataBoxEdgeDeviceStatus() {
return this.innerModel().dataBoxEdgeDeviceStatus();
}
@@ -121,6 +146,22 @@ public Integer nodeCount() {
return this.innerModel().nodeCount();
}
+ public ResourceMoveDetails resourceMoveDetails() {
+ return this.innerModel().resourceMoveDetails();
+ }
+
+ public EdgeProfile edgeProfile() {
+ return this.innerModel().edgeProfile();
+ }
+
+ public DataResidency dataResidency() {
+ return this.innerModel().dataResidency();
+ }
+
+ public String kubernetesWorkloadProfile() {
+ return this.innerModel().kubernetesWorkloadProfile();
+ }
+
public Region region() {
return Region.fromName(this.regionName());
}
@@ -157,7 +198,8 @@ public DataBoxEdgeDevice create() {
serviceManager
.serviceClient()
.getDevices()
- .createOrUpdate(deviceName, resourceGroupName, this.innerModel(), Context.NONE);
+ .createOrUpdateWithResponse(deviceName, resourceGroupName, this.innerModel(), Context.NONE)
+ .getValue();
return this;
}
@@ -166,7 +208,8 @@ public DataBoxEdgeDevice create(Context context) {
serviceManager
.serviceClient()
.getDevices()
- .createOrUpdate(deviceName, resourceGroupName, this.innerModel(), context);
+ .createOrUpdateWithResponse(deviceName, resourceGroupName, this.innerModel(), context)
+ .getValue();
return this;
}
@@ -237,6 +280,14 @@ public void downloadUpdates(Context context) {
serviceManager.devices().downloadUpdates(deviceName, resourceGroupName, context);
}
+ public Response generateCertificateWithResponse(Context context) {
+ return serviceManager.devices().generateCertificateWithResponse(deviceName, resourceGroupName, context);
+ }
+
+ public GenerateCertResponse generateCertificate() {
+ return serviceManager.devices().generateCertificate(deviceName, resourceGroupName);
+ }
+
public Response getExtendedInformationWithResponse(Context context) {
return serviceManager.devices().getExtendedInformationWithResponse(deviceName, resourceGroupName, context);
}
@@ -261,6 +312,17 @@ public void scanForUpdates(Context context) {
serviceManager.devices().scanForUpdates(deviceName, resourceGroupName, context);
}
+ public Response updateExtendedInformationWithResponse(
+ DataBoxEdgeDeviceExtendedInfoPatch parameters, Context context) {
+ return serviceManager
+ .devices()
+ .updateExtendedInformationWithResponse(deviceName, resourceGroupName, parameters, context);
+ }
+
+ public DataBoxEdgeDeviceExtendedInfo updateExtendedInformation(DataBoxEdgeDeviceExtendedInfoPatch parameters) {
+ return serviceManager.devices().updateExtendedInformation(deviceName, resourceGroupName, parameters);
+ }
+
public Response uploadCertificateWithResponse(
UploadCertificateRequest parameters, Context context) {
return serviceManager
@@ -302,23 +364,23 @@ public DataBoxEdgeDeviceImpl withEtag(String etag) {
return this;
}
- public DataBoxEdgeDeviceImpl withDataBoxEdgeDeviceStatus(DataBoxEdgeDeviceStatus dataBoxEdgeDeviceStatus) {
- this.innerModel().withDataBoxEdgeDeviceStatus(dataBoxEdgeDeviceStatus);
- return this;
- }
-
- public DataBoxEdgeDeviceImpl withDescription(String description) {
- this.innerModel().withDescription(description);
- return this;
+ public DataBoxEdgeDeviceImpl withIdentity(ResourceIdentity identity) {
+ if (isInCreateMode()) {
+ this.innerModel().withIdentity(identity);
+ return this;
+ } else {
+ this.updateParameters.withIdentity(identity);
+ return this;
+ }
}
- public DataBoxEdgeDeviceImpl withModelDescription(String modelDescription) {
- this.innerModel().withModelDescription(modelDescription);
+ public DataBoxEdgeDeviceImpl withDataResidency(DataResidency dataResidency) {
+ this.innerModel().withDataResidency(dataResidency);
return this;
}
- public DataBoxEdgeDeviceImpl withFriendlyName(String friendlyName) {
- this.innerModel().withFriendlyName(friendlyName);
+ public DataBoxEdgeDeviceImpl withEdgeProfile(EdgeProfilePatch edgeProfile) {
+ this.updateParameters.withEdgeProfile(edgeProfile);
return this;
}
diff --git a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DataBoxEdgeManagementClientImpl.java b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DataBoxEdgeManagementClientImpl.java
index 9ba6f294c7f0..5f857011dc60 100644
--- a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DataBoxEdgeManagementClientImpl.java
+++ b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DataBoxEdgeManagementClientImpl.java
@@ -22,21 +22,27 @@
import com.azure.core.util.polling.PollerFlux;
import com.azure.core.util.serializer.SerializerAdapter;
import com.azure.core.util.serializer.SerializerEncoding;
+import com.azure.resourcemanager.databoxedge.fluent.AddonsClient;
import com.azure.resourcemanager.databoxedge.fluent.AlertsClient;
+import com.azure.resourcemanager.databoxedge.fluent.AvailableSkusClient;
import com.azure.resourcemanager.databoxedge.fluent.BandwidthSchedulesClient;
import com.azure.resourcemanager.databoxedge.fluent.ContainersClient;
import com.azure.resourcemanager.databoxedge.fluent.DataBoxEdgeManagementClient;
+import com.azure.resourcemanager.databoxedge.fluent.DeviceCapacityChecksClient;
+import com.azure.resourcemanager.databoxedge.fluent.DeviceCapacityInfoesClient;
import com.azure.resourcemanager.databoxedge.fluent.DevicesClient;
+import com.azure.resourcemanager.databoxedge.fluent.DiagnosticSettingsClient;
import com.azure.resourcemanager.databoxedge.fluent.JobsClient;
+import com.azure.resourcemanager.databoxedge.fluent.MonitoringConfigsClient;
import com.azure.resourcemanager.databoxedge.fluent.NodesClient;
import com.azure.resourcemanager.databoxedge.fluent.OperationsClient;
import com.azure.resourcemanager.databoxedge.fluent.OperationsStatusClient;
import com.azure.resourcemanager.databoxedge.fluent.OrdersClient;
import com.azure.resourcemanager.databoxedge.fluent.RolesClient;
import com.azure.resourcemanager.databoxedge.fluent.SharesClient;
-import com.azure.resourcemanager.databoxedge.fluent.SkusClient;
import com.azure.resourcemanager.databoxedge.fluent.StorageAccountCredentialsClient;
import com.azure.resourcemanager.databoxedge.fluent.StorageAccountsClient;
+import com.azure.resourcemanager.databoxedge.fluent.SupportPackagesClient;
import com.azure.resourcemanager.databoxedge.fluent.TriggersClient;
import com.azure.resourcemanager.databoxedge.fluent.UsersClient;
import java.io.IOException;
@@ -135,6 +141,18 @@ public OperationsClient getOperations() {
return this.operations;
}
+ /** The AvailableSkusClient object to access its operations. */
+ private final AvailableSkusClient availableSkus;
+
+ /**
+ * Gets the AvailableSkusClient object to access its operations.
+ *
+ * @return the AvailableSkusClient object.
+ */
+ public AvailableSkusClient getAvailableSkus() {
+ return this.availableSkus;
+ }
+
/** The DevicesClient object to access its operations. */
private final DevicesClient devices;
@@ -171,6 +189,42 @@ public BandwidthSchedulesClient getBandwidthSchedules() {
return this.bandwidthSchedules;
}
+ /** The DeviceCapacityChecksClient object to access its operations. */
+ private final DeviceCapacityChecksClient deviceCapacityChecks;
+
+ /**
+ * Gets the DeviceCapacityChecksClient object to access its operations.
+ *
+ * @return the DeviceCapacityChecksClient object.
+ */
+ public DeviceCapacityChecksClient getDeviceCapacityChecks() {
+ return this.deviceCapacityChecks;
+ }
+
+ /** The DeviceCapacityInfoesClient object to access its operations. */
+ private final DeviceCapacityInfoesClient deviceCapacityInfoes;
+
+ /**
+ * Gets the DeviceCapacityInfoesClient object to access its operations.
+ *
+ * @return the DeviceCapacityInfoesClient object.
+ */
+ public DeviceCapacityInfoesClient getDeviceCapacityInfoes() {
+ return this.deviceCapacityInfoes;
+ }
+
+ /** The DiagnosticSettingsClient object to access its operations. */
+ private final DiagnosticSettingsClient diagnosticSettings;
+
+ /**
+ * Gets the DiagnosticSettingsClient object to access its operations.
+ *
+ * @return the DiagnosticSettingsClient object.
+ */
+ public DiagnosticSettingsClient getDiagnosticSettings() {
+ return this.diagnosticSettings;
+ }
+
/** The JobsClient object to access its operations. */
private final JobsClient jobs;
@@ -231,6 +285,30 @@ public RolesClient getRoles() {
return this.roles;
}
+ /** The AddonsClient object to access its operations. */
+ private final AddonsClient addons;
+
+ /**
+ * Gets the AddonsClient object to access its operations.
+ *
+ * @return the AddonsClient object.
+ */
+ public AddonsClient getAddons() {
+ return this.addons;
+ }
+
+ /** The MonitoringConfigsClient object to access its operations. */
+ private final MonitoringConfigsClient monitoringConfigs;
+
+ /**
+ * Gets the MonitoringConfigsClient object to access its operations.
+ *
+ * @return the MonitoringConfigsClient object.
+ */
+ public MonitoringConfigsClient getMonitoringConfigs() {
+ return this.monitoringConfigs;
+ }
+
/** The SharesClient object to access its operations. */
private final SharesClient shares;
@@ -291,28 +369,28 @@ public TriggersClient getTriggers() {
return this.triggers;
}
- /** The UsersClient object to access its operations. */
- private final UsersClient users;
+ /** The SupportPackagesClient object to access its operations. */
+ private final SupportPackagesClient supportPackages;
/**
- * Gets the UsersClient object to access its operations.
+ * Gets the SupportPackagesClient object to access its operations.
*
- * @return the UsersClient object.
+ * @return the SupportPackagesClient object.
*/
- public UsersClient getUsers() {
- return this.users;
+ public SupportPackagesClient getSupportPackages() {
+ return this.supportPackages;
}
- /** The SkusClient object to access its operations. */
- private final SkusClient skus;
+ /** The UsersClient object to access its operations. */
+ private final UsersClient users;
/**
- * Gets the SkusClient object to access its operations.
+ * Gets the UsersClient object to access its operations.
*
- * @return the SkusClient object.
+ * @return the UsersClient object.
*/
- public SkusClient getSkus() {
- return this.skus;
+ public UsersClient getUsers() {
+ return this.users;
}
/**
@@ -337,23 +415,29 @@ public SkusClient getSkus() {
this.defaultPollInterval = defaultPollInterval;
this.subscriptionId = subscriptionId;
this.endpoint = endpoint;
- this.apiVersion = "2019-08-01";
+ this.apiVersion = "2023-07-01";
this.operations = new OperationsClientImpl(this);
+ this.availableSkus = new AvailableSkusClientImpl(this);
this.devices = new DevicesClientImpl(this);
this.alerts = new AlertsClientImpl(this);
this.bandwidthSchedules = new BandwidthSchedulesClientImpl(this);
+ this.deviceCapacityChecks = new DeviceCapacityChecksClientImpl(this);
+ this.deviceCapacityInfoes = new DeviceCapacityInfoesClientImpl(this);
+ this.diagnosticSettings = new DiagnosticSettingsClientImpl(this);
this.jobs = new JobsClientImpl(this);
this.nodes = new NodesClientImpl(this);
this.operationsStatus = new OperationsStatusClientImpl(this);
this.orders = new OrdersClientImpl(this);
this.roles = new RolesClientImpl(this);
+ this.addons = new AddonsClientImpl(this);
+ this.monitoringConfigs = new MonitoringConfigsClientImpl(this);
this.shares = new SharesClientImpl(this);
this.storageAccountCredentials = new StorageAccountCredentialsClientImpl(this);
this.storageAccounts = new StorageAccountsClientImpl(this);
this.containers = new ContainersClientImpl(this);
this.triggers = new TriggersClientImpl(this);
+ this.supportPackages = new SupportPackagesClientImpl(this);
this.users = new UsersClientImpl(this);
- this.skus = new SkusClientImpl(this);
}
/**
diff --git a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/ResourceTypeSkuImpl.java b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DataBoxEdgeSkuImpl.java
similarity index 61%
rename from sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/ResourceTypeSkuImpl.java
rename to sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DataBoxEdgeSkuImpl.java
index 52a889e6252b..052366788c0b 100644
--- a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/ResourceTypeSkuImpl.java
+++ b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DataBoxEdgeSkuImpl.java
@@ -4,23 +4,27 @@
package com.azure.resourcemanager.databoxedge.implementation;
-import com.azure.resourcemanager.databoxedge.fluent.models.ResourceTypeSkuInner;
-import com.azure.resourcemanager.databoxedge.models.ResourceTypeSku;
+import com.azure.resourcemanager.databoxedge.fluent.models.DataBoxEdgeSkuInner;
+import com.azure.resourcemanager.databoxedge.models.DataBoxEdgeSku;
+import com.azure.resourcemanager.databoxedge.models.ShipmentType;
+import com.azure.resourcemanager.databoxedge.models.SkuAvailability;
+import com.azure.resourcemanager.databoxedge.models.SkuCapability;
import com.azure.resourcemanager.databoxedge.models.SkuCost;
import com.azure.resourcemanager.databoxedge.models.SkuLocationInfo;
import com.azure.resourcemanager.databoxedge.models.SkuName;
-import com.azure.resourcemanager.databoxedge.models.SkuRestriction;
+import com.azure.resourcemanager.databoxedge.models.SkuSignupOption;
import com.azure.resourcemanager.databoxedge.models.SkuTier;
+import com.azure.resourcemanager.databoxedge.models.SkuVersion;
import java.util.Collections;
import java.util.List;
-public final class ResourceTypeSkuImpl implements ResourceTypeSku {
- private ResourceTypeSkuInner innerObject;
+public final class DataBoxEdgeSkuImpl implements DataBoxEdgeSku {
+ private DataBoxEdgeSkuInner innerObject;
private final com.azure.resourcemanager.databoxedge.DataBoxEdgeManager serviceManager;
- ResourceTypeSkuImpl(
- ResourceTypeSkuInner innerObject, com.azure.resourcemanager.databoxedge.DataBoxEdgeManager serviceManager) {
+ DataBoxEdgeSkuImpl(
+ DataBoxEdgeSkuInner innerObject, com.azure.resourcemanager.databoxedge.DataBoxEdgeManager serviceManager) {
this.innerObject = innerObject;
this.serviceManager = serviceManager;
}
@@ -41,6 +45,10 @@ public SkuTier tier() {
return this.innerModel().tier();
}
+ public String size() {
+ return this.innerModel().size();
+ }
+
public String family() {
return this.innerModel().family();
}
@@ -81,8 +89,29 @@ public List costs() {
}
}
- public List restrictions() {
- List inner = this.innerModel().restrictions();
+ public SkuSignupOption signupOption() {
+ return this.innerModel().signupOption();
+ }
+
+ public SkuVersion version() {
+ return this.innerModel().version();
+ }
+
+ public SkuAvailability availability() {
+ return this.innerModel().availability();
+ }
+
+ public List shipmentTypes() {
+ List inner = this.innerModel().shipmentTypes();
+ if (inner != null) {
+ return Collections.unmodifiableList(inner);
+ } else {
+ return Collections.emptyList();
+ }
+ }
+
+ public List capabilities() {
+ List inner = this.innerModel().capabilities();
if (inner != null) {
return Collections.unmodifiableList(inner);
} else {
@@ -90,7 +119,7 @@ public List restrictions() {
}
}
- public ResourceTypeSkuInner innerModel() {
+ public DataBoxEdgeSkuInner innerModel() {
return this.innerObject;
}
diff --git a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DeviceCapacityChecksClientImpl.java b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DeviceCapacityChecksClientImpl.java
new file mode 100644
index 000000000000..3077e3702126
--- /dev/null
+++ b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DeviceCapacityChecksClientImpl.java
@@ -0,0 +1,442 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) AutoRest Code Generator.
+
+package com.azure.resourcemanager.databoxedge.implementation;
+
+import com.azure.core.annotation.BodyParam;
+import com.azure.core.annotation.ExpectedResponses;
+import com.azure.core.annotation.HeaderParam;
+import com.azure.core.annotation.Headers;
+import com.azure.core.annotation.Host;
+import com.azure.core.annotation.HostParam;
+import com.azure.core.annotation.PathParam;
+import com.azure.core.annotation.Post;
+import com.azure.core.annotation.QueryParam;
+import com.azure.core.annotation.ReturnType;
+import com.azure.core.annotation.ServiceInterface;
+import com.azure.core.annotation.ServiceMethod;
+import com.azure.core.annotation.UnexpectedResponseExceptionType;
+import com.azure.core.http.rest.Response;
+import com.azure.core.http.rest.RestProxy;
+import com.azure.core.management.exception.ManagementException;
+import com.azure.core.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.databoxedge.fluent.DeviceCapacityChecksClient;
+import com.azure.resourcemanager.databoxedge.models.DeviceCapacityRequestInfo;
+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 DeviceCapacityChecksClient. */
+public final class DeviceCapacityChecksClientImpl implements DeviceCapacityChecksClient {
+ /** The proxy service used to perform REST calls. */
+ private final DeviceCapacityChecksService service;
+
+ /** The service client containing this operation class. */
+ private final DataBoxEdgeManagementClientImpl client;
+
+ /**
+ * Initializes an instance of DeviceCapacityChecksClientImpl.
+ *
+ * @param client the instance of the service client containing this operation class.
+ */
+ DeviceCapacityChecksClientImpl(DataBoxEdgeManagementClientImpl client) {
+ this.service =
+ RestProxy
+ .create(DeviceCapacityChecksService.class, client.getHttpPipeline(), client.getSerializerAdapter());
+ this.client = client;
+ }
+
+ /**
+ * The interface defining all the services for DataBoxEdgeManagementClientDeviceCapacityChecks to be used by the
+ * proxy service to perform REST calls.
+ */
+ @Host("{$host}")
+ @ServiceInterface(name = "DataBoxEdgeManagemen")
+ public interface DeviceCapacityChecksService {
+ @Headers({"Content-Type: application/json"})
+ @Post(
+ "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataBoxEdge/dataBoxEdgeDevices/{deviceName}/deviceCapacityCheck")
+ @ExpectedResponses({200, 202})
+ @UnexpectedResponseExceptionType(ManagementException.class)
+ Mono>> checkResourceCreationFeasibility(
+ @HostParam("$host") String endpoint,
+ @PathParam("subscriptionId") String subscriptionId,
+ @PathParam("resourceGroupName") String resourceGroupName,
+ @QueryParam("api-version") String apiVersion,
+ @PathParam("deviceName") String deviceName,
+ @QueryParam("capacityName") String capacityName,
+ @BodyParam("application/json") DeviceCapacityRequestInfo deviceCapacityRequestInfo,
+ @HeaderParam("Accept") String accept,
+ Context context);
+ }
+
+ /**
+ * Posts the device capacity request info to check feasibility.
+ *
+ * @param resourceGroupName The resource group name.
+ * @param deviceName The device name.
+ * @param deviceCapacityRequestInfo The device capacity request info.
+ * @param capacityName The capacity name.
+ * @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>> checkResourceCreationFeasibilityWithResponseAsync(
+ String resourceGroupName,
+ String deviceName,
+ DeviceCapacityRequestInfo deviceCapacityRequestInfo,
+ String capacityName) {
+ 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 (deviceName == null) {
+ return Mono.error(new IllegalArgumentException("Parameter deviceName is required and cannot be null."));
+ }
+ if (deviceCapacityRequestInfo == null) {
+ return Mono
+ .error(
+ new IllegalArgumentException(
+ "Parameter deviceCapacityRequestInfo is required and cannot be null."));
+ } else {
+ deviceCapacityRequestInfo.validate();
+ }
+ final String accept = "application/json";
+ return FluxUtil
+ .withContext(
+ context ->
+ service
+ .checkResourceCreationFeasibility(
+ this.client.getEndpoint(),
+ this.client.getSubscriptionId(),
+ resourceGroupName,
+ this.client.getApiVersion(),
+ deviceName,
+ capacityName,
+ deviceCapacityRequestInfo,
+ accept,
+ context))
+ .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
+ }
+
+ /**
+ * Posts the device capacity request info to check feasibility.
+ *
+ * @param resourceGroupName The resource group name.
+ * @param deviceName The device name.
+ * @param deviceCapacityRequestInfo The device capacity request info.
+ * @param capacityName The capacity name.
+ * @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>> checkResourceCreationFeasibilityWithResponseAsync(
+ String resourceGroupName,
+ String deviceName,
+ DeviceCapacityRequestInfo deviceCapacityRequestInfo,
+ String capacityName,
+ 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 (deviceName == null) {
+ return Mono.error(new IllegalArgumentException("Parameter deviceName is required and cannot be null."));
+ }
+ if (deviceCapacityRequestInfo == null) {
+ return Mono
+ .error(
+ new IllegalArgumentException(
+ "Parameter deviceCapacityRequestInfo is required and cannot be null."));
+ } else {
+ deviceCapacityRequestInfo.validate();
+ }
+ final String accept = "application/json";
+ context = this.client.mergeContext(context);
+ return service
+ .checkResourceCreationFeasibility(
+ this.client.getEndpoint(),
+ this.client.getSubscriptionId(),
+ resourceGroupName,
+ this.client.getApiVersion(),
+ deviceName,
+ capacityName,
+ deviceCapacityRequestInfo,
+ accept,
+ context);
+ }
+
+ /**
+ * Posts the device capacity request info to check feasibility.
+ *
+ * @param resourceGroupName The resource group name.
+ * @param deviceName The device name.
+ * @param deviceCapacityRequestInfo The device capacity request info.
+ * @param capacityName The capacity name.
+ * @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> beginCheckResourceCreationFeasibilityAsync(
+ String resourceGroupName,
+ String deviceName,
+ DeviceCapacityRequestInfo deviceCapacityRequestInfo,
+ String capacityName) {
+ Mono>> mono =
+ checkResourceCreationFeasibilityWithResponseAsync(
+ resourceGroupName, deviceName, deviceCapacityRequestInfo, capacityName);
+ return this
+ .client
+ .getLroResult(
+ mono, this.client.getHttpPipeline(), Void.class, Void.class, this.client.getContext());
+ }
+
+ /**
+ * Posts the device capacity request info to check feasibility.
+ *
+ * @param resourceGroupName The resource group name.
+ * @param deviceName The device name.
+ * @param deviceCapacityRequestInfo The device capacity request info.
+ * @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> beginCheckResourceCreationFeasibilityAsync(
+ String resourceGroupName, String deviceName, DeviceCapacityRequestInfo deviceCapacityRequestInfo) {
+ final String capacityName = null;
+ Mono>> mono =
+ checkResourceCreationFeasibilityWithResponseAsync(
+ resourceGroupName, deviceName, deviceCapacityRequestInfo, capacityName);
+ return this
+ .client
+ .getLroResult(
+ mono, this.client.getHttpPipeline(), Void.class, Void.class, this.client.getContext());
+ }
+
+ /**
+ * Posts the device capacity request info to check feasibility.
+ *
+ * @param resourceGroupName The resource group name.
+ * @param deviceName The device name.
+ * @param deviceCapacityRequestInfo The device capacity request info.
+ * @param capacityName The capacity name.
+ * @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> beginCheckResourceCreationFeasibilityAsync(
+ String resourceGroupName,
+ String deviceName,
+ DeviceCapacityRequestInfo deviceCapacityRequestInfo,
+ String capacityName,
+ Context context) {
+ context = this.client.mergeContext(context);
+ Mono>> mono =
+ checkResourceCreationFeasibilityWithResponseAsync(
+ resourceGroupName, deviceName, deviceCapacityRequestInfo, capacityName, context);
+ return this
+ .client
+ .getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, context);
+ }
+
+ /**
+ * Posts the device capacity request info to check feasibility.
+ *
+ * @param resourceGroupName The resource group name.
+ * @param deviceName The device name.
+ * @param deviceCapacityRequestInfo The device capacity request info.
+ * @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> beginCheckResourceCreationFeasibility(
+ String resourceGroupName, String deviceName, DeviceCapacityRequestInfo deviceCapacityRequestInfo) {
+ final String capacityName = null;
+ return this
+ .beginCheckResourceCreationFeasibilityAsync(
+ resourceGroupName, deviceName, deviceCapacityRequestInfo, capacityName)
+ .getSyncPoller();
+ }
+
+ /**
+ * Posts the device capacity request info to check feasibility.
+ *
+ * @param resourceGroupName The resource group name.
+ * @param deviceName The device name.
+ * @param deviceCapacityRequestInfo The device capacity request info.
+ * @param capacityName The capacity name.
+ * @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> beginCheckResourceCreationFeasibility(
+ String resourceGroupName,
+ String deviceName,
+ DeviceCapacityRequestInfo deviceCapacityRequestInfo,
+ String capacityName,
+ Context context) {
+ return this
+ .beginCheckResourceCreationFeasibilityAsync(
+ resourceGroupName, deviceName, deviceCapacityRequestInfo, capacityName, context)
+ .getSyncPoller();
+ }
+
+ /**
+ * Posts the device capacity request info to check feasibility.
+ *
+ * @param resourceGroupName The resource group name.
+ * @param deviceName The device name.
+ * @param deviceCapacityRequestInfo The device capacity request info.
+ * @param capacityName The capacity name.
+ * @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 checkResourceCreationFeasibilityAsync(
+ String resourceGroupName,
+ String deviceName,
+ DeviceCapacityRequestInfo deviceCapacityRequestInfo,
+ String capacityName) {
+ return beginCheckResourceCreationFeasibilityAsync(
+ resourceGroupName, deviceName, deviceCapacityRequestInfo, capacityName)
+ .last()
+ .flatMap(this.client::getLroFinalResultOrError);
+ }
+
+ /**
+ * Posts the device capacity request info to check feasibility.
+ *
+ * @param resourceGroupName The resource group name.
+ * @param deviceName The device name.
+ * @param deviceCapacityRequestInfo The device capacity request info.
+ * @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 checkResourceCreationFeasibilityAsync(
+ String resourceGroupName, String deviceName, DeviceCapacityRequestInfo deviceCapacityRequestInfo) {
+ final String capacityName = null;
+ return beginCheckResourceCreationFeasibilityAsync(
+ resourceGroupName, deviceName, deviceCapacityRequestInfo, capacityName)
+ .last()
+ .flatMap(this.client::getLroFinalResultOrError);
+ }
+
+ /**
+ * Posts the device capacity request info to check feasibility.
+ *
+ * @param resourceGroupName The resource group name.
+ * @param deviceName The device name.
+ * @param deviceCapacityRequestInfo The device capacity request info.
+ * @param capacityName The capacity name.
+ * @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 checkResourceCreationFeasibilityAsync(
+ String resourceGroupName,
+ String deviceName,
+ DeviceCapacityRequestInfo deviceCapacityRequestInfo,
+ String capacityName,
+ Context context) {
+ return beginCheckResourceCreationFeasibilityAsync(
+ resourceGroupName, deviceName, deviceCapacityRequestInfo, capacityName, context)
+ .last()
+ .flatMap(this.client::getLroFinalResultOrError);
+ }
+
+ /**
+ * Posts the device capacity request info to check feasibility.
+ *
+ * @param resourceGroupName The resource group name.
+ * @param deviceName The device name.
+ * @param deviceCapacityRequestInfo The device capacity request info.
+ * @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 checkResourceCreationFeasibility(
+ String resourceGroupName, String deviceName, DeviceCapacityRequestInfo deviceCapacityRequestInfo) {
+ final String capacityName = null;
+ checkResourceCreationFeasibilityAsync(resourceGroupName, deviceName, deviceCapacityRequestInfo, capacityName)
+ .block();
+ }
+
+ /**
+ * Posts the device capacity request info to check feasibility.
+ *
+ * @param resourceGroupName The resource group name.
+ * @param deviceName The device name.
+ * @param deviceCapacityRequestInfo The device capacity request info.
+ * @param capacityName The capacity name.
+ * @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 checkResourceCreationFeasibility(
+ String resourceGroupName,
+ String deviceName,
+ DeviceCapacityRequestInfo deviceCapacityRequestInfo,
+ String capacityName,
+ Context context) {
+ checkResourceCreationFeasibilityAsync(
+ resourceGroupName, deviceName, deviceCapacityRequestInfo, capacityName, context)
+ .block();
+ }
+}
diff --git a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DeviceCapacityChecksImpl.java b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DeviceCapacityChecksImpl.java
new file mode 100644
index 000000000000..390e153db492
--- /dev/null
+++ b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DeviceCapacityChecksImpl.java
@@ -0,0 +1,51 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) AutoRest Code Generator.
+
+package com.azure.resourcemanager.databoxedge.implementation;
+
+import com.azure.core.util.Context;
+import com.azure.core.util.logging.ClientLogger;
+import com.azure.resourcemanager.databoxedge.fluent.DeviceCapacityChecksClient;
+import com.azure.resourcemanager.databoxedge.models.DeviceCapacityChecks;
+import com.azure.resourcemanager.databoxedge.models.DeviceCapacityRequestInfo;
+
+public final class DeviceCapacityChecksImpl implements DeviceCapacityChecks {
+ private static final ClientLogger LOGGER = new ClientLogger(DeviceCapacityChecksImpl.class);
+
+ private final DeviceCapacityChecksClient innerClient;
+
+ private final com.azure.resourcemanager.databoxedge.DataBoxEdgeManager serviceManager;
+
+ public DeviceCapacityChecksImpl(
+ DeviceCapacityChecksClient innerClient,
+ com.azure.resourcemanager.databoxedge.DataBoxEdgeManager serviceManager) {
+ this.innerClient = innerClient;
+ this.serviceManager = serviceManager;
+ }
+
+ public void checkResourceCreationFeasibility(
+ String resourceGroupName, String deviceName, DeviceCapacityRequestInfo deviceCapacityRequestInfo) {
+ this.serviceClient().checkResourceCreationFeasibility(resourceGroupName, deviceName, deviceCapacityRequestInfo);
+ }
+
+ public void checkResourceCreationFeasibility(
+ String resourceGroupName,
+ String deviceName,
+ DeviceCapacityRequestInfo deviceCapacityRequestInfo,
+ String capacityName,
+ Context context) {
+ this
+ .serviceClient()
+ .checkResourceCreationFeasibility(
+ resourceGroupName, deviceName, deviceCapacityRequestInfo, capacityName, context);
+ }
+
+ private DeviceCapacityChecksClient serviceClient() {
+ return this.innerClient;
+ }
+
+ private com.azure.resourcemanager.databoxedge.DataBoxEdgeManager manager() {
+ return this.serviceManager;
+ }
+}
diff --git a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DeviceCapacityInfoImpl.java b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DeviceCapacityInfoImpl.java
new file mode 100644
index 000000000000..36906ca142e2
--- /dev/null
+++ b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DeviceCapacityInfoImpl.java
@@ -0,0 +1,72 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) AutoRest Code Generator.
+
+package com.azure.resourcemanager.databoxedge.implementation;
+
+import com.azure.core.management.SystemData;
+import com.azure.resourcemanager.databoxedge.fluent.models.DeviceCapacityInfoInner;
+import com.azure.resourcemanager.databoxedge.models.ClusterCapacityViewData;
+import com.azure.resourcemanager.databoxedge.models.ClusterStorageViewData;
+import com.azure.resourcemanager.databoxedge.models.DeviceCapacityInfo;
+import com.azure.resourcemanager.databoxedge.models.HostCapacity;
+import java.time.OffsetDateTime;
+import java.util.Collections;
+import java.util.Map;
+
+public final class DeviceCapacityInfoImpl implements DeviceCapacityInfo {
+ private DeviceCapacityInfoInner innerObject;
+
+ private final com.azure.resourcemanager.databoxedge.DataBoxEdgeManager serviceManager;
+
+ DeviceCapacityInfoImpl(
+ DeviceCapacityInfoInner innerObject, com.azure.resourcemanager.databoxedge.DataBoxEdgeManager serviceManager) {
+ this.innerObject = innerObject;
+ this.serviceManager = serviceManager;
+ }
+
+ public String id() {
+ return this.innerModel().id();
+ }
+
+ public String name() {
+ return this.innerModel().name();
+ }
+
+ public String type() {
+ return this.innerModel().type();
+ }
+
+ public SystemData systemData() {
+ return this.innerModel().systemData();
+ }
+
+ public OffsetDateTime timestamp() {
+ return this.innerModel().timestamp();
+ }
+
+ public ClusterStorageViewData clusterStorageCapacityInfo() {
+ return this.innerModel().clusterStorageCapacityInfo();
+ }
+
+ public ClusterCapacityViewData clusterComputeCapacityInfo() {
+ return this.innerModel().clusterComputeCapacityInfo();
+ }
+
+ public Map nodeCapacityInfos() {
+ Map inner = this.innerModel().nodeCapacityInfos();
+ if (inner != null) {
+ return Collections.unmodifiableMap(inner);
+ } else {
+ return Collections.emptyMap();
+ }
+ }
+
+ public DeviceCapacityInfoInner innerModel() {
+ return this.innerObject;
+ }
+
+ private com.azure.resourcemanager.databoxedge.DataBoxEdgeManager manager() {
+ return this.serviceManager;
+ }
+}
diff --git a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DeviceCapacityInfoesClientImpl.java b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DeviceCapacityInfoesClientImpl.java
new file mode 100644
index 000000000000..c8ba66a2efeb
--- /dev/null
+++ b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DeviceCapacityInfoesClientImpl.java
@@ -0,0 +1,213 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) AutoRest Code Generator.
+
+package com.azure.resourcemanager.databoxedge.implementation;
+
+import com.azure.core.annotation.ExpectedResponses;
+import com.azure.core.annotation.Get;
+import com.azure.core.annotation.HeaderParam;
+import com.azure.core.annotation.Headers;
+import com.azure.core.annotation.Host;
+import com.azure.core.annotation.HostParam;
+import com.azure.core.annotation.PathParam;
+import com.azure.core.annotation.QueryParam;
+import com.azure.core.annotation.ReturnType;
+import com.azure.core.annotation.ServiceInterface;
+import com.azure.core.annotation.ServiceMethod;
+import com.azure.core.annotation.UnexpectedResponseExceptionType;
+import com.azure.core.http.rest.Response;
+import com.azure.core.http.rest.RestProxy;
+import com.azure.core.management.exception.ManagementException;
+import com.azure.core.util.Context;
+import com.azure.core.util.FluxUtil;
+import com.azure.resourcemanager.databoxedge.fluent.DeviceCapacityInfoesClient;
+import com.azure.resourcemanager.databoxedge.fluent.models.DeviceCapacityInfoInner;
+import reactor.core.publisher.Mono;
+
+/** An instance of this class provides access to all the operations defined in DeviceCapacityInfoesClient. */
+public final class DeviceCapacityInfoesClientImpl implements DeviceCapacityInfoesClient {
+ /** The proxy service used to perform REST calls. */
+ private final DeviceCapacityInfoesService service;
+
+ /** The service client containing this operation class. */
+ private final DataBoxEdgeManagementClientImpl client;
+
+ /**
+ * Initializes an instance of DeviceCapacityInfoesClientImpl.
+ *
+ * @param client the instance of the service client containing this operation class.
+ */
+ DeviceCapacityInfoesClientImpl(DataBoxEdgeManagementClientImpl client) {
+ this.service =
+ RestProxy
+ .create(DeviceCapacityInfoesService.class, client.getHttpPipeline(), client.getSerializerAdapter());
+ this.client = client;
+ }
+
+ /**
+ * The interface defining all the services for DataBoxEdgeManagementClientDeviceCapacityInfoes to be used by the
+ * proxy service to perform REST calls.
+ */
+ @Host("{$host}")
+ @ServiceInterface(name = "DataBoxEdgeManagemen")
+ public interface DeviceCapacityInfoesService {
+ @Headers({"Content-Type: application/json"})
+ @Get(
+ "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataBoxEdge/dataBoxEdgeDevices/{deviceName}/deviceCapacityInfo/default")
+ @ExpectedResponses({200})
+ @UnexpectedResponseExceptionType(ManagementException.class)
+ Mono> getDeviceCapacityInfo(
+ @HostParam("$host") String endpoint,
+ @PathParam("subscriptionId") String subscriptionId,
+ @PathParam("resourceGroupName") String resourceGroupName,
+ @QueryParam("api-version") String apiVersion,
+ @PathParam("deviceName") String deviceName,
+ @HeaderParam("Accept") String accept,
+ Context context);
+ }
+
+ /**
+ * Gets the properties of the specified device capacity info.
+ *
+ * @param resourceGroupName The resource group name.
+ * @param deviceName The device name.
+ * @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 device capacity info along with {@link Response} on successful completion
+ * of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private Mono> getDeviceCapacityInfoWithResponseAsync(
+ String resourceGroupName, String deviceName) {
+ 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 (deviceName == null) {
+ return Mono.error(new IllegalArgumentException("Parameter deviceName is required and cannot be null."));
+ }
+ final String accept = "application/json";
+ return FluxUtil
+ .withContext(
+ context ->
+ service
+ .getDeviceCapacityInfo(
+ this.client.getEndpoint(),
+ this.client.getSubscriptionId(),
+ resourceGroupName,
+ this.client.getApiVersion(),
+ deviceName,
+ accept,
+ context))
+ .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
+ }
+
+ /**
+ * Gets the properties of the specified device capacity info.
+ *
+ * @param resourceGroupName The resource group name.
+ * @param deviceName The device name.
+ * @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 device capacity info along with {@link Response} on successful completion
+ * of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private Mono> getDeviceCapacityInfoWithResponseAsync(
+ String resourceGroupName, String deviceName, 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 (deviceName == null) {
+ return Mono.error(new IllegalArgumentException("Parameter deviceName is required and cannot be null."));
+ }
+ final String accept = "application/json";
+ context = this.client.mergeContext(context);
+ return service
+ .getDeviceCapacityInfo(
+ this.client.getEndpoint(),
+ this.client.getSubscriptionId(),
+ resourceGroupName,
+ this.client.getApiVersion(),
+ deviceName,
+ accept,
+ context);
+ }
+
+ /**
+ * Gets the properties of the specified device capacity info.
+ *
+ * @param resourceGroupName The resource group name.
+ * @param deviceName The device name.
+ * @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 device capacity info on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private Mono getDeviceCapacityInfoAsync(String resourceGroupName, String deviceName) {
+ return getDeviceCapacityInfoWithResponseAsync(resourceGroupName, deviceName)
+ .flatMap(res -> Mono.justOrEmpty(res.getValue()));
+ }
+
+ /**
+ * Gets the properties of the specified device capacity info.
+ *
+ * @param resourceGroupName The resource group name.
+ * @param deviceName The device name.
+ * @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 device capacity info along with {@link Response}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response getDeviceCapacityInfoWithResponse(
+ String resourceGroupName, String deviceName, Context context) {
+ return getDeviceCapacityInfoWithResponseAsync(resourceGroupName, deviceName, context).block();
+ }
+
+ /**
+ * Gets the properties of the specified device capacity info.
+ *
+ * @param resourceGroupName The resource group name.
+ * @param deviceName The device name.
+ * @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 device capacity info.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public DeviceCapacityInfoInner getDeviceCapacityInfo(String resourceGroupName, String deviceName) {
+ return getDeviceCapacityInfoWithResponse(resourceGroupName, deviceName, Context.NONE).getValue();
+ }
+}
diff --git a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DeviceCapacityInfoesImpl.java b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DeviceCapacityInfoesImpl.java
new file mode 100644
index 000000000000..d6ad86bff10f
--- /dev/null
+++ b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DeviceCapacityInfoesImpl.java
@@ -0,0 +1,61 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) AutoRest Code Generator.
+
+package com.azure.resourcemanager.databoxedge.implementation;
+
+import com.azure.core.http.rest.Response;
+import com.azure.core.http.rest.SimpleResponse;
+import com.azure.core.util.Context;
+import com.azure.core.util.logging.ClientLogger;
+import com.azure.resourcemanager.databoxedge.fluent.DeviceCapacityInfoesClient;
+import com.azure.resourcemanager.databoxedge.fluent.models.DeviceCapacityInfoInner;
+import com.azure.resourcemanager.databoxedge.models.DeviceCapacityInfo;
+import com.azure.resourcemanager.databoxedge.models.DeviceCapacityInfoes;
+
+public final class DeviceCapacityInfoesImpl implements DeviceCapacityInfoes {
+ private static final ClientLogger LOGGER = new ClientLogger(DeviceCapacityInfoesImpl.class);
+
+ private final DeviceCapacityInfoesClient innerClient;
+
+ private final com.azure.resourcemanager.databoxedge.DataBoxEdgeManager serviceManager;
+
+ public DeviceCapacityInfoesImpl(
+ DeviceCapacityInfoesClient innerClient,
+ com.azure.resourcemanager.databoxedge.DataBoxEdgeManager serviceManager) {
+ this.innerClient = innerClient;
+ this.serviceManager = serviceManager;
+ }
+
+ public Response getDeviceCapacityInfoWithResponse(
+ String resourceGroupName, String deviceName, Context context) {
+ Response inner =
+ this.serviceClient().getDeviceCapacityInfoWithResponse(resourceGroupName, deviceName, context);
+ if (inner != null) {
+ return new SimpleResponse<>(
+ inner.getRequest(),
+ inner.getStatusCode(),
+ inner.getHeaders(),
+ new DeviceCapacityInfoImpl(inner.getValue(), this.manager()));
+ } else {
+ return null;
+ }
+ }
+
+ public DeviceCapacityInfo getDeviceCapacityInfo(String resourceGroupName, String deviceName) {
+ DeviceCapacityInfoInner inner = this.serviceClient().getDeviceCapacityInfo(resourceGroupName, deviceName);
+ if (inner != null) {
+ return new DeviceCapacityInfoImpl(inner, this.manager());
+ } else {
+ return null;
+ }
+ }
+
+ private DeviceCapacityInfoesClient serviceClient() {
+ return this.innerClient;
+ }
+
+ private com.azure.resourcemanager.databoxedge.DataBoxEdgeManager manager() {
+ return this.serviceManager;
+ }
+}
diff --git a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DevicesClientImpl.java b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DevicesClientImpl.java
index 370d5d126a68..9af2ea5b9ef5 100644
--- a/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DevicesClientImpl.java
+++ b/sdk/databoxedge/azure-resourcemanager-databoxedge/src/main/java/com/azure/resourcemanager/databoxedge/implementation/DevicesClientImpl.java
@@ -36,9 +36,11 @@
import com.azure.resourcemanager.databoxedge.fluent.DevicesClient;
import com.azure.resourcemanager.databoxedge.fluent.models.DataBoxEdgeDeviceExtendedInfoInner;
import com.azure.resourcemanager.databoxedge.fluent.models.DataBoxEdgeDeviceInner;
+import com.azure.resourcemanager.databoxedge.fluent.models.GenerateCertResponseInner;
import com.azure.resourcemanager.databoxedge.fluent.models.NetworkSettingsInner;
import com.azure.resourcemanager.databoxedge.fluent.models.UpdateSummaryInner;
import com.azure.resourcemanager.databoxedge.fluent.models.UploadCertificateResponseInner;
+import com.azure.resourcemanager.databoxedge.models.DataBoxEdgeDeviceExtendedInfoPatch;
import com.azure.resourcemanager.databoxedge.models.DataBoxEdgeDeviceList;
import com.azure.resourcemanager.databoxedge.models.DataBoxEdgeDevicePatch;
import com.azure.resourcemanager.databoxedge.models.SecuritySettings;
@@ -86,8 +88,7 @@ Mono> list(
@Headers({"Content-Type: application/json"})
@Get(
- "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataBoxEdge"
- + "/dataBoxEdgeDevices")
+ "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataBoxEdge/dataBoxEdgeDevices")
@ExpectedResponses({200})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono> listByResourceGroup(
@@ -101,8 +102,7 @@ Mono