From 1063aa623d45ff2354e9a4ff0cc834825bbbce00 Mon Sep 17 00:00:00 2001 From: SDK Automation Date: Wed, 28 Oct 2020 05:53:07 +0000 Subject: [PATCH] Generated from 106fe2745c96b3db0c9e806e9ea392b3fc69037f --- .../mgmt-v2020_03_01_preview/pom.xml | 135 ++ .../ErrorResponseBody.java | 79 ++ .../v2020_03_01_preview/OfferDetail.java | 175 +++ .../v2020_03_01_preview/OperationDisplay.java | 121 ++ .../v2020_03_01_preview/OperationResult.java | 30 + .../OrganizationOperations.java | 27 + .../OrganizationResource.java | 171 +++ .../OrganizationResourceProperties.java | 143 ++ ...nizationResourcePropertiesOfferDetail.java | 16 + ...anizationResourcePropertiesUserDetail.java | 16 + .../OrganizationResourceUpdate.java | 44 + .../v2020_03_01_preview/Organizations.java | 25 + .../v2020_03_01_preview/ProvisionState.java | 62 + .../ResourceProviderDefaultErrorResponse.java | 33 + ...ProviderDefaultErrorResponseException.java | 45 + .../v2020_03_01_preview/SaaSOfferStatus.java | 65 + .../v2020_03_01_preview/UserDetail.java | 95 ++ .../ConfluentManagementClientImpl.java | 210 +++ .../implementation/ConfluentManager.java | 111 ++ .../implementation/IdParsingUtils.java | 57 + .../implementation/OperationResultImpl.java | 37 + .../implementation/OperationResultInner.java | 70 + .../OrganizationOperationsImpl.java | 49 + .../OrganizationOperationsInner.java | 280 ++++ .../OrganizationResourceImpl.java | 98 ++ .../OrganizationResourceInner.java | 149 ++ .../implementation/OrganizationsImpl.java | 138 ++ .../implementation/OrganizationsInner.java | 1257 +++++++++++++++++ .../implementation/PageImpl.java | 75 + .../implementation/package-info.java | 10 + .../v2020_03_01_preview/package-info.java | 10 + 31 files changed, 3833 insertions(+) create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/pom.xml create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/ErrorResponseBody.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OfferDetail.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OperationDisplay.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OperationResult.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OrganizationOperations.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OrganizationResource.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OrganizationResourceProperties.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OrganizationResourcePropertiesOfferDetail.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OrganizationResourcePropertiesUserDetail.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OrganizationResourceUpdate.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/Organizations.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/ProvisionState.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/ResourceProviderDefaultErrorResponse.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/ResourceProviderDefaultErrorResponseException.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/SaaSOfferStatus.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/UserDetail.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/ConfluentManagementClientImpl.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/ConfluentManager.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/IdParsingUtils.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OperationResultImpl.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OperationResultInner.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OrganizationOperationsImpl.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OrganizationOperationsInner.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OrganizationResourceImpl.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OrganizationResourceInner.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OrganizationsImpl.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OrganizationsInner.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/PageImpl.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/package-info.java create mode 100644 sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/package-info.java diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/pom.xml b/sdk/confluent/mgmt-v2020_03_01_preview/pom.xml new file mode 100644 index 0000000000000..83cc611ecd958 --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/pom.xml @@ -0,0 +1,135 @@ + + + 4.0.0 + com.microsoft.azure.confluent.v2020_03_01_preview + + com.microsoft.azure + azure-arm-parent + 1.1.0 + ../../../pom.management.xml + + azure-mgmt-confluent + 1.0.0-beta + jar + Microsoft Azure SDK for Confluent Management + This package contains Microsoft Confluent Management SDK. + https://github.com/Azure/azure-sdk-for-java + + + The MIT License (MIT) + http://opensource.org/licenses/MIT + repo + + + + scm:git:https://github.com/Azure/azure-sdk-for-java + scm:git:git@github.com:Azure/azure-sdk-for-java.git + HEAD + + + UTF-8 + + + + + microsoft + Microsoft + + + + + com.microsoft.azure + azure-client-runtime + + + com.microsoft.azure + azure-arm-client-runtime + + + junit + junit + test + + + com.microsoft.azure + azure-client-authentication + test + + + com.microsoft.azure + azure-mgmt-resources + test + + + com.microsoft.azure + azure-arm-client-runtime + test-jar + test + + 1.6.5 + + + + + + org.apache.maven.plugins + maven-jar-plugin + + + + true + true + + + + + + org.codehaus.mojo + build-helper-maven-plugin + + + org.apache.maven.plugins + maven-compiler-plugin + 3.1 + + 1.7 + 1.7 + + + com.microsoft.azure.management.apigeneration.LangDefinitionProcessor + + + true + true + + true + true + + + + + org.apache.maven.plugins + maven-javadoc-plugin + 2.8 + + *.implementation.*;*.utils.*;com.microsoft.schemas._2003._10.serialization;*.blob.core.search + + + /** +
* Copyright (c) Microsoft Corporation. All rights reserved. +
* Licensed under the MIT License. See License.txt in the project root for +
* license information. +
*/ + ]]> + + + + + + diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/ErrorResponseBody.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/ErrorResponseBody.java new file mode 100644 index 0000000000000..bd6286768ff07 --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/ErrorResponseBody.java @@ -0,0 +1,79 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview; + +import java.util.List; +import com.fasterxml.jackson.annotation.JsonProperty; + +/** + * ErrorResponseBody. + * Response body of Error. + */ +public class ErrorResponseBody { + /** + * Error code. + */ + @JsonProperty(value = "code", access = JsonProperty.Access.WRITE_ONLY) + private String code; + + /** + * Error message. + */ + @JsonProperty(value = "message", access = JsonProperty.Access.WRITE_ONLY) + private String message; + + /** + * Error target. + */ + @JsonProperty(value = "target", access = JsonProperty.Access.WRITE_ONLY) + private String target; + + /** + * Error detail. + */ + @JsonProperty(value = "details", access = JsonProperty.Access.WRITE_ONLY) + private List details; + + /** + * Get error code. + * + * @return the code value + */ + public String code() { + return this.code; + } + + /** + * Get error message. + * + * @return the message value + */ + public String message() { + return this.message; + } + + /** + * Get error target. + * + * @return the target value + */ + public String target() { + return this.target; + } + + /** + * Get error detail. + * + * @return the details value + */ + public List details() { + return this.details; + } + +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OfferDetail.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OfferDetail.java new file mode 100644 index 0000000000000..fc9205183503c --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OfferDetail.java @@ -0,0 +1,175 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview; + +import com.fasterxml.jackson.annotation.JsonProperty; + +/** + * Confluent Offer detail. + */ +public class OfferDetail { + /** + * Publisher Id. + */ + @JsonProperty(value = "publisherId") + private String publisherId; + + /** + * Offer Id. + */ + @JsonProperty(value = "id") + private String id; + + /** + * Offer Plan Id. + */ + @JsonProperty(value = "planId") + private String planId; + + /** + * Offer Plan Name. + */ + @JsonProperty(value = "planName") + private String planName; + + /** + * Offer Plan Term unit. + */ + @JsonProperty(value = "termUnit") + private String termUnit; + + /** + * SaaS Offer Status. Possible values include: 'Started', + * 'PendingFulfillmentStart', 'InProgress', 'Subscribed', 'Suspended', + * 'Reinstated', 'Succeeded', 'Failed', 'Unsubscribed', 'Updating'. + */ + @JsonProperty(value = "status") + private SaaSOfferStatus status; + + /** + * Get publisher Id. + * + * @return the publisherId value + */ + public String publisherId() { + return this.publisherId; + } + + /** + * Set publisher Id. + * + * @param publisherId the publisherId value to set + * @return the OfferDetail object itself. + */ + public OfferDetail withPublisherId(String publisherId) { + this.publisherId = publisherId; + return this; + } + + /** + * Get offer Id. + * + * @return the id value + */ + public String id() { + return this.id; + } + + /** + * Set offer Id. + * + * @param id the id value to set + * @return the OfferDetail object itself. + */ + public OfferDetail withId(String id) { + this.id = id; + return this; + } + + /** + * Get offer Plan Id. + * + * @return the planId value + */ + public String planId() { + return this.planId; + } + + /** + * Set offer Plan Id. + * + * @param planId the planId value to set + * @return the OfferDetail object itself. + */ + public OfferDetail withPlanId(String planId) { + this.planId = planId; + return this; + } + + /** + * Get offer Plan Name. + * + * @return the planName value + */ + public String planName() { + return this.planName; + } + + /** + * Set offer Plan Name. + * + * @param planName the planName value to set + * @return the OfferDetail object itself. + */ + public OfferDetail withPlanName(String planName) { + this.planName = planName; + return this; + } + + /** + * Get offer Plan Term unit. + * + * @return the termUnit value + */ + public String termUnit() { + return this.termUnit; + } + + /** + * Set offer Plan Term unit. + * + * @param termUnit the termUnit value to set + * @return the OfferDetail object itself. + */ + public OfferDetail withTermUnit(String termUnit) { + this.termUnit = termUnit; + return this; + } + + /** + * Get saaS Offer Status. Possible values include: 'Started', 'PendingFulfillmentStart', 'InProgress', 'Subscribed', 'Suspended', 'Reinstated', 'Succeeded', 'Failed', 'Unsubscribed', 'Updating'. + * + * @return the status value + */ + public SaaSOfferStatus status() { + return this.status; + } + + /** + * Set saaS Offer Status. Possible values include: 'Started', 'PendingFulfillmentStart', 'InProgress', 'Subscribed', 'Suspended', 'Reinstated', 'Succeeded', 'Failed', 'Unsubscribed', 'Updating'. + * + * @param status the status value to set + * @return the OfferDetail object itself. + */ + public OfferDetail withStatus(SaaSOfferStatus status) { + this.status = status; + return this; + } + +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OperationDisplay.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OperationDisplay.java new file mode 100644 index 0000000000000..353bcdedaef4d --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OperationDisplay.java @@ -0,0 +1,121 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview; + +import com.fasterxml.jackson.annotation.JsonProperty; + +/** + * The object that represents the operation. + */ +public class OperationDisplay { + /** + * Service provider: Microsoft.Confluent. + */ + @JsonProperty(value = "provider") + private String provider; + + /** + * Type on which the operation is performed, e.g., 'clusters'. + */ + @JsonProperty(value = "resource") + private String resource; + + /** + * Operation type, e.g., read, write, delete, etc. + */ + @JsonProperty(value = "operation") + private String operation; + + /** + * Description of the operation, e.g., 'Write confluent'. + */ + @JsonProperty(value = "description") + private String description; + + /** + * Get service provider: Microsoft.Confluent. + * + * @return the provider value + */ + public String provider() { + return this.provider; + } + + /** + * Set service provider: Microsoft.Confluent. + * + * @param provider the provider value to set + * @return the OperationDisplay object itself. + */ + public OperationDisplay withProvider(String provider) { + this.provider = provider; + return this; + } + + /** + * Get type on which the operation is performed, e.g., 'clusters'. + * + * @return the resource value + */ + public String resource() { + return this.resource; + } + + /** + * Set type on which the operation is performed, e.g., 'clusters'. + * + * @param resource the resource value to set + * @return the OperationDisplay object itself. + */ + public OperationDisplay withResource(String resource) { + this.resource = resource; + return this; + } + + /** + * Get operation type, e.g., read, write, delete, etc. + * + * @return the operation value + */ + public String operation() { + return this.operation; + } + + /** + * Set operation type, e.g., read, write, delete, etc. + * + * @param operation the operation value to set + * @return the OperationDisplay object itself. + */ + public OperationDisplay withOperation(String operation) { + this.operation = operation; + return this; + } + + /** + * Get description of the operation, e.g., 'Write confluent'. + * + * @return the description value + */ + public String description() { + return this.description; + } + + /** + * Set description of the operation, e.g., 'Write confluent'. + * + * @param description the description value to set + * @return the OperationDisplay object itself. + */ + public OperationDisplay withDescription(String description) { + this.description = description; + return this; + } + +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OperationResult.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OperationResult.java new file mode 100644 index 0000000000000..a382a630498c2 --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OperationResult.java @@ -0,0 +1,30 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview; + +import com.microsoft.azure.arm.model.HasInner; +import com.microsoft.azure.arm.resources.models.HasManager; +import com.microsoft.azure.management.confluent.v2020_03_01_preview.implementation.ConfluentManager; +import com.microsoft.azure.management.confluent.v2020_03_01_preview.implementation.OperationResultInner; + +/** + * Type representing OperationResult. + */ +public interface OperationResult extends HasInner, HasManager { + /** + * @return the display value. + */ + OperationDisplay display(); + + /** + * @return the name value. + */ + String name(); + +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OrganizationOperations.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OrganizationOperations.java new file mode 100644 index 0000000000000..cb60dd093f744 --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OrganizationOperations.java @@ -0,0 +1,27 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview; + +import rx.Observable; +import com.microsoft.azure.management.confluent.v2020_03_01_preview.implementation.OrganizationOperationsInner; +import com.microsoft.azure.arm.model.HasInner; + +/** + * Type representing OrganizationOperations. + */ +public interface OrganizationOperations extends HasInner { + /** + * List all operations provided by Microsoft.Confluent. + * + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable for the request + */ + Observable listAsync(); + +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OrganizationResource.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OrganizationResource.java new file mode 100644 index 0000000000000..04b155c708dc9 --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OrganizationResource.java @@ -0,0 +1,171 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview; + +import com.microsoft.azure.arm.model.HasInner; +import com.microsoft.azure.arm.resources.models.Resource; +import com.microsoft.azure.arm.resources.models.GroupableResourceCore; +import com.microsoft.azure.arm.resources.models.HasResourceGroup; +import com.microsoft.azure.arm.model.Refreshable; +import com.microsoft.azure.arm.model.Updatable; +import com.microsoft.azure.arm.model.Appliable; +import com.microsoft.azure.arm.model.Creatable; +import com.microsoft.azure.arm.resources.models.HasManager; +import com.microsoft.azure.management.confluent.v2020_03_01_preview.implementation.ConfluentManager; +import org.joda.time.DateTime; +import com.microsoft.azure.management.confluent.v2020_03_01_preview.implementation.OrganizationResourceInner; + +/** + * Type representing OrganizationResource. + */ +public interface OrganizationResource extends HasInner, Resource, GroupableResourceCore, HasResourceGroup, Refreshable, Updatable, HasManager { + /** + * @return the createdTime value. + */ + DateTime createdTime(); + + /** + * @return the offerDetail value. + */ + OrganizationResourcePropertiesOfferDetail offerDetail(); + + /** + * @return the organizationId value. + */ + String organizationId(); + + /** + * @return the provisioningState value. + */ + ProvisionState provisioningState(); + + /** + * @return the ssoUrl value. + */ + String ssoUrl(); + + /** + * @return the userDetail value. + */ + OrganizationResourcePropertiesUserDetail userDetail(); + + /** + * The entirety of the OrganizationResource definition. + */ + interface Definition extends DefinitionStages.Blank, DefinitionStages.WithGroup, DefinitionStages.WithCreate { + } + + /** + * Grouping of OrganizationResource definition stages. + */ + interface DefinitionStages { + /** + * The first stage of a OrganizationResource definition. + */ + interface Blank extends GroupableResourceCore.DefinitionWithRegion { + } + + /** + * The stage of the OrganizationResource definition allowing to specify the resource group. + */ + interface WithGroup extends GroupableResourceCore.DefinitionStages.WithGroup { + } + + /** + * The stage of the organizationresource definition allowing to specify OfferDetail. + */ + interface WithOfferDetail { + /** + * Specifies offerDetail. + * @param offerDetail Confluent offer detail + * @return the next definition stage + */ + WithCreate withOfferDetail(OrganizationResourcePropertiesOfferDetail offerDetail); + } + + /** + * The stage of the organizationresource definition allowing to specify ProvisioningState. + */ + interface WithProvisioningState { + /** + * Specifies provisioningState. + * @param provisioningState Provision states for confluent RP. Possible values include: 'Accepted', 'Creating', 'Updating', 'Deleting', 'Succeeded', 'Failed', 'Canceled', 'Deleted', 'NotSpecified' + * @return the next definition stage + */ + WithCreate withProvisioningState(ProvisionState provisioningState); + } + + /** + * The stage of the organizationresource definition allowing to specify UserDetail. + */ + interface WithUserDetail { + /** + * Specifies userDetail. + * @param userDetail Subscriber detail + * @return the next definition stage + */ + WithCreate withUserDetail(OrganizationResourcePropertiesUserDetail userDetail); + } + + /** + * The stage of the definition which contains all the minimum required inputs for + * the resource to be created (via {@link WithCreate#create()}), but also allows + * for any other optional settings to be specified. + */ + interface WithCreate extends Creatable, Resource.DefinitionWithTags, DefinitionStages.WithOfferDetail, DefinitionStages.WithProvisioningState, DefinitionStages.WithUserDetail { + } + } + /** + * The template for a OrganizationResource update operation, containing all the settings that can be modified. + */ + interface Update extends Appliable, Resource.UpdateWithTags, UpdateStages.WithOfferDetail, UpdateStages.WithProvisioningState, UpdateStages.WithUserDetail { + } + + /** + * Grouping of OrganizationResource update stages. + */ + interface UpdateStages { + /** + * The stage of the organizationresource update allowing to specify OfferDetail. + */ + interface WithOfferDetail { + /** + * Specifies offerDetail. + * @param offerDetail Confluent offer detail + * @return the next update stage + */ + Update withOfferDetail(OrganizationResourcePropertiesOfferDetail offerDetail); + } + + /** + * The stage of the organizationresource update allowing to specify ProvisioningState. + */ + interface WithProvisioningState { + /** + * Specifies provisioningState. + * @param provisioningState Provision states for confluent RP. Possible values include: 'Accepted', 'Creating', 'Updating', 'Deleting', 'Succeeded', 'Failed', 'Canceled', 'Deleted', 'NotSpecified' + * @return the next update stage + */ + Update withProvisioningState(ProvisionState provisioningState); + } + + /** + * The stage of the organizationresource update allowing to specify UserDetail. + */ + interface WithUserDetail { + /** + * Specifies userDetail. + * @param userDetail Subscriber detail + * @return the next update stage + */ + Update withUserDetail(OrganizationResourcePropertiesUserDetail userDetail); + } + + } +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OrganizationResourceProperties.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OrganizationResourceProperties.java new file mode 100644 index 0000000000000..d8bc5d38ab764 --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OrganizationResourceProperties.java @@ -0,0 +1,143 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview; + +import org.joda.time.DateTime; +import com.fasterxml.jackson.annotation.JsonProperty; + +/** + * Organization resource property. + */ +public class OrganizationResourceProperties { + /** + * The creation time of the resource. + */ + @JsonProperty(value = "createdTime", access = JsonProperty.Access.WRITE_ONLY) + private DateTime createdTime; + + /** + * Provision states for confluent RP. Possible values include: 'Accepted', + * 'Creating', 'Updating', 'Deleting', 'Succeeded', 'Failed', 'Canceled', + * 'Deleted', 'NotSpecified'. + */ + @JsonProperty(value = "provisioningState") + private ProvisionState provisioningState; + + /** + * Id of the Confluent organization. + */ + @JsonProperty(value = "organizationId", access = JsonProperty.Access.WRITE_ONLY) + private String organizationId; + + /** + * SSO url for the Confluent organization. + */ + @JsonProperty(value = "ssoUrl", access = JsonProperty.Access.WRITE_ONLY) + private String ssoUrl; + + /** + * Confluent offer detail. + */ + @JsonProperty(value = "offerDetail") + private OrganizationResourcePropertiesOfferDetail offerDetail; + + /** + * Subscriber detail. + */ + @JsonProperty(value = "userDetail") + private OrganizationResourcePropertiesUserDetail userDetail; + + /** + * Get the creation time of the resource. + * + * @return the createdTime value + */ + public DateTime createdTime() { + return this.createdTime; + } + + /** + * Get provision states for confluent RP. Possible values include: 'Accepted', 'Creating', 'Updating', 'Deleting', 'Succeeded', 'Failed', 'Canceled', 'Deleted', 'NotSpecified'. + * + * @return the provisioningState value + */ + public ProvisionState provisioningState() { + return this.provisioningState; + } + + /** + * Set provision states for confluent RP. Possible values include: 'Accepted', 'Creating', 'Updating', 'Deleting', 'Succeeded', 'Failed', 'Canceled', 'Deleted', 'NotSpecified'. + * + * @param provisioningState the provisioningState value to set + * @return the OrganizationResourceProperties object itself. + */ + public OrganizationResourceProperties withProvisioningState(ProvisionState provisioningState) { + this.provisioningState = provisioningState; + return this; + } + + /** + * Get id of the Confluent organization. + * + * @return the organizationId value + */ + public String organizationId() { + return this.organizationId; + } + + /** + * Get sSO url for the Confluent organization. + * + * @return the ssoUrl value + */ + public String ssoUrl() { + return this.ssoUrl; + } + + /** + * Get confluent offer detail. + * + * @return the offerDetail value + */ + public OrganizationResourcePropertiesOfferDetail offerDetail() { + return this.offerDetail; + } + + /** + * Set confluent offer detail. + * + * @param offerDetail the offerDetail value to set + * @return the OrganizationResourceProperties object itself. + */ + public OrganizationResourceProperties withOfferDetail(OrganizationResourcePropertiesOfferDetail offerDetail) { + this.offerDetail = offerDetail; + return this; + } + + /** + * Get subscriber detail. + * + * @return the userDetail value + */ + public OrganizationResourcePropertiesUserDetail userDetail() { + return this.userDetail; + } + + /** + * Set subscriber detail. + * + * @param userDetail the userDetail value to set + * @return the OrganizationResourceProperties object itself. + */ + public OrganizationResourceProperties withUserDetail(OrganizationResourcePropertiesUserDetail userDetail) { + this.userDetail = userDetail; + return this; + } + +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OrganizationResourcePropertiesOfferDetail.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OrganizationResourcePropertiesOfferDetail.java new file mode 100644 index 0000000000000..e9ce367315b77 --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OrganizationResourcePropertiesOfferDetail.java @@ -0,0 +1,16 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview; + + +/** + * Confluent offer detail. + */ +public class OrganizationResourcePropertiesOfferDetail extends OfferDetail { +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OrganizationResourcePropertiesUserDetail.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OrganizationResourcePropertiesUserDetail.java new file mode 100644 index 0000000000000..501b245f32ca4 --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OrganizationResourcePropertiesUserDetail.java @@ -0,0 +1,16 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview; + + +/** + * Subscriber detail. + */ +public class OrganizationResourcePropertiesUserDetail extends UserDetail { +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OrganizationResourceUpdate.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OrganizationResourceUpdate.java new file mode 100644 index 0000000000000..658c58ea73283 --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/OrganizationResourceUpdate.java @@ -0,0 +1,44 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview; + +import java.util.Map; +import com.fasterxml.jackson.annotation.JsonProperty; + +/** + * Organization Resource update. + */ +public class OrganizationResourceUpdate { + /** + * ARM resource tags. + */ + @JsonProperty(value = "tags") + private Map tags; + + /** + * Get aRM resource tags. + * + * @return the tags value + */ + public Map tags() { + return this.tags; + } + + /** + * Set aRM resource tags. + * + * @param tags the tags value to set + * @return the OrganizationResourceUpdate object itself. + */ + public OrganizationResourceUpdate withTags(Map tags) { + this.tags = tags; + return this; + } + +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/Organizations.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/Organizations.java new file mode 100644 index 0000000000000..6f81c0ce3b9b6 --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/Organizations.java @@ -0,0 +1,25 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview; + +import com.microsoft.azure.arm.collection.SupportsCreating; +import com.microsoft.azure.arm.resources.collection.SupportsDeletingByResourceGroup; +import com.microsoft.azure.arm.resources.collection.SupportsBatchDeletion; +import com.microsoft.azure.arm.resources.collection.SupportsGettingByResourceGroup; +import rx.Observable; +import com.microsoft.azure.arm.resources.collection.SupportsListingByResourceGroup; +import com.microsoft.azure.arm.collection.SupportsListing; +import com.microsoft.azure.management.confluent.v2020_03_01_preview.implementation.OrganizationsInner; +import com.microsoft.azure.arm.model.HasInner; + +/** + * Type representing Organizations. + */ +public interface Organizations extends SupportsCreating, SupportsDeletingByResourceGroup, SupportsBatchDeletion, SupportsGettingByResourceGroup, SupportsListingByResourceGroup, SupportsListing, HasInner { +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/ProvisionState.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/ProvisionState.java new file mode 100644 index 0000000000000..39f1308d705eb --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/ProvisionState.java @@ -0,0 +1,62 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview; + +import java.util.Collection; +import com.fasterxml.jackson.annotation.JsonCreator; +import com.microsoft.rest.ExpandableStringEnum; + +/** + * Defines values for ProvisionState. + */ +public final class ProvisionState extends ExpandableStringEnum { + /** Static value Accepted for ProvisionState. */ + public static final ProvisionState ACCEPTED = fromString("Accepted"); + + /** Static value Creating for ProvisionState. */ + public static final ProvisionState CREATING = fromString("Creating"); + + /** Static value Updating for ProvisionState. */ + public static final ProvisionState UPDATING = fromString("Updating"); + + /** Static value Deleting for ProvisionState. */ + public static final ProvisionState DELETING = fromString("Deleting"); + + /** Static value Succeeded for ProvisionState. */ + public static final ProvisionState SUCCEEDED = fromString("Succeeded"); + + /** Static value Failed for ProvisionState. */ + public static final ProvisionState FAILED = fromString("Failed"); + + /** Static value Canceled for ProvisionState. */ + public static final ProvisionState CANCELED = fromString("Canceled"); + + /** Static value Deleted for ProvisionState. */ + public static final ProvisionState DELETED = fromString("Deleted"); + + /** Static value NotSpecified for ProvisionState. */ + public static final ProvisionState NOT_SPECIFIED = fromString("NotSpecified"); + + /** + * Creates or finds a ProvisionState from its string representation. + * @param name a name to look for + * @return the corresponding ProvisionState + */ + @JsonCreator + public static ProvisionState fromString(String name) { + return fromString(name, ProvisionState.class); + } + + /** + * @return known ProvisionState values + */ + public static Collection values() { + return values(ProvisionState.class); + } +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/ResourceProviderDefaultErrorResponse.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/ResourceProviderDefaultErrorResponse.java new file mode 100644 index 0000000000000..7d75808ce3435 --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/ResourceProviderDefaultErrorResponse.java @@ -0,0 +1,33 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview; + +import com.fasterxml.jackson.annotation.JsonProperty; + +/** + * ResourceProviderDefaultErrorResponse. + * Default error response for resource provider. + */ +public class ResourceProviderDefaultErrorResponse { + /** + * Response body of Error. + */ + @JsonProperty(value = "error", access = JsonProperty.Access.WRITE_ONLY) + private ErrorResponseBody error; + + /** + * Get response body of Error. + * + * @return the error value + */ + public ErrorResponseBody error() { + return this.error; + } + +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/ResourceProviderDefaultErrorResponseException.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/ResourceProviderDefaultErrorResponseException.java new file mode 100644 index 0000000000000..6c1a090aa6e41 --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/ResourceProviderDefaultErrorResponseException.java @@ -0,0 +1,45 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview; + +import com.microsoft.rest.RestException; +import okhttp3.ResponseBody; +import retrofit2.Response; + +/** + * Exception thrown for an invalid response with + * ResourceProviderDefaultErrorResponse information. + */ +public class ResourceProviderDefaultErrorResponseException extends RestException { + /** + * Initializes a new instance of the ResourceProviderDefaultErrorResponseException class. + * + * @param message the exception message or the response content if a message is not available + * @param response the HTTP response + */ + public ResourceProviderDefaultErrorResponseException(final String message, final Response response) { + super(message, response); + } + + /** + * Initializes a new instance of the ResourceProviderDefaultErrorResponseException class. + * + * @param message the exception message or the response content if a message is not available + * @param response the HTTP response + * @param body the deserialized response body + */ + public ResourceProviderDefaultErrorResponseException(final String message, final Response response, final ResourceProviderDefaultErrorResponse body) { + super(message, response, body); + } + + @Override + public ResourceProviderDefaultErrorResponse body() { + return (ResourceProviderDefaultErrorResponse) super.body(); + } +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/SaaSOfferStatus.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/SaaSOfferStatus.java new file mode 100644 index 0000000000000..f79b2eca3410a --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/SaaSOfferStatus.java @@ -0,0 +1,65 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview; + +import java.util.Collection; +import com.fasterxml.jackson.annotation.JsonCreator; +import com.microsoft.rest.ExpandableStringEnum; + +/** + * Defines values for SaaSOfferStatus. + */ +public final class SaaSOfferStatus extends ExpandableStringEnum { + /** Static value Started for SaaSOfferStatus. */ + public static final SaaSOfferStatus STARTED = fromString("Started"); + + /** Static value PendingFulfillmentStart for SaaSOfferStatus. */ + public static final SaaSOfferStatus PENDING_FULFILLMENT_START = fromString("PendingFulfillmentStart"); + + /** Static value InProgress for SaaSOfferStatus. */ + public static final SaaSOfferStatus IN_PROGRESS = fromString("InProgress"); + + /** Static value Subscribed for SaaSOfferStatus. */ + public static final SaaSOfferStatus SUBSCRIBED = fromString("Subscribed"); + + /** Static value Suspended for SaaSOfferStatus. */ + public static final SaaSOfferStatus SUSPENDED = fromString("Suspended"); + + /** Static value Reinstated for SaaSOfferStatus. */ + public static final SaaSOfferStatus REINSTATED = fromString("Reinstated"); + + /** Static value Succeeded for SaaSOfferStatus. */ + public static final SaaSOfferStatus SUCCEEDED = fromString("Succeeded"); + + /** Static value Failed for SaaSOfferStatus. */ + public static final SaaSOfferStatus FAILED = fromString("Failed"); + + /** Static value Unsubscribed for SaaSOfferStatus. */ + public static final SaaSOfferStatus UNSUBSCRIBED = fromString("Unsubscribed"); + + /** Static value Updating for SaaSOfferStatus. */ + public static final SaaSOfferStatus UPDATING = fromString("Updating"); + + /** + * Creates or finds a SaaSOfferStatus from its string representation. + * @param name a name to look for + * @return the corresponding SaaSOfferStatus + */ + @JsonCreator + public static SaaSOfferStatus fromString(String name) { + return fromString(name, SaaSOfferStatus.class); + } + + /** + * @return known SaaSOfferStatus values + */ + public static Collection values() { + return values(SaaSOfferStatus.class); + } +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/UserDetail.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/UserDetail.java new file mode 100644 index 0000000000000..b153764215900 --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/UserDetail.java @@ -0,0 +1,95 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview; + +import com.fasterxml.jackson.annotation.JsonProperty; + +/** + * Subscriber detail. + */ +public class UserDetail { + /** + * First name. + */ + @JsonProperty(value = "firstName") + private String firstName; + + /** + * Last name. + */ + @JsonProperty(value = "lastName") + private String lastName; + + /** + * Email address. + */ + @JsonProperty(value = "emailAddress") + private String emailAddress; + + /** + * Get first name. + * + * @return the firstName value + */ + public String firstName() { + return this.firstName; + } + + /** + * Set first name. + * + * @param firstName the firstName value to set + * @return the UserDetail object itself. + */ + public UserDetail withFirstName(String firstName) { + this.firstName = firstName; + return this; + } + + /** + * Get last name. + * + * @return the lastName value + */ + public String lastName() { + return this.lastName; + } + + /** + * Set last name. + * + * @param lastName the lastName value to set + * @return the UserDetail object itself. + */ + public UserDetail withLastName(String lastName) { + this.lastName = lastName; + return this; + } + + /** + * Get email address. + * + * @return the emailAddress value + */ + public String emailAddress() { + return this.emailAddress; + } + + /** + * Set email address. + * + * @param emailAddress the emailAddress value to set + * @return the UserDetail object itself. + */ + public UserDetail withEmailAddress(String emailAddress) { + this.emailAddress = emailAddress; + return this; + } + +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/ConfluentManagementClientImpl.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/ConfluentManagementClientImpl.java new file mode 100644 index 0000000000000..78f2388353acb --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/ConfluentManagementClientImpl.java @@ -0,0 +1,210 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview.implementation; + +import com.microsoft.azure.AzureClient; +import com.microsoft.azure.AzureServiceClient; +import com.microsoft.rest.credentials.ServiceClientCredentials; +import com.microsoft.rest.RestClient; + +/** + * Initializes a new instance of the ConfluentManagementClientImpl class. + */ +public class ConfluentManagementClientImpl extends AzureServiceClient { + /** the {@link AzureClient} used for long running operations. */ + private AzureClient azureClient; + + /** + * Gets the {@link AzureClient} used for long running operations. + * @return the azure client; + */ + public AzureClient getAzureClient() { + return this.azureClient; + } + + /** Client Api Version. */ + private String apiVersion; + + /** + * Gets Client Api Version. + * + * @return the apiVersion value. + */ + public String apiVersion() { + return this.apiVersion; + } + + /** Microsoft Azure subscription id. */ + private String subscriptionId; + + /** + * Gets Microsoft Azure subscription id. + * + * @return the subscriptionId value. + */ + public String subscriptionId() { + return this.subscriptionId; + } + + /** + * Sets Microsoft Azure subscription id. + * + * @param subscriptionId the subscriptionId value. + * @return the service client itself + */ + public ConfluentManagementClientImpl withSubscriptionId(String subscriptionId) { + this.subscriptionId = subscriptionId; + return this; + } + + /** The preferred language for the response. */ + private String acceptLanguage; + + /** + * Gets The preferred language for the response. + * + * @return the acceptLanguage value. + */ + public String acceptLanguage() { + return this.acceptLanguage; + } + + /** + * Sets The preferred language for the response. + * + * @param acceptLanguage the acceptLanguage value. + * @return the service client itself + */ + public ConfluentManagementClientImpl withAcceptLanguage(String acceptLanguage) { + this.acceptLanguage = acceptLanguage; + return this; + } + + /** The retry timeout in seconds for Long Running Operations. Default value is 30. */ + private int longRunningOperationRetryTimeout; + + /** + * Gets The retry timeout in seconds for Long Running Operations. Default value is 30. + * + * @return the longRunningOperationRetryTimeout value. + */ + public int longRunningOperationRetryTimeout() { + return this.longRunningOperationRetryTimeout; + } + + /** + * Sets The retry timeout in seconds for Long Running Operations. Default value is 30. + * + * @param longRunningOperationRetryTimeout the longRunningOperationRetryTimeout value. + * @return the service client itself + */ + public ConfluentManagementClientImpl withLongRunningOperationRetryTimeout(int longRunningOperationRetryTimeout) { + this.longRunningOperationRetryTimeout = longRunningOperationRetryTimeout; + return this; + } + + /** Whether a unique x-ms-client-request-id should be generated. When set to true a unique x-ms-client-request-id value is generated and included in each request. Default is true. */ + private boolean generateClientRequestId; + + /** + * Gets Whether a unique x-ms-client-request-id should be generated. When set to true a unique x-ms-client-request-id value is generated and included in each request. Default is true. + * + * @return the generateClientRequestId value. + */ + public boolean generateClientRequestId() { + return this.generateClientRequestId; + } + + /** + * Sets Whether a unique x-ms-client-request-id should be generated. When set to true a unique x-ms-client-request-id value is generated and included in each request. Default is true. + * + * @param generateClientRequestId the generateClientRequestId value. + * @return the service client itself + */ + public ConfluentManagementClientImpl withGenerateClientRequestId(boolean generateClientRequestId) { + this.generateClientRequestId = generateClientRequestId; + return this; + } + + /** + * The OrganizationOperationsInner object to access its operations. + */ + private OrganizationOperationsInner organizationOperations; + + /** + * Gets the OrganizationOperationsInner object to access its operations. + * @return the OrganizationOperationsInner object. + */ + public OrganizationOperationsInner organizationOperations() { + return this.organizationOperations; + } + + /** + * The OrganizationsInner object to access its operations. + */ + private OrganizationsInner organizations; + + /** + * Gets the OrganizationsInner object to access its operations. + * @return the OrganizationsInner object. + */ + public OrganizationsInner organizations() { + return this.organizations; + } + + /** + * Initializes an instance of ConfluentManagementClient client. + * + * @param credentials the management credentials for Azure + */ + public ConfluentManagementClientImpl(ServiceClientCredentials credentials) { + this("https://management.azure.com", credentials); + } + + /** + * Initializes an instance of ConfluentManagementClient client. + * + * @param baseUrl the base URL of the host + * @param credentials the management credentials for Azure + */ + public ConfluentManagementClientImpl(String baseUrl, ServiceClientCredentials credentials) { + super(baseUrl, credentials); + initialize(); + } + + /** + * Initializes an instance of ConfluentManagementClient client. + * + * @param restClient the REST client to connect to Azure. + */ + public ConfluentManagementClientImpl(RestClient restClient) { + super(restClient); + initialize(); + } + + protected void initialize() { + this.apiVersion = "2020-03-01-preview"; + this.acceptLanguage = "en-US"; + this.longRunningOperationRetryTimeout = 30; + this.generateClientRequestId = true; + this.organizationOperations = new OrganizationOperationsInner(restClient().retrofit(), this); + this.organizations = new OrganizationsInner(restClient().retrofit(), this); + this.azureClient = new AzureClient(this); + } + + /** + * Gets the User-Agent header for the client. + * + * @return the user agent string. + */ + @Override + public String userAgent() { + return String.format("%s (%s, %s, auto-generated)", super.userAgent(), "ConfluentManagementClient", "2020-03-01-preview"); + } +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/ConfluentManager.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/ConfluentManager.java new file mode 100644 index 0000000000000..5e02b173ef9c7 --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/ConfluentManager.java @@ -0,0 +1,111 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview.implementation; + +import com.microsoft.azure.AzureEnvironment; +import com.microsoft.azure.AzureResponseBuilder; +import com.microsoft.azure.credentials.AzureTokenCredentials; +import com.microsoft.azure.management.apigeneration.Beta; +import com.microsoft.azure.management.apigeneration.Beta.SinceVersion; +import com.microsoft.azure.arm.resources.AzureConfigurable; +import com.microsoft.azure.serializer.AzureJacksonAdapter; +import com.microsoft.rest.RestClient; +import com.microsoft.azure.management.confluent.v2020_03_01_preview.OrganizationOperations; +import com.microsoft.azure.management.confluent.v2020_03_01_preview.Organizations; +import com.microsoft.azure.arm.resources.implementation.AzureConfigurableCoreImpl; +import com.microsoft.azure.arm.resources.implementation.ManagerCore; + +/** + * Entry point to Azure Confluent resource management. + */ +public final class ConfluentManager extends ManagerCore { + private OrganizationOperations organizationOperations; + private Organizations organizations; + /** + * Get a Configurable instance that can be used to create ConfluentManager with optional configuration. + * + * @return the instance allowing configurations + */ + public static Configurable configure() { + return new ConfluentManager.ConfigurableImpl(); + } + /** + * Creates an instance of ConfluentManager that exposes Confluent resource management API entry points. + * + * @param credentials the credentials to use + * @param subscriptionId the subscription UUID + * @return the ConfluentManager + */ + public static ConfluentManager authenticate(AzureTokenCredentials credentials, String subscriptionId) { + return new ConfluentManager(new RestClient.Builder() + .withBaseUrl(credentials.environment(), AzureEnvironment.Endpoint.RESOURCE_MANAGER) + .withCredentials(credentials) + .withSerializerAdapter(new AzureJacksonAdapter()) + .withResponseBuilderFactory(new AzureResponseBuilder.Factory()) + .build(), subscriptionId); + } + /** + * Creates an instance of ConfluentManager that exposes Confluent resource management API entry points. + * + * @param restClient the RestClient to be used for API calls. + * @param subscriptionId the subscription UUID + * @return the ConfluentManager + */ + public static ConfluentManager authenticate(RestClient restClient, String subscriptionId) { + return new ConfluentManager(restClient, subscriptionId); + } + /** + * The interface allowing configurations to be set. + */ + public interface Configurable extends AzureConfigurable { + /** + * Creates an instance of ConfluentManager that exposes Confluent management API entry points. + * + * @param credentials the credentials to use + * @param subscriptionId the subscription UUID + * @return the interface exposing Confluent management API entry points that work across subscriptions + */ + ConfluentManager authenticate(AzureTokenCredentials credentials, String subscriptionId); + } + + /** + * @return Entry point to manage OrganizationOperations. + */ + public OrganizationOperations organizationOperations() { + if (this.organizationOperations == null) { + this.organizationOperations = new OrganizationOperationsImpl(this); + } + return this.organizationOperations; + } + + /** + * @return Entry point to manage Organizations. + */ + public Organizations organizations() { + if (this.organizations == null) { + this.organizations = new OrganizationsImpl(this); + } + return this.organizations; + } + + /** + * The implementation for Configurable interface. + */ + private static final class ConfigurableImpl extends AzureConfigurableCoreImpl implements Configurable { + public ConfluentManager authenticate(AzureTokenCredentials credentials, String subscriptionId) { + return ConfluentManager.authenticate(buildRestClient(credentials), subscriptionId); + } + } + private ConfluentManager(RestClient restClient, String subscriptionId) { + super( + restClient, + subscriptionId, + new ConfluentManagementClientImpl(restClient).withSubscriptionId(subscriptionId)); + } +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/IdParsingUtils.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/IdParsingUtils.java new file mode 100644 index 0000000000000..9a79963eff397 --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/IdParsingUtils.java @@ -0,0 +1,57 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview.implementation; +import java.util.Arrays; +import java.util.Iterator; + +class IdParsingUtils { + public static String getValueFromIdByName(String id, String name) { + if (id == null) { + return null; + } + Iterable iterable = Arrays.asList(id.split("/")); + Iterator itr = iterable.iterator(); + while (itr.hasNext()) { + String part = itr.next(); + if (part != null && part.trim() != "") { + if (part.equalsIgnoreCase(name)) { + if (itr.hasNext()) { + return itr.next(); + } else { + return null; + } + } + } + } + return null; + } + + public static String getValueFromIdByPosition(String id, int pos) { + if (id == null) { + return null; + } + Iterable iterable = Arrays.asList(id.split("/")); + Iterator itr = iterable.iterator(); + int index = 0; + while (itr.hasNext()) { + String part = itr.next(); + if (part != null && part.trim() != "") { + if (index == pos) { + if (itr.hasNext()) { + return itr.next(); + } else { + return null; + } + } + } + index++; + } + return null; + } +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OperationResultImpl.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OperationResultImpl.java new file mode 100644 index 0000000000000..653403f95af2d --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OperationResultImpl.java @@ -0,0 +1,37 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview.implementation; + +import com.microsoft.azure.management.confluent.v2020_03_01_preview.OperationResult; +import com.microsoft.azure.arm.model.implementation.WrapperImpl; +import com.microsoft.azure.management.confluent.v2020_03_01_preview.OperationDisplay; + +class OperationResultImpl extends WrapperImpl implements OperationResult { + private final ConfluentManager manager; + OperationResultImpl(OperationResultInner inner, ConfluentManager manager) { + super(inner); + this.manager = manager; + } + + @Override + public ConfluentManager manager() { + return this.manager; + } + + @Override + public OperationDisplay display() { + return this.inner().display(); + } + + @Override + public String name() { + return this.inner().name(); + } + +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OperationResultInner.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OperationResultInner.java new file mode 100644 index 0000000000000..ab8c76ad2b6cc --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OperationResultInner.java @@ -0,0 +1,70 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview.implementation; + +import com.microsoft.azure.management.confluent.v2020_03_01_preview.OperationDisplay; +import com.fasterxml.jackson.annotation.JsonProperty; + +/** + * An Confluent REST API operation. + */ +public class OperationResultInner { + /** + * Operation name: {provider}/{resource}/{operation}. + */ + @JsonProperty(value = "name") + private String name; + + /** + * The object that represents the operation. + */ + @JsonProperty(value = "display") + private OperationDisplay display; + + /** + * Get operation name: {provider}/{resource}/{operation}. + * + * @return the name value + */ + public String name() { + return this.name; + } + + /** + * Set operation name: {provider}/{resource}/{operation}. + * + * @param name the name value to set + * @return the OperationResultInner object itself. + */ + public OperationResultInner withName(String name) { + this.name = name; + return this; + } + + /** + * Get the object that represents the operation. + * + * @return the display value + */ + public OperationDisplay display() { + return this.display; + } + + /** + * Set the object that represents the operation. + * + * @param display the display value to set + * @return the OperationResultInner object itself. + */ + public OperationResultInner withDisplay(OperationDisplay display) { + this.display = display; + return this; + } + +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OrganizationOperationsImpl.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OrganizationOperationsImpl.java new file mode 100644 index 0000000000000..52edd44cc4565 --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OrganizationOperationsImpl.java @@ -0,0 +1,49 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + * abc + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview.implementation; + +import com.microsoft.azure.arm.model.implementation.WrapperImpl; +import com.microsoft.azure.management.confluent.v2020_03_01_preview.OrganizationOperations; +import rx.functions.Func1; +import rx.Observable; +import com.microsoft.azure.Page; +import com.microsoft.azure.management.confluent.v2020_03_01_preview.OperationResult; + +class OrganizationOperationsImpl extends WrapperImpl implements OrganizationOperations { + private final ConfluentManager manager; + + OrganizationOperationsImpl(ConfluentManager manager) { + super(manager.inner().organizationOperations()); + this.manager = manager; + } + + public ConfluentManager manager() { + return this.manager; + } + + @Override + public Observable listAsync() { + OrganizationOperationsInner client = this.inner(); + return client.listAsync() + .flatMapIterable(new Func1, Iterable>() { + @Override + public Iterable call(Page page) { + return page.items(); + } + }) + .map(new Func1() { + @Override + public OperationResult call(OperationResultInner inner) { + return new OperationResultImpl(inner, manager()); + } + }); + } + +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OrganizationOperationsInner.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OrganizationOperationsInner.java new file mode 100644 index 0000000000000..aa0d6715f9018 --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OrganizationOperationsInner.java @@ -0,0 +1,280 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview.implementation; + +import retrofit2.Retrofit; +import com.google.common.reflect.TypeToken; +import com.microsoft.azure.AzureServiceFuture; +import com.microsoft.azure.ListOperationCallback; +import com.microsoft.azure.management.confluent.v2020_03_01_preview.ResourceProviderDefaultErrorResponseException; +import com.microsoft.azure.Page; +import com.microsoft.azure.PagedList; +import com.microsoft.rest.ServiceFuture; +import com.microsoft.rest.ServiceResponse; +import java.io.IOException; +import java.util.List; +import okhttp3.ResponseBody; +import retrofit2.http.GET; +import retrofit2.http.Header; +import retrofit2.http.Headers; +import retrofit2.http.Query; +import retrofit2.http.Url; +import retrofit2.Response; +import rx.functions.Func1; +import rx.Observable; + +/** + * An instance of this class provides access to all the operations defined + * in OrganizationOperations. + */ +public class OrganizationOperationsInner { + /** The Retrofit service to perform REST calls. */ + private OrganizationOperationsService service; + /** The service client containing this operation class. */ + private ConfluentManagementClientImpl client; + + /** + * Initializes an instance of OrganizationOperationsInner. + * + * @param retrofit the Retrofit instance built from a Retrofit Builder. + * @param client the instance of the service client containing this operation class. + */ + public OrganizationOperationsInner(Retrofit retrofit, ConfluentManagementClientImpl client) { + this.service = retrofit.create(OrganizationOperationsService.class); + this.client = client; + } + + /** + * The interface defining all the services for OrganizationOperations to be + * used by Retrofit to perform actually REST calls. + */ + interface OrganizationOperationsService { + @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.confluent.v2020_03_01_preview.OrganizationOperations list" }) + @GET("providers/Microsoft.Confluent/operations") + Observable> list(@Query("api-version") String apiVersion, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent); + + @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.confluent.v2020_03_01_preview.OrganizationOperations listNext" }) + @GET + Observable> listNext(@Url String nextUrl, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent); + + } + + /** + * List all operations provided by Microsoft.Confluent. + * + * @throws IllegalArgumentException thrown if parameters fail the validation + * @throws ResourceProviderDefaultErrorResponseException thrown if the request is rejected by server + * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent + * @return the PagedList<OperationResultInner> object if successful. + */ + public PagedList list() { + ServiceResponse> response = listSinglePageAsync().toBlocking().single(); + return new PagedList(response.body()) { + @Override + public Page nextPage(String nextPageLink) { + return listNextSinglePageAsync(nextPageLink).toBlocking().single().body(); + } + }; + } + + /** + * List all operations provided by Microsoft.Confluent. + * + * @param serviceCallback the async ServiceCallback to handle successful and failed responses. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the {@link ServiceFuture} object + */ + public ServiceFuture> listAsync(final ListOperationCallback serviceCallback) { + return AzureServiceFuture.fromPageResponse( + listSinglePageAsync(), + new Func1>>>() { + @Override + public Observable>> call(String nextPageLink) { + return listNextSinglePageAsync(nextPageLink); + } + }, + serviceCallback); + } + + /** + * List all operations provided by Microsoft.Confluent. + * + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the PagedList<OperationResultInner> object + */ + public Observable> listAsync() { + return listWithServiceResponseAsync() + .map(new Func1>, Page>() { + @Override + public Page call(ServiceResponse> response) { + return response.body(); + } + }); + } + + /** + * List all operations provided by Microsoft.Confluent. + * + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the PagedList<OperationResultInner> object + */ + public Observable>> listWithServiceResponseAsync() { + return listSinglePageAsync() + .concatMap(new Func1>, Observable>>>() { + @Override + public Observable>> call(ServiceResponse> page) { + String nextPageLink = page.body().nextPageLink(); + if (nextPageLink == null) { + return Observable.just(page); + } + return Observable.just(page).concatWith(listNextWithServiceResponseAsync(nextPageLink)); + } + }); + } + + /** + * List all operations provided by Microsoft.Confluent. + * + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the PagedList<OperationResultInner> object wrapped in {@link ServiceResponse} if successful. + */ + public Observable>> listSinglePageAsync() { + return service.list(this.client.apiVersion(), this.client.acceptLanguage(), this.client.userAgent()) + .flatMap(new Func1, Observable>>>() { + @Override + public Observable>> call(Response response) { + try { + ServiceResponse> result = listDelegate(response); + return Observable.just(new ServiceResponse>(result.body(), result.response())); + } catch (Throwable t) { + return Observable.error(t); + } + } + }); + } + + private ServiceResponse> listDelegate(Response response) throws ResourceProviderDefaultErrorResponseException, IOException { + return this.client.restClient().responseBuilderFactory()., ResourceProviderDefaultErrorResponseException>newInstance(this.client.serializerAdapter()) + .register(200, new TypeToken>() { }.getType()) + .registerError(ResourceProviderDefaultErrorResponseException.class) + .build(response); + } + + /** + * List all operations provided by Microsoft.Confluent. + * + * @param nextPageLink The NextLink from the previous successful call to List operation. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @throws ResourceProviderDefaultErrorResponseException thrown if the request is rejected by server + * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent + * @return the PagedList<OperationResultInner> object if successful. + */ + public PagedList listNext(final String nextPageLink) { + ServiceResponse> response = listNextSinglePageAsync(nextPageLink).toBlocking().single(); + return new PagedList(response.body()) { + @Override + public Page nextPage(String nextPageLink) { + return listNextSinglePageAsync(nextPageLink).toBlocking().single().body(); + } + }; + } + + /** + * List all operations provided by Microsoft.Confluent. + * + * @param nextPageLink The NextLink from the previous successful call to List operation. + * @param serviceFuture the ServiceFuture object tracking the Retrofit calls + * @param serviceCallback the async ServiceCallback to handle successful and failed responses. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the {@link ServiceFuture} object + */ + public ServiceFuture> listNextAsync(final String nextPageLink, final ServiceFuture> serviceFuture, final ListOperationCallback serviceCallback) { + return AzureServiceFuture.fromPageResponse( + listNextSinglePageAsync(nextPageLink), + new Func1>>>() { + @Override + public Observable>> call(String nextPageLink) { + return listNextSinglePageAsync(nextPageLink); + } + }, + serviceCallback); + } + + /** + * List all operations provided by Microsoft.Confluent. + * + * @param nextPageLink The NextLink from the previous successful call to List operation. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the PagedList<OperationResultInner> object + */ + public Observable> listNextAsync(final String nextPageLink) { + return listNextWithServiceResponseAsync(nextPageLink) + .map(new Func1>, Page>() { + @Override + public Page call(ServiceResponse> response) { + return response.body(); + } + }); + } + + /** + * List all operations provided by Microsoft.Confluent. + * + * @param nextPageLink The NextLink from the previous successful call to List operation. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the PagedList<OperationResultInner> object + */ + public Observable>> listNextWithServiceResponseAsync(final String nextPageLink) { + return listNextSinglePageAsync(nextPageLink) + .concatMap(new Func1>, Observable>>>() { + @Override + public Observable>> call(ServiceResponse> page) { + String nextPageLink = page.body().nextPageLink(); + if (nextPageLink == null) { + return Observable.just(page); + } + return Observable.just(page).concatWith(listNextWithServiceResponseAsync(nextPageLink)); + } + }); + } + + /** + * List all operations provided by Microsoft.Confluent. + * + ServiceResponse> * @param nextPageLink The NextLink from the previous successful call to List operation. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the PagedList<OperationResultInner> object wrapped in {@link ServiceResponse} if successful. + */ + public Observable>> listNextSinglePageAsync(final String nextPageLink) { + if (nextPageLink == null) { + throw new IllegalArgumentException("Parameter nextPageLink is required and cannot be null."); + } + String nextUrl = String.format("%s", nextPageLink); + return service.listNext(nextUrl, this.client.acceptLanguage(), this.client.userAgent()) + .flatMap(new Func1, Observable>>>() { + @Override + public Observable>> call(Response response) { + try { + ServiceResponse> result = listNextDelegate(response); + return Observable.just(new ServiceResponse>(result.body(), result.response())); + } catch (Throwable t) { + return Observable.error(t); + } + } + }); + } + + private ServiceResponse> listNextDelegate(Response response) throws ResourceProviderDefaultErrorResponseException, IOException, IllegalArgumentException { + return this.client.restClient().responseBuilderFactory()., ResourceProviderDefaultErrorResponseException>newInstance(this.client.serializerAdapter()) + .register(200, new TypeToken>() { }.getType()) + .registerError(ResourceProviderDefaultErrorResponseException.class) + .build(response); + } + +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OrganizationResourceImpl.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OrganizationResourceImpl.java new file mode 100644 index 0000000000000..6e6d7edf14b01 --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OrganizationResourceImpl.java @@ -0,0 +1,98 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview.implementation; + +import com.microsoft.azure.arm.resources.models.implementation.GroupableResourceCoreImpl; +import com.microsoft.azure.management.confluent.v2020_03_01_preview.OrganizationResource; +import rx.Observable; +import org.joda.time.DateTime; +import com.microsoft.azure.management.confluent.v2020_03_01_preview.ProvisionState; +import com.microsoft.azure.management.confluent.v2020_03_01_preview.OrganizationResourcePropertiesOfferDetail; +import com.microsoft.azure.management.confluent.v2020_03_01_preview.OrganizationResourcePropertiesUserDetail; + +class OrganizationResourceImpl extends GroupableResourceCoreImpl implements OrganizationResource, OrganizationResource.Definition, OrganizationResource.Update { + OrganizationResourceImpl(String name, OrganizationResourceInner inner, ConfluentManager manager) { + super(name, inner, manager); + } + + @Override + public Observable createResourceAsync() { + OrganizationsInner client = this.manager().inner().organizations(); + return client.createAsync(this.resourceGroupName(), this.name(), this.inner()) + .map(innerToFluentMap(this)); + } + + @Override + public Observable updateResourceAsync() { + OrganizationsInner client = this.manager().inner().organizations(); + return client.createAsync(this.resourceGroupName(), this.name(), this.inner()) + .map(innerToFluentMap(this)); + } + + @Override + protected Observable getInnerAsync() { + OrganizationsInner client = this.manager().inner().organizations(); + return client.getByResourceGroupAsync(this.resourceGroupName(), this.name()); + } + + @Override + public boolean isInCreateMode() { + return this.inner().id() == null; + } + + + @Override + public DateTime createdTime() { + return this.inner().createdTime(); + } + + @Override + public OrganizationResourcePropertiesOfferDetail offerDetail() { + return this.inner().offerDetail(); + } + + @Override + public String organizationId() { + return this.inner().organizationId(); + } + + @Override + public ProvisionState provisioningState() { + return this.inner().provisioningState(); + } + + @Override + public String ssoUrl() { + return this.inner().ssoUrl(); + } + + @Override + public OrganizationResourcePropertiesUserDetail userDetail() { + return this.inner().userDetail(); + } + + @Override + public OrganizationResourceImpl withOfferDetail(OrganizationResourcePropertiesOfferDetail offerDetail) { + this.inner().withOfferDetail(offerDetail); + return this; + } + + @Override + public OrganizationResourceImpl withProvisioningState(ProvisionState provisioningState) { + this.inner().withProvisioningState(provisioningState); + return this; + } + + @Override + public OrganizationResourceImpl withUserDetail(OrganizationResourcePropertiesUserDetail userDetail) { + this.inner().withUserDetail(userDetail); + return this; + } + +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OrganizationResourceInner.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OrganizationResourceInner.java new file mode 100644 index 0000000000000..64ad8f6ac6112 --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OrganizationResourceInner.java @@ -0,0 +1,149 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview.implementation; + +import org.joda.time.DateTime; +import com.microsoft.azure.management.confluent.v2020_03_01_preview.ProvisionState; +import com.microsoft.azure.management.confluent.v2020_03_01_preview.OrganizationResourcePropertiesOfferDetail; +import com.microsoft.azure.management.confluent.v2020_03_01_preview.OrganizationResourcePropertiesUserDetail; +import com.fasterxml.jackson.annotation.JsonProperty; +import com.microsoft.rest.serializer.JsonFlatten; +import com.microsoft.azure.Resource; + +/** + * Organization resource. + */ +@JsonFlatten +public class OrganizationResourceInner extends Resource { + /** + * The creation time of the resource. + */ + @JsonProperty(value = "properties.createdTime", access = JsonProperty.Access.WRITE_ONLY) + private DateTime createdTime; + + /** + * Provision states for confluent RP. Possible values include: 'Accepted', + * 'Creating', 'Updating', 'Deleting', 'Succeeded', 'Failed', 'Canceled', + * 'Deleted', 'NotSpecified'. + */ + @JsonProperty(value = "properties.provisioningState") + private ProvisionState provisioningState; + + /** + * Id of the Confluent organization. + */ + @JsonProperty(value = "properties.organizationId", access = JsonProperty.Access.WRITE_ONLY) + private String organizationId; + + /** + * SSO url for the Confluent organization. + */ + @JsonProperty(value = "properties.ssoUrl", access = JsonProperty.Access.WRITE_ONLY) + private String ssoUrl; + + /** + * Confluent offer detail. + */ + @JsonProperty(value = "properties.offerDetail") + private OrganizationResourcePropertiesOfferDetail offerDetail; + + /** + * Subscriber detail. + */ + @JsonProperty(value = "properties.userDetail") + private OrganizationResourcePropertiesUserDetail userDetail; + + /** + * Get the creation time of the resource. + * + * @return the createdTime value + */ + public DateTime createdTime() { + return this.createdTime; + } + + /** + * Get provision states for confluent RP. Possible values include: 'Accepted', 'Creating', 'Updating', 'Deleting', 'Succeeded', 'Failed', 'Canceled', 'Deleted', 'NotSpecified'. + * + * @return the provisioningState value + */ + public ProvisionState provisioningState() { + return this.provisioningState; + } + + /** + * Set provision states for confluent RP. Possible values include: 'Accepted', 'Creating', 'Updating', 'Deleting', 'Succeeded', 'Failed', 'Canceled', 'Deleted', 'NotSpecified'. + * + * @param provisioningState the provisioningState value to set + * @return the OrganizationResourceInner object itself. + */ + public OrganizationResourceInner withProvisioningState(ProvisionState provisioningState) { + this.provisioningState = provisioningState; + return this; + } + + /** + * Get id of the Confluent organization. + * + * @return the organizationId value + */ + public String organizationId() { + return this.organizationId; + } + + /** + * Get sSO url for the Confluent organization. + * + * @return the ssoUrl value + */ + public String ssoUrl() { + return this.ssoUrl; + } + + /** + * Get confluent offer detail. + * + * @return the offerDetail value + */ + public OrganizationResourcePropertiesOfferDetail offerDetail() { + return this.offerDetail; + } + + /** + * Set confluent offer detail. + * + * @param offerDetail the offerDetail value to set + * @return the OrganizationResourceInner object itself. + */ + public OrganizationResourceInner withOfferDetail(OrganizationResourcePropertiesOfferDetail offerDetail) { + this.offerDetail = offerDetail; + return this; + } + + /** + * Get subscriber detail. + * + * @return the userDetail value + */ + public OrganizationResourcePropertiesUserDetail userDetail() { + return this.userDetail; + } + + /** + * Set subscriber detail. + * + * @param userDetail the userDetail value to set + * @return the OrganizationResourceInner object itself. + */ + public OrganizationResourceInner withUserDetail(OrganizationResourcePropertiesUserDetail userDetail) { + this.userDetail = userDetail; + return this; + } + +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OrganizationsImpl.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OrganizationsImpl.java new file mode 100644 index 0000000000000..4260733ebbd57 --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OrganizationsImpl.java @@ -0,0 +1,138 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + * def + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview.implementation; + +import com.microsoft.azure.arm.resources.collection.implementation.GroupableResourcesCoreImpl; +import com.microsoft.azure.management.confluent.v2020_03_01_preview.Organizations; +import com.microsoft.azure.management.confluent.v2020_03_01_preview.OrganizationResource; +import rx.Observable; +import rx.Completable; +import java.util.ArrayList; +import java.util.Arrays; +import java.util.Collection; +import com.microsoft.azure.arm.resources.ResourceUtilsCore; +import com.microsoft.azure.arm.utils.RXMapper; +import rx.functions.Func1; +import com.microsoft.azure.PagedList; +import com.microsoft.azure.Page; + +class OrganizationsImpl extends GroupableResourcesCoreImpl implements Organizations { + protected OrganizationsImpl(ConfluentManager manager) { + super(manager.inner().organizations(), manager); + } + + @Override + protected Observable getInnerAsync(String resourceGroupName, String name) { + OrganizationsInner client = this.inner(); + return client.getByResourceGroupAsync(resourceGroupName, name); + } + + @Override + protected Completable deleteInnerAsync(String resourceGroupName, String name) { + OrganizationsInner client = this.inner(); + return client.deleteAsync(resourceGroupName, name).toCompletable(); + } + + @Override + public Observable deleteByIdsAsync(Collection ids) { + if (ids == null || ids.isEmpty()) { + return Observable.empty(); + } + Collection> observables = new ArrayList<>(); + for (String id : ids) { + final String resourceGroupName = ResourceUtilsCore.groupFromResourceId(id); + final String name = ResourceUtilsCore.nameFromResourceId(id); + Observable o = RXMapper.map(this.inner().deleteAsync(resourceGroupName, name), id); + observables.add(o); + } + return Observable.mergeDelayError(observables); + } + + @Override + public Observable deleteByIdsAsync(String...ids) { + return this.deleteByIdsAsync(new ArrayList(Arrays.asList(ids))); + } + + @Override + public void deleteByIds(Collection ids) { + if (ids != null && !ids.isEmpty()) { + this.deleteByIdsAsync(ids).toBlocking().last(); + } + } + + @Override + public void deleteByIds(String...ids) { + this.deleteByIds(new ArrayList(Arrays.asList(ids))); + } + + @Override + public PagedList listByResourceGroup(String resourceGroupName) { + OrganizationsInner client = this.inner(); + return this.wrapList(client.listByResourceGroup(resourceGroupName)); + } + + @Override + public Observable listByResourceGroupAsync(String resourceGroupName) { + OrganizationsInner client = this.inner(); + return client.listByResourceGroupAsync(resourceGroupName) + .flatMapIterable(new Func1, Iterable>() { + @Override + public Iterable call(Page page) { + return page.items(); + } + }) + .map(new Func1() { + @Override + public OrganizationResource call(OrganizationResourceInner inner) { + return wrapModel(inner); + } + }); + } + + @Override + public PagedList list() { + OrganizationsInner client = this.inner(); + return this.wrapList(client.list()); + } + + @Override + public Observable listAsync() { + OrganizationsInner client = this.inner(); + return client.listAsync() + .flatMapIterable(new Func1, Iterable>() { + @Override + public Iterable call(Page page) { + return page.items(); + } + }) + .map(new Func1() { + @Override + public OrganizationResource call(OrganizationResourceInner inner) { + return wrapModel(inner); + } + }); + } + + @Override + public OrganizationResourceImpl define(String name) { + return wrapModel(name); + } + + @Override + protected OrganizationResourceImpl wrapModel(OrganizationResourceInner inner) { + return new OrganizationResourceImpl(inner.name(), inner, manager()); + } + + @Override + protected OrganizationResourceImpl wrapModel(String name) { + return new OrganizationResourceImpl(name, new OrganizationResourceInner(), this.manager()); + } + +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OrganizationsInner.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OrganizationsInner.java new file mode 100644 index 0000000000000..2db96e039818f --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/OrganizationsInner.java @@ -0,0 +1,1257 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview.implementation; + +import com.microsoft.azure.arm.collection.InnerSupportsGet; +import com.microsoft.azure.arm.collection.InnerSupportsDelete; +import com.microsoft.azure.arm.collection.InnerSupportsListing; +import retrofit2.Retrofit; +import com.google.common.reflect.TypeToken; +import com.microsoft.azure.AzureServiceFuture; +import com.microsoft.azure.ListOperationCallback; +import com.microsoft.azure.management.confluent.v2020_03_01_preview.OrganizationResourceUpdate; +import com.microsoft.azure.management.confluent.v2020_03_01_preview.ResourceProviderDefaultErrorResponseException; +import com.microsoft.azure.Page; +import com.microsoft.azure.PagedList; +import com.microsoft.rest.ServiceCallback; +import com.microsoft.rest.ServiceFuture; +import com.microsoft.rest.ServiceResponse; +import com.microsoft.rest.Validator; +import java.io.IOException; +import java.util.List; +import java.util.Map; +import okhttp3.ResponseBody; +import retrofit2.http.Body; +import retrofit2.http.GET; +import retrofit2.http.Header; +import retrofit2.http.Headers; +import retrofit2.http.HTTP; +import retrofit2.http.PATCH; +import retrofit2.http.Path; +import retrofit2.http.PUT; +import retrofit2.http.Query; +import retrofit2.http.Url; +import retrofit2.Response; +import rx.functions.Func1; +import rx.Observable; + +/** + * An instance of this class provides access to all the operations defined + * in Organizations. + */ +public class OrganizationsInner implements InnerSupportsGet, InnerSupportsDelete, InnerSupportsListing { + /** The Retrofit service to perform REST calls. */ + private OrganizationsService service; + /** The service client containing this operation class. */ + private ConfluentManagementClientImpl client; + + /** + * Initializes an instance of OrganizationsInner. + * + * @param retrofit the Retrofit instance built from a Retrofit Builder. + * @param client the instance of the service client containing this operation class. + */ + public OrganizationsInner(Retrofit retrofit, ConfluentManagementClientImpl client) { + this.service = retrofit.create(OrganizationsService.class); + this.client = client; + } + + /** + * The interface defining all the services for Organizations to be + * used by Retrofit to perform actually REST calls. + */ + interface OrganizationsService { + @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.confluent.v2020_03_01_preview.Organizations list" }) + @GET("subscriptions/{subscriptionId}/providers/Microsoft.Confluent/organizations") + Observable> list(@Path("subscriptionId") String subscriptionId, @Query("api-version") String apiVersion, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent); + + @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.confluent.v2020_03_01_preview.Organizations listByResourceGroup" }) + @GET("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Confluent/organizations") + Observable> listByResourceGroup(@Path("subscriptionId") String subscriptionId, @Path("resourceGroupName") String resourceGroupName, @Query("api-version") String apiVersion, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent); + + @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.confluent.v2020_03_01_preview.Organizations getByResourceGroup" }) + @GET("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Confluent/organizations/{organizationName}") + Observable> getByResourceGroup(@Path("subscriptionId") String subscriptionId, @Path("resourceGroupName") String resourceGroupName, @Path("organizationName") String organizationName, @Query("api-version") String apiVersion, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent); + + @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.confluent.v2020_03_01_preview.Organizations create" }) + @PUT("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Confluent/organizations/{organizationName}") + Observable> create(@Path("subscriptionId") String subscriptionId, @Path("resourceGroupName") String resourceGroupName, @Path("organizationName") String organizationName, @Query("api-version") String apiVersion, @Body OrganizationResourceInner body, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent); + + @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.confluent.v2020_03_01_preview.Organizations beginCreate" }) + @PUT("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Confluent/organizations/{organizationName}") + Observable> beginCreate(@Path("subscriptionId") String subscriptionId, @Path("resourceGroupName") String resourceGroupName, @Path("organizationName") String organizationName, @Query("api-version") String apiVersion, @Body OrganizationResourceInner body, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent); + + @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.confluent.v2020_03_01_preview.Organizations update" }) + @PATCH("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Confluent/organizations/{organizationName}") + Observable> update(@Path("subscriptionId") String subscriptionId, @Path("resourceGroupName") String resourceGroupName, @Path("organizationName") String organizationName, @Query("api-version") String apiVersion, @Header("accept-language") String acceptLanguage, @Body OrganizationResourceUpdate body, @Header("User-Agent") String userAgent); + + @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.confluent.v2020_03_01_preview.Organizations delete" }) + @HTTP(path = "subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Confluent/organizations/{organizationName}", method = "DELETE", hasBody = true) + Observable> delete(@Path("subscriptionId") String subscriptionId, @Path("resourceGroupName") String resourceGroupName, @Path("organizationName") String organizationName, @Query("api-version") String apiVersion, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent); + + @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.confluent.v2020_03_01_preview.Organizations beginDelete" }) + @HTTP(path = "subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Confluent/organizations/{organizationName}", method = "DELETE", hasBody = true) + Observable> beginDelete(@Path("subscriptionId") String subscriptionId, @Path("resourceGroupName") String resourceGroupName, @Path("organizationName") String organizationName, @Query("api-version") String apiVersion, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent); + + @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.confluent.v2020_03_01_preview.Organizations listNext" }) + @GET + Observable> listNext(@Url String nextUrl, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent); + + @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.confluent.v2020_03_01_preview.Organizations listByResourceGroupNext" }) + @GET + Observable> listByResourceGroupNext(@Url String nextUrl, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent); + + } + + /** + * List all organizations under the specified subscription. + * + * @throws IllegalArgumentException thrown if parameters fail the validation + * @throws ResourceProviderDefaultErrorResponseException thrown if the request is rejected by server + * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent + * @return the PagedList<OrganizationResourceInner> object if successful. + */ + public PagedList list() { + ServiceResponse> response = listSinglePageAsync().toBlocking().single(); + return new PagedList(response.body()) { + @Override + public Page nextPage(String nextPageLink) { + return listNextSinglePageAsync(nextPageLink).toBlocking().single().body(); + } + }; + } + + /** + * List all organizations under the specified subscription. + * + * @param serviceCallback the async ServiceCallback to handle successful and failed responses. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the {@link ServiceFuture} object + */ + public ServiceFuture> listAsync(final ListOperationCallback serviceCallback) { + return AzureServiceFuture.fromPageResponse( + listSinglePageAsync(), + new Func1>>>() { + @Override + public Observable>> call(String nextPageLink) { + return listNextSinglePageAsync(nextPageLink); + } + }, + serviceCallback); + } + + /** + * List all organizations under the specified subscription. + * + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the PagedList<OrganizationResourceInner> object + */ + public Observable> listAsync() { + return listWithServiceResponseAsync() + .map(new Func1>, Page>() { + @Override + public Page call(ServiceResponse> response) { + return response.body(); + } + }); + } + + /** + * List all organizations under the specified subscription. + * + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the PagedList<OrganizationResourceInner> object + */ + public Observable>> listWithServiceResponseAsync() { + return listSinglePageAsync() + .concatMap(new Func1>, Observable>>>() { + @Override + public Observable>> call(ServiceResponse> page) { + String nextPageLink = page.body().nextPageLink(); + if (nextPageLink == null) { + return Observable.just(page); + } + return Observable.just(page).concatWith(listNextWithServiceResponseAsync(nextPageLink)); + } + }); + } + + /** + * List all organizations under the specified subscription. + * + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the PagedList<OrganizationResourceInner> object wrapped in {@link ServiceResponse} if successful. + */ + public Observable>> listSinglePageAsync() { + if (this.client.subscriptionId() == null) { + throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null."); + } + return service.list(this.client.subscriptionId(), this.client.apiVersion(), this.client.acceptLanguage(), this.client.userAgent()) + .flatMap(new Func1, Observable>>>() { + @Override + public Observable>> call(Response response) { + try { + ServiceResponse> result = listDelegate(response); + return Observable.just(new ServiceResponse>(result.body(), result.response())); + } catch (Throwable t) { + return Observable.error(t); + } + } + }); + } + + private ServiceResponse> listDelegate(Response response) throws ResourceProviderDefaultErrorResponseException, IOException, IllegalArgumentException { + return this.client.restClient().responseBuilderFactory()., ResourceProviderDefaultErrorResponseException>newInstance(this.client.serializerAdapter()) + .register(200, new TypeToken>() { }.getType()) + .registerError(ResourceProviderDefaultErrorResponseException.class) + .build(response); + } + + /** + * List all Organizations under the specified resource group. + * + * @param resourceGroupName Resource group name + * @throws IllegalArgumentException thrown if parameters fail the validation + * @throws ResourceProviderDefaultErrorResponseException thrown if the request is rejected by server + * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent + * @return the PagedList<OrganizationResourceInner> object if successful. + */ + public PagedList listByResourceGroup(final String resourceGroupName) { + ServiceResponse> response = listByResourceGroupSinglePageAsync(resourceGroupName).toBlocking().single(); + return new PagedList(response.body()) { + @Override + public Page nextPage(String nextPageLink) { + return listByResourceGroupNextSinglePageAsync(nextPageLink).toBlocking().single().body(); + } + }; + } + + /** + * List all Organizations under the specified resource group. + * + * @param resourceGroupName Resource group name + * @param serviceCallback the async ServiceCallback to handle successful and failed responses. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the {@link ServiceFuture} object + */ + public ServiceFuture> listByResourceGroupAsync(final String resourceGroupName, final ListOperationCallback serviceCallback) { + return AzureServiceFuture.fromPageResponse( + listByResourceGroupSinglePageAsync(resourceGroupName), + new Func1>>>() { + @Override + public Observable>> call(String nextPageLink) { + return listByResourceGroupNextSinglePageAsync(nextPageLink); + } + }, + serviceCallback); + } + + /** + * List all Organizations under the specified resource group. + * + * @param resourceGroupName Resource group name + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the PagedList<OrganizationResourceInner> object + */ + public Observable> listByResourceGroupAsync(final String resourceGroupName) { + return listByResourceGroupWithServiceResponseAsync(resourceGroupName) + .map(new Func1>, Page>() { + @Override + public Page call(ServiceResponse> response) { + return response.body(); + } + }); + } + + /** + * List all Organizations under the specified resource group. + * + * @param resourceGroupName Resource group name + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the PagedList<OrganizationResourceInner> object + */ + public Observable>> listByResourceGroupWithServiceResponseAsync(final String resourceGroupName) { + return listByResourceGroupSinglePageAsync(resourceGroupName) + .concatMap(new Func1>, Observable>>>() { + @Override + public Observable>> call(ServiceResponse> page) { + String nextPageLink = page.body().nextPageLink(); + if (nextPageLink == null) { + return Observable.just(page); + } + return Observable.just(page).concatWith(listByResourceGroupNextWithServiceResponseAsync(nextPageLink)); + } + }); + } + + /** + * List all Organizations under the specified resource group. + * + ServiceResponse> * @param resourceGroupName Resource group name + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the PagedList<OrganizationResourceInner> object wrapped in {@link ServiceResponse} if successful. + */ + public Observable>> listByResourceGroupSinglePageAsync(final String resourceGroupName) { + if (this.client.subscriptionId() == null) { + throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null."); + } + if (resourceGroupName == null) { + throw new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."); + } + return service.listByResourceGroup(this.client.subscriptionId(), resourceGroupName, this.client.apiVersion(), this.client.acceptLanguage(), this.client.userAgent()) + .flatMap(new Func1, Observable>>>() { + @Override + public Observable>> call(Response response) { + try { + ServiceResponse> result = listByResourceGroupDelegate(response); + return Observable.just(new ServiceResponse>(result.body(), result.response())); + } catch (Throwable t) { + return Observable.error(t); + } + } + }); + } + + private ServiceResponse> listByResourceGroupDelegate(Response response) throws ResourceProviderDefaultErrorResponseException, IOException, IllegalArgumentException { + return this.client.restClient().responseBuilderFactory()., ResourceProviderDefaultErrorResponseException>newInstance(this.client.serializerAdapter()) + .register(200, new TypeToken>() { }.getType()) + .registerError(ResourceProviderDefaultErrorResponseException.class) + .build(response); + } + + /** + * Get the properties of a specific Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @throws IllegalArgumentException thrown if parameters fail the validation + * @throws ResourceProviderDefaultErrorResponseException thrown if the request is rejected by server + * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent + * @return the OrganizationResourceInner object if successful. + */ + public OrganizationResourceInner getByResourceGroup(String resourceGroupName, String organizationName) { + return getByResourceGroupWithServiceResponseAsync(resourceGroupName, organizationName).toBlocking().single().body(); + } + + /** + * Get the properties of a specific Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @param serviceCallback the async ServiceCallback to handle successful and failed responses. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the {@link ServiceFuture} object + */ + public ServiceFuture getByResourceGroupAsync(String resourceGroupName, String organizationName, final ServiceCallback serviceCallback) { + return ServiceFuture.fromResponse(getByResourceGroupWithServiceResponseAsync(resourceGroupName, organizationName), serviceCallback); + } + + /** + * Get the properties of a specific Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the OrganizationResourceInner object + */ + public Observable getByResourceGroupAsync(String resourceGroupName, String organizationName) { + return getByResourceGroupWithServiceResponseAsync(resourceGroupName, organizationName).map(new Func1, OrganizationResourceInner>() { + @Override + public OrganizationResourceInner call(ServiceResponse response) { + return response.body(); + } + }); + } + + /** + * Get the properties of a specific Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the OrganizationResourceInner object + */ + public Observable> getByResourceGroupWithServiceResponseAsync(String resourceGroupName, String organizationName) { + if (this.client.subscriptionId() == null) { + throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null."); + } + if (resourceGroupName == null) { + throw new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."); + } + if (organizationName == null) { + throw new IllegalArgumentException("Parameter organizationName is required and cannot be null."); + } + return service.getByResourceGroup(this.client.subscriptionId(), resourceGroupName, organizationName, this.client.apiVersion(), this.client.acceptLanguage(), this.client.userAgent()) + .flatMap(new Func1, Observable>>() { + @Override + public Observable> call(Response response) { + try { + ServiceResponse clientResponse = getByResourceGroupDelegate(response); + return Observable.just(clientResponse); + } catch (Throwable t) { + return Observable.error(t); + } + } + }); + } + + private ServiceResponse getByResourceGroupDelegate(Response response) throws ResourceProviderDefaultErrorResponseException, IOException, IllegalArgumentException { + return this.client.restClient().responseBuilderFactory().newInstance(this.client.serializerAdapter()) + .register(200, new TypeToken() { }.getType()) + .registerError(ResourceProviderDefaultErrorResponseException.class) + .build(response); + } + + /** + * Create Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @throws IllegalArgumentException thrown if parameters fail the validation + * @throws ResourceProviderDefaultErrorResponseException thrown if the request is rejected by server + * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent + * @return the OrganizationResourceInner object if successful. + */ + public OrganizationResourceInner create(String resourceGroupName, String organizationName) { + return createWithServiceResponseAsync(resourceGroupName, organizationName).toBlocking().last().body(); + } + + /** + * Create Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @param serviceCallback the async ServiceCallback to handle successful and failed responses. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the {@link ServiceFuture} object + */ + public ServiceFuture createAsync(String resourceGroupName, String organizationName, final ServiceCallback serviceCallback) { + return ServiceFuture.fromResponse(createWithServiceResponseAsync(resourceGroupName, organizationName), serviceCallback); + } + + /** + * Create Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable for the request + */ + public Observable createAsync(String resourceGroupName, String organizationName) { + return createWithServiceResponseAsync(resourceGroupName, organizationName).map(new Func1, OrganizationResourceInner>() { + @Override + public OrganizationResourceInner call(ServiceResponse response) { + return response.body(); + } + }); + } + + /** + * Create Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable for the request + */ + public Observable> createWithServiceResponseAsync(String resourceGroupName, String organizationName) { + if (this.client.subscriptionId() == null) { + throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null."); + } + if (resourceGroupName == null) { + throw new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."); + } + if (organizationName == null) { + throw new IllegalArgumentException("Parameter organizationName is required and cannot be null."); + } + final OrganizationResourceInner body = null; + Observable> observable = service.create(this.client.subscriptionId(), resourceGroupName, organizationName, this.client.apiVersion(), body, this.client.acceptLanguage(), this.client.userAgent()); + return client.getAzureClient().getPutOrPatchResultAsync(observable, new TypeToken() { }.getType()); + } + /** + * Create Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @param body Organization resource model + * @throws IllegalArgumentException thrown if parameters fail the validation + * @throws ResourceProviderDefaultErrorResponseException thrown if the request is rejected by server + * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent + * @return the OrganizationResourceInner object if successful. + */ + public OrganizationResourceInner create(String resourceGroupName, String organizationName, OrganizationResourceInner body) { + return createWithServiceResponseAsync(resourceGroupName, organizationName, body).toBlocking().last().body(); + } + + /** + * Create Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @param body Organization resource model + * @param serviceCallback the async ServiceCallback to handle successful and failed responses. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the {@link ServiceFuture} object + */ + public ServiceFuture createAsync(String resourceGroupName, String organizationName, OrganizationResourceInner body, final ServiceCallback serviceCallback) { + return ServiceFuture.fromResponse(createWithServiceResponseAsync(resourceGroupName, organizationName, body), serviceCallback); + } + + /** + * Create Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @param body Organization resource model + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable for the request + */ + public Observable createAsync(String resourceGroupName, String organizationName, OrganizationResourceInner body) { + return createWithServiceResponseAsync(resourceGroupName, organizationName, body).map(new Func1, OrganizationResourceInner>() { + @Override + public OrganizationResourceInner call(ServiceResponse response) { + return response.body(); + } + }); + } + + /** + * Create Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @param body Organization resource model + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable for the request + */ + public Observable> createWithServiceResponseAsync(String resourceGroupName, String organizationName, OrganizationResourceInner body) { + if (this.client.subscriptionId() == null) { + throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null."); + } + if (resourceGroupName == null) { + throw new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."); + } + if (organizationName == null) { + throw new IllegalArgumentException("Parameter organizationName is required and cannot be null."); + } + Validator.validate(body); + Observable> observable = service.create(this.client.subscriptionId(), resourceGroupName, organizationName, this.client.apiVersion(), body, this.client.acceptLanguage(), this.client.userAgent()); + return client.getAzureClient().getPutOrPatchResultAsync(observable, new TypeToken() { }.getType()); + } + + /** + * Create Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @throws IllegalArgumentException thrown if parameters fail the validation + * @throws ResourceProviderDefaultErrorResponseException thrown if the request is rejected by server + * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent + * @return the OrganizationResourceInner object if successful. + */ + public OrganizationResourceInner beginCreate(String resourceGroupName, String organizationName) { + return beginCreateWithServiceResponseAsync(resourceGroupName, organizationName).toBlocking().single().body(); + } + + /** + * Create Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @param serviceCallback the async ServiceCallback to handle successful and failed responses. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the {@link ServiceFuture} object + */ + public ServiceFuture beginCreateAsync(String resourceGroupName, String organizationName, final ServiceCallback serviceCallback) { + return ServiceFuture.fromResponse(beginCreateWithServiceResponseAsync(resourceGroupName, organizationName), serviceCallback); + } + + /** + * Create Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the OrganizationResourceInner object + */ + public Observable beginCreateAsync(String resourceGroupName, String organizationName) { + return beginCreateWithServiceResponseAsync(resourceGroupName, organizationName).map(new Func1, OrganizationResourceInner>() { + @Override + public OrganizationResourceInner call(ServiceResponse response) { + return response.body(); + } + }); + } + + /** + * Create Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the OrganizationResourceInner object + */ + public Observable> beginCreateWithServiceResponseAsync(String resourceGroupName, String organizationName) { + if (this.client.subscriptionId() == null) { + throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null."); + } + if (resourceGroupName == null) { + throw new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."); + } + if (organizationName == null) { + throw new IllegalArgumentException("Parameter organizationName is required and cannot be null."); + } + final OrganizationResourceInner body = null; + return service.beginCreate(this.client.subscriptionId(), resourceGroupName, organizationName, this.client.apiVersion(), body, this.client.acceptLanguage(), this.client.userAgent()) + .flatMap(new Func1, Observable>>() { + @Override + public Observable> call(Response response) { + try { + ServiceResponse clientResponse = beginCreateDelegate(response); + return Observable.just(clientResponse); + } catch (Throwable t) { + return Observable.error(t); + } + } + }); + } + + /** + * Create Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @param body Organization resource model + * @throws IllegalArgumentException thrown if parameters fail the validation + * @throws ResourceProviderDefaultErrorResponseException thrown if the request is rejected by server + * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent + * @return the OrganizationResourceInner object if successful. + */ + public OrganizationResourceInner beginCreate(String resourceGroupName, String organizationName, OrganizationResourceInner body) { + return beginCreateWithServiceResponseAsync(resourceGroupName, organizationName, body).toBlocking().single().body(); + } + + /** + * Create Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @param body Organization resource model + * @param serviceCallback the async ServiceCallback to handle successful and failed responses. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the {@link ServiceFuture} object + */ + public ServiceFuture beginCreateAsync(String resourceGroupName, String organizationName, OrganizationResourceInner body, final ServiceCallback serviceCallback) { + return ServiceFuture.fromResponse(beginCreateWithServiceResponseAsync(resourceGroupName, organizationName, body), serviceCallback); + } + + /** + * Create Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @param body Organization resource model + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the OrganizationResourceInner object + */ + public Observable beginCreateAsync(String resourceGroupName, String organizationName, OrganizationResourceInner body) { + return beginCreateWithServiceResponseAsync(resourceGroupName, organizationName, body).map(new Func1, OrganizationResourceInner>() { + @Override + public OrganizationResourceInner call(ServiceResponse response) { + return response.body(); + } + }); + } + + /** + * Create Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @param body Organization resource model + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the OrganizationResourceInner object + */ + public Observable> beginCreateWithServiceResponseAsync(String resourceGroupName, String organizationName, OrganizationResourceInner body) { + if (this.client.subscriptionId() == null) { + throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null."); + } + if (resourceGroupName == null) { + throw new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."); + } + if (organizationName == null) { + throw new IllegalArgumentException("Parameter organizationName is required and cannot be null."); + } + Validator.validate(body); + return service.beginCreate(this.client.subscriptionId(), resourceGroupName, organizationName, this.client.apiVersion(), body, this.client.acceptLanguage(), this.client.userAgent()) + .flatMap(new Func1, Observable>>() { + @Override + public Observable> call(Response response) { + try { + ServiceResponse clientResponse = beginCreateDelegate(response); + return Observable.just(clientResponse); + } catch (Throwable t) { + return Observable.error(t); + } + } + }); + } + + private ServiceResponse beginCreateDelegate(Response response) throws ResourceProviderDefaultErrorResponseException, IOException, IllegalArgumentException { + return this.client.restClient().responseBuilderFactory().newInstance(this.client.serializerAdapter()) + .register(200, new TypeToken() { }.getType()) + .register(201, new TypeToken() { }.getType()) + .registerError(ResourceProviderDefaultErrorResponseException.class) + .build(response); + } + + /** + * Update Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @throws IllegalArgumentException thrown if parameters fail the validation + * @throws ResourceProviderDefaultErrorResponseException thrown if the request is rejected by server + * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent + * @return the OrganizationResourceInner object if successful. + */ + public OrganizationResourceInner update(String resourceGroupName, String organizationName) { + return updateWithServiceResponseAsync(resourceGroupName, organizationName).toBlocking().single().body(); + } + + /** + * Update Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @param serviceCallback the async ServiceCallback to handle successful and failed responses. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the {@link ServiceFuture} object + */ + public ServiceFuture updateAsync(String resourceGroupName, String organizationName, final ServiceCallback serviceCallback) { + return ServiceFuture.fromResponse(updateWithServiceResponseAsync(resourceGroupName, organizationName), serviceCallback); + } + + /** + * Update Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the OrganizationResourceInner object + */ + public Observable updateAsync(String resourceGroupName, String organizationName) { + return updateWithServiceResponseAsync(resourceGroupName, organizationName).map(new Func1, OrganizationResourceInner>() { + @Override + public OrganizationResourceInner call(ServiceResponse response) { + return response.body(); + } + }); + } + + /** + * Update Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the OrganizationResourceInner object + */ + public Observable> updateWithServiceResponseAsync(String resourceGroupName, String organizationName) { + if (this.client.subscriptionId() == null) { + throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null."); + } + if (resourceGroupName == null) { + throw new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."); + } + if (organizationName == null) { + throw new IllegalArgumentException("Parameter organizationName is required and cannot be null."); + } + final Map tags = null; + OrganizationResourceUpdate body = new OrganizationResourceUpdate(); + body.withTags(null); + return service.update(this.client.subscriptionId(), resourceGroupName, organizationName, this.client.apiVersion(), this.client.acceptLanguage(), body, this.client.userAgent()) + .flatMap(new Func1, Observable>>() { + @Override + public Observable> call(Response response) { + try { + ServiceResponse clientResponse = updateDelegate(response); + return Observable.just(clientResponse); + } catch (Throwable t) { + return Observable.error(t); + } + } + }); + } + + /** + * Update Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @param tags ARM resource tags + * @throws IllegalArgumentException thrown if parameters fail the validation + * @throws ResourceProviderDefaultErrorResponseException thrown if the request is rejected by server + * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent + * @return the OrganizationResourceInner object if successful. + */ + public OrganizationResourceInner update(String resourceGroupName, String organizationName, Map tags) { + return updateWithServiceResponseAsync(resourceGroupName, organizationName, tags).toBlocking().single().body(); + } + + /** + * Update Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @param tags ARM resource tags + * @param serviceCallback the async ServiceCallback to handle successful and failed responses. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the {@link ServiceFuture} object + */ + public ServiceFuture updateAsync(String resourceGroupName, String organizationName, Map tags, final ServiceCallback serviceCallback) { + return ServiceFuture.fromResponse(updateWithServiceResponseAsync(resourceGroupName, organizationName, tags), serviceCallback); + } + + /** + * Update Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @param tags ARM resource tags + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the OrganizationResourceInner object + */ + public Observable updateAsync(String resourceGroupName, String organizationName, Map tags) { + return updateWithServiceResponseAsync(resourceGroupName, organizationName, tags).map(new Func1, OrganizationResourceInner>() { + @Override + public OrganizationResourceInner call(ServiceResponse response) { + return response.body(); + } + }); + } + + /** + * Update Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @param tags ARM resource tags + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the OrganizationResourceInner object + */ + public Observable> updateWithServiceResponseAsync(String resourceGroupName, String organizationName, Map tags) { + if (this.client.subscriptionId() == null) { + throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null."); + } + if (resourceGroupName == null) { + throw new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."); + } + if (organizationName == null) { + throw new IllegalArgumentException("Parameter organizationName is required and cannot be null."); + } + Validator.validate(tags); + OrganizationResourceUpdate body = null; + if (tags != null) { + body = new OrganizationResourceUpdate(); + body.withTags(tags); + } + return service.update(this.client.subscriptionId(), resourceGroupName, organizationName, this.client.apiVersion(), this.client.acceptLanguage(), body, this.client.userAgent()) + .flatMap(new Func1, Observable>>() { + @Override + public Observable> call(Response response) { + try { + ServiceResponse clientResponse = updateDelegate(response); + return Observable.just(clientResponse); + } catch (Throwable t) { + return Observable.error(t); + } + } + }); + } + + private ServiceResponse updateDelegate(Response response) throws ResourceProviderDefaultErrorResponseException, IOException, IllegalArgumentException { + return this.client.restClient().responseBuilderFactory().newInstance(this.client.serializerAdapter()) + .register(200, new TypeToken() { }.getType()) + .registerError(ResourceProviderDefaultErrorResponseException.class) + .build(response); + } + + /** + * Delete Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @throws IllegalArgumentException thrown if parameters fail the validation + * @throws ResourceProviderDefaultErrorResponseException thrown if the request is rejected by server + * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent + */ + public void delete(String resourceGroupName, String organizationName) { + deleteWithServiceResponseAsync(resourceGroupName, organizationName).toBlocking().last().body(); + } + + /** + * Delete Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @param serviceCallback the async ServiceCallback to handle successful and failed responses. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the {@link ServiceFuture} object + */ + public ServiceFuture deleteAsync(String resourceGroupName, String organizationName, final ServiceCallback serviceCallback) { + return ServiceFuture.fromResponse(deleteWithServiceResponseAsync(resourceGroupName, organizationName), serviceCallback); + } + + /** + * Delete Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable for the request + */ + public Observable deleteAsync(String resourceGroupName, String organizationName) { + return deleteWithServiceResponseAsync(resourceGroupName, organizationName).map(new Func1, Void>() { + @Override + public Void call(ServiceResponse response) { + return response.body(); + } + }); + } + + /** + * Delete Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable for the request + */ + public Observable> deleteWithServiceResponseAsync(String resourceGroupName, String organizationName) { + if (this.client.subscriptionId() == null) { + throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null."); + } + if (resourceGroupName == null) { + throw new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."); + } + if (organizationName == null) { + throw new IllegalArgumentException("Parameter organizationName is required and cannot be null."); + } + Observable> observable = service.delete(this.client.subscriptionId(), resourceGroupName, organizationName, this.client.apiVersion(), this.client.acceptLanguage(), this.client.userAgent()); + return client.getAzureClient().getPostOrDeleteResultAsync(observable, new TypeToken() { }.getType()); + } + + /** + * Delete Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @throws IllegalArgumentException thrown if parameters fail the validation + * @throws ResourceProviderDefaultErrorResponseException thrown if the request is rejected by server + * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent + */ + public void beginDelete(String resourceGroupName, String organizationName) { + beginDeleteWithServiceResponseAsync(resourceGroupName, organizationName).toBlocking().single().body(); + } + + /** + * Delete Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @param serviceCallback the async ServiceCallback to handle successful and failed responses. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the {@link ServiceFuture} object + */ + public ServiceFuture beginDeleteAsync(String resourceGroupName, String organizationName, final ServiceCallback serviceCallback) { + return ServiceFuture.fromResponse(beginDeleteWithServiceResponseAsync(resourceGroupName, organizationName), serviceCallback); + } + + /** + * Delete Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the {@link ServiceResponse} object if successful. + */ + public Observable beginDeleteAsync(String resourceGroupName, String organizationName) { + return beginDeleteWithServiceResponseAsync(resourceGroupName, organizationName).map(new Func1, Void>() { + @Override + public Void call(ServiceResponse response) { + return response.body(); + } + }); + } + + /** + * Delete Organization resource. + * + * @param resourceGroupName Resource group name + * @param organizationName Organization resource name + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the {@link ServiceResponse} object if successful. + */ + public Observable> beginDeleteWithServiceResponseAsync(String resourceGroupName, String organizationName) { + if (this.client.subscriptionId() == null) { + throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null."); + } + if (resourceGroupName == null) { + throw new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."); + } + if (organizationName == null) { + throw new IllegalArgumentException("Parameter organizationName is required and cannot be null."); + } + return service.beginDelete(this.client.subscriptionId(), resourceGroupName, organizationName, this.client.apiVersion(), this.client.acceptLanguage(), this.client.userAgent()) + .flatMap(new Func1, Observable>>() { + @Override + public Observable> call(Response response) { + try { + ServiceResponse clientResponse = beginDeleteDelegate(response); + return Observable.just(clientResponse); + } catch (Throwable t) { + return Observable.error(t); + } + } + }); + } + + private ServiceResponse beginDeleteDelegate(Response response) throws ResourceProviderDefaultErrorResponseException, IOException, IllegalArgumentException { + return this.client.restClient().responseBuilderFactory().newInstance(this.client.serializerAdapter()) + .register(200, new TypeToken() { }.getType()) + .register(202, new TypeToken() { }.getType()) + .register(204, new TypeToken() { }.getType()) + .registerError(ResourceProviderDefaultErrorResponseException.class) + .build(response); + } + + /** + * List all organizations under the specified subscription. + * + * @param nextPageLink The NextLink from the previous successful call to List operation. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @throws ResourceProviderDefaultErrorResponseException thrown if the request is rejected by server + * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent + * @return the PagedList<OrganizationResourceInner> object if successful. + */ + public PagedList listNext(final String nextPageLink) { + ServiceResponse> response = listNextSinglePageAsync(nextPageLink).toBlocking().single(); + return new PagedList(response.body()) { + @Override + public Page nextPage(String nextPageLink) { + return listNextSinglePageAsync(nextPageLink).toBlocking().single().body(); + } + }; + } + + /** + * List all organizations under the specified subscription. + * + * @param nextPageLink The NextLink from the previous successful call to List operation. + * @param serviceFuture the ServiceFuture object tracking the Retrofit calls + * @param serviceCallback the async ServiceCallback to handle successful and failed responses. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the {@link ServiceFuture} object + */ + public ServiceFuture> listNextAsync(final String nextPageLink, final ServiceFuture> serviceFuture, final ListOperationCallback serviceCallback) { + return AzureServiceFuture.fromPageResponse( + listNextSinglePageAsync(nextPageLink), + new Func1>>>() { + @Override + public Observable>> call(String nextPageLink) { + return listNextSinglePageAsync(nextPageLink); + } + }, + serviceCallback); + } + + /** + * List all organizations under the specified subscription. + * + * @param nextPageLink The NextLink from the previous successful call to List operation. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the PagedList<OrganizationResourceInner> object + */ + public Observable> listNextAsync(final String nextPageLink) { + return listNextWithServiceResponseAsync(nextPageLink) + .map(new Func1>, Page>() { + @Override + public Page call(ServiceResponse> response) { + return response.body(); + } + }); + } + + /** + * List all organizations under the specified subscription. + * + * @param nextPageLink The NextLink from the previous successful call to List operation. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the PagedList<OrganizationResourceInner> object + */ + public Observable>> listNextWithServiceResponseAsync(final String nextPageLink) { + return listNextSinglePageAsync(nextPageLink) + .concatMap(new Func1>, Observable>>>() { + @Override + public Observable>> call(ServiceResponse> page) { + String nextPageLink = page.body().nextPageLink(); + if (nextPageLink == null) { + return Observable.just(page); + } + return Observable.just(page).concatWith(listNextWithServiceResponseAsync(nextPageLink)); + } + }); + } + + /** + * List all organizations under the specified subscription. + * + ServiceResponse> * @param nextPageLink The NextLink from the previous successful call to List operation. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the PagedList<OrganizationResourceInner> object wrapped in {@link ServiceResponse} if successful. + */ + public Observable>> listNextSinglePageAsync(final String nextPageLink) { + if (nextPageLink == null) { + throw new IllegalArgumentException("Parameter nextPageLink is required and cannot be null."); + } + String nextUrl = String.format("%s", nextPageLink); + return service.listNext(nextUrl, this.client.acceptLanguage(), this.client.userAgent()) + .flatMap(new Func1, Observable>>>() { + @Override + public Observable>> call(Response response) { + try { + ServiceResponse> result = listNextDelegate(response); + return Observable.just(new ServiceResponse>(result.body(), result.response())); + } catch (Throwable t) { + return Observable.error(t); + } + } + }); + } + + private ServiceResponse> listNextDelegate(Response response) throws ResourceProviderDefaultErrorResponseException, IOException, IllegalArgumentException { + return this.client.restClient().responseBuilderFactory()., ResourceProviderDefaultErrorResponseException>newInstance(this.client.serializerAdapter()) + .register(200, new TypeToken>() { }.getType()) + .registerError(ResourceProviderDefaultErrorResponseException.class) + .build(response); + } + + /** + * List all Organizations under the specified resource group. + * + * @param nextPageLink The NextLink from the previous successful call to List operation. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @throws ResourceProviderDefaultErrorResponseException thrown if the request is rejected by server + * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent + * @return the PagedList<OrganizationResourceInner> object if successful. + */ + public PagedList listByResourceGroupNext(final String nextPageLink) { + ServiceResponse> response = listByResourceGroupNextSinglePageAsync(nextPageLink).toBlocking().single(); + return new PagedList(response.body()) { + @Override + public Page nextPage(String nextPageLink) { + return listByResourceGroupNextSinglePageAsync(nextPageLink).toBlocking().single().body(); + } + }; + } + + /** + * List all Organizations under the specified resource group. + * + * @param nextPageLink The NextLink from the previous successful call to List operation. + * @param serviceFuture the ServiceFuture object tracking the Retrofit calls + * @param serviceCallback the async ServiceCallback to handle successful and failed responses. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the {@link ServiceFuture} object + */ + public ServiceFuture> listByResourceGroupNextAsync(final String nextPageLink, final ServiceFuture> serviceFuture, final ListOperationCallback serviceCallback) { + return AzureServiceFuture.fromPageResponse( + listByResourceGroupNextSinglePageAsync(nextPageLink), + new Func1>>>() { + @Override + public Observable>> call(String nextPageLink) { + return listByResourceGroupNextSinglePageAsync(nextPageLink); + } + }, + serviceCallback); + } + + /** + * List all Organizations under the specified resource group. + * + * @param nextPageLink The NextLink from the previous successful call to List operation. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the PagedList<OrganizationResourceInner> object + */ + public Observable> listByResourceGroupNextAsync(final String nextPageLink) { + return listByResourceGroupNextWithServiceResponseAsync(nextPageLink) + .map(new Func1>, Page>() { + @Override + public Page call(ServiceResponse> response) { + return response.body(); + } + }); + } + + /** + * List all Organizations under the specified resource group. + * + * @param nextPageLink The NextLink from the previous successful call to List operation. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the PagedList<OrganizationResourceInner> object + */ + public Observable>> listByResourceGroupNextWithServiceResponseAsync(final String nextPageLink) { + return listByResourceGroupNextSinglePageAsync(nextPageLink) + .concatMap(new Func1>, Observable>>>() { + @Override + public Observable>> call(ServiceResponse> page) { + String nextPageLink = page.body().nextPageLink(); + if (nextPageLink == null) { + return Observable.just(page); + } + return Observable.just(page).concatWith(listByResourceGroupNextWithServiceResponseAsync(nextPageLink)); + } + }); + } + + /** + * List all Organizations under the specified resource group. + * + ServiceResponse> * @param nextPageLink The NextLink from the previous successful call to List operation. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the PagedList<OrganizationResourceInner> object wrapped in {@link ServiceResponse} if successful. + */ + public Observable>> listByResourceGroupNextSinglePageAsync(final String nextPageLink) { + if (nextPageLink == null) { + throw new IllegalArgumentException("Parameter nextPageLink is required and cannot be null."); + } + String nextUrl = String.format("%s", nextPageLink); + return service.listByResourceGroupNext(nextUrl, this.client.acceptLanguage(), this.client.userAgent()) + .flatMap(new Func1, Observable>>>() { + @Override + public Observable>> call(Response response) { + try { + ServiceResponse> result = listByResourceGroupNextDelegate(response); + return Observable.just(new ServiceResponse>(result.body(), result.response())); + } catch (Throwable t) { + return Observable.error(t); + } + } + }); + } + + private ServiceResponse> listByResourceGroupNextDelegate(Response response) throws ResourceProviderDefaultErrorResponseException, IOException, IllegalArgumentException { + return this.client.restClient().responseBuilderFactory()., ResourceProviderDefaultErrorResponseException>newInstance(this.client.serializerAdapter()) + .register(200, new TypeToken>() { }.getType()) + .registerError(ResourceProviderDefaultErrorResponseException.class) + .build(response); + } + +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/PageImpl.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/PageImpl.java new file mode 100644 index 0000000000000..55c4f025762f6 --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/PageImpl.java @@ -0,0 +1,75 @@ +/** + * Copyright (c) Microsoft Corporation. All rights reserved. + * Licensed under the MIT License. See License.txt in the project root for + * license information. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + */ + +package com.microsoft.azure.management.confluent.v2020_03_01_preview.implementation; + +import com.fasterxml.jackson.annotation.JsonProperty; +import com.microsoft.azure.Page; +import java.util.List; + +/** + * An instance of this class defines a page of Azure resources and a link to + * get the next page of resources, if any. + * + * @param type of Azure resource + */ +public class PageImpl implements Page { + /** + * The link to the next page. + */ + @JsonProperty("nextLink") + private String nextPageLink; + + /** + * The list of items. + */ + @JsonProperty("value") + private List items; + + /** + * Gets the link to the next page. + * + * @return the link to the next page. + */ + @Override + public String nextPageLink() { + return this.nextPageLink; + } + + /** + * Gets the list of items. + * + * @return the list of items in {@link List}. + */ + @Override + public List items() { + return items; + } + + /** + * Sets the link to the next page. + * + * @param nextPageLink the link to the next page. + * @return this Page object itself. + */ + public PageImpl setNextPageLink(String nextPageLink) { + this.nextPageLink = nextPageLink; + return this; + } + + /** + * Sets the list of items. + * + * @param items the list of items in {@link List}. + * @return this Page object itself. + */ + public PageImpl setItems(List items) { + this.items = items; + return this; + } +} diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/package-info.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/package-info.java new file mode 100644 index 0000000000000..2c8d14a6e392c --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/implementation/package-info.java @@ -0,0 +1,10 @@ +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. See License.txt in the project root for +// license information. +// +// Code generated by Microsoft (R) AutoRest Code Generator. + +/** + * This package contains the implementation classes for ConfluentManagementClient. + */ +package com.microsoft.azure.management.confluent.v2020_03_01_preview.implementation; diff --git a/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/package-info.java b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/package-info.java new file mode 100644 index 0000000000000..5692ee0bfe136 --- /dev/null +++ b/sdk/confluent/mgmt-v2020_03_01_preview/src/main/java/com/microsoft/azure/management/confluent/v2020_03_01_preview/package-info.java @@ -0,0 +1,10 @@ +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. See License.txt in the project root for +// license information. +// +// Code generated by Microsoft (R) AutoRest Code Generator. + +/** + * This package contains the classes for ConfluentManagementClient. + */ +package com.microsoft.azure.management.confluent.v2020_03_01_preview;