[ReleasePR sdk/storage/mgmt-v2019_06_01] [Storage] Add support for listing private endpoint connections

sdk/storage/mgmt-v2019_06_01/pom.xml

@@ -11,11 +11,11 @@
     <parent>
         <groupId>com.microsoft.azure</groupId>
         <artifactId>azure-arm-parent</artifactId>
-        <version>1.3.0</version>
+        <version>1.1.0</version>
         <relativePath>../../../pom.management.xml</relativePath>
     </parent>
     <artifactId>azure-mgmt-storage</artifactId>
-    <version>1.0.0-beta-7</version>
+    <version>1.0.0-beta</version>
     <packaging>jar</packaging>
     <name>Microsoft Azure SDK for Storage Management</name>
     <description>This package contains Microsoft Storage Management SDK.</description>

sdk/storage/mgmt-v2019_06_01/src/main/java/com/microsoft/azure/management/storage/v2019_06_01/BlobServiceProperties.java

@@ -16,7 +16,6 @@
 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.storage.v2019_06_01.implementation.SkuInner;
 import com.microsoft.azure.management.storage.v2019_06_01.implementation.StorageManager;
 
 /**

sdk/storage/mgmt-v2019_06_01/src/main/java/com/microsoft/azure/management/storage/v2019_06_01/FileServiceProperties.java

@@ -16,7 +16,6 @@
 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.storage.v2019_06_01.implementation.SkuInner;
 import com.microsoft.azure.management.storage.v2019_06_01.implementation.StorageManager;
 import java.util.List;
 

sdk/storage/mgmt-v2019_06_01/src/main/java/com/microsoft/azure/management/storage/v2019_06_01/ManagementPolicyRule.java

@@ -42,6 +42,8 @@ public class ManagementPolicyRule {
 
     /**
      * Creates an instance of ManagementPolicyRule class.
+     * @param name a rule name can contain any combination of alpha numeric characters. Rule name is case-sensitive. It must be unique within a policy.
+     * @param definition an object that defines the Lifecycle rule.
      */
     public ManagementPolicyRule() {
         type = "Lifecycle";

sdk/storage/mgmt-v2019_06_01/src/main/java/com/microsoft/azure/management/storage/v2019_06_01/PrivateEndpointConnections.java

@@ -29,6 +29,16 @@ public interface PrivateEndpointConnections extends SupportsCreating<PrivateEndp
      */
     Observable<PrivateEndpointConnection> getAsync(String resourceGroupName, String accountName, String privateEndpointConnectionName);
 
+    /**
+     * List all the private endpoint connections associated with the storage account.
+     *
+     * @param resourceGroupName The name of the resource group within the user's subscription. The name is case insensitive.
+     * @param accountName The name of the storage account within the specified resource group. Storage account names must be between 3 and 24 characters in length and use numbers and lower-case letters only.
+     * @throws IllegalArgumentException thrown if parameters fail the validation
+     * @return the observable for the request
+     */
+    Observable<PrivateEndpointConnection> listAsync(String resourceGroupName, String accountName);
+
     /**
      * Deletes the specified private endpoint connection associated with the storage account.
      *

sdk/storage/mgmt-v2019_06_01/src/main/java/com/microsoft/azure/management/storage/v2019_06_01/StorageAccountCheckNameAvailabilityParameters.java

@@ -28,6 +28,7 @@ public class StorageAccountCheckNameAvailabilityParameters {
 
     /**
      * Creates an instance of StorageAccountCheckNameAvailabilityParameters class.
+     * @param name the storage account name.
      */
     public StorageAccountCheckNameAvailabilityParameters() {
         type = "Microsoft.Storage/storageAccounts";

sdk/storage/mgmt-v2019_06_01/src/main/java/com/microsoft/azure/management/storage/v2019_06_01/implementation/PrivateEndpointConnectionsImpl.java

@@ -14,6 +14,7 @@
 import rx.Completable;
 import rx.Observable;
 import rx.functions.Func1;
+import java.util.List;
 import com.microsoft.azure.management.storage.v2019_06_01.PrivateEndpointConnection;
 
 class PrivateEndpointConnectionsImpl extends WrapperImpl<PrivateEndpointConnectionsInner> implements PrivateEndpointConnections {
@@ -41,6 +42,24 @@ private PrivateEndpointConnectionImpl wrapModel(String name) {
         return new PrivateEndpointConnectionImpl(name, this.manager());
     }
 
+    @Override
+    public Observable<PrivateEndpointConnection> listAsync(String resourceGroupName, String accountName) {
+        PrivateEndpointConnectionsInner client = this.inner();
+        return client.listAsync(resourceGroupName, accountName)
+        .flatMap(new Func1<List<PrivateEndpointConnectionInner>, Observable<PrivateEndpointConnectionInner>>() {
+            @Override
+            public Observable<PrivateEndpointConnectionInner> call(List<PrivateEndpointConnectionInner> innerList) {
+                return Observable.from(innerList);
+            }
+        })
+        .map(new Func1<PrivateEndpointConnectionInner, PrivateEndpointConnection>() {
+            @Override
+            public PrivateEndpointConnection call(PrivateEndpointConnectionInner inner) {
+                return wrapModel(inner);
+            }
+        });
+    }
+
     @Override
     public Observable<PrivateEndpointConnection> getAsync(String resourceGroupName, String accountName, String privateEndpointConnectionName) {
         PrivateEndpointConnectionsInner client = this.inner();

sdk/storage/mgmt-v2019_06_01/src/main/java/com/microsoft/azure/management/storage/v2019_06_01/implementation/PrivateEndpointConnectionsInner.java

@@ -10,12 +10,14 @@
 
 import retrofit2.Retrofit;
 import com.google.common.reflect.TypeToken;
+import com.microsoft.azure.CloudException;
 import com.microsoft.azure.management.storage.v2019_06_01.ErrorResponseException;
 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 okhttp3.ResponseBody;
 import retrofit2.http.Body;
 import retrofit2.http.GET;
@@ -55,6 +57,10 @@ public PrivateEndpointConnectionsInner(Retrofit retrofit, StorageManagementClien
      * used by Retrofit to perform actually REST calls.
      */
     interface PrivateEndpointConnectionsService {
+        @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.storage.v2019_06_01.PrivateEndpointConnections list" })
+        @GET("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Storage/storageAccounts/{accountName}/privateEndpointConnections")
+        Observable<Response<ResponseBody>> list(@Path("resourceGroupName") String resourceGroupName, @Path("accountName") String accountName, @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.storage.v2019_06_01.PrivateEndpointConnections get" })
         @GET("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Storage/storageAccounts/{accountName}/privateEndpointConnections/{privateEndpointConnectionName}")
         Observable<Response<ResponseBody>> get(@Path("resourceGroupName") String resourceGroupName, @Path("accountName") String accountName, @Path("subscriptionId") String subscriptionId, @Path("privateEndpointConnectionName") String privateEndpointConnectionName, @Query("api-version") String apiVersion, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent);
@@ -69,6 +75,97 @@ interface PrivateEndpointConnectionsService {
 
     }
 
+    /**
+     * List all the private endpoint connections associated with the storage account.
+     *
+     * @param resourceGroupName The name of the resource group within the user's subscription. The name is case insensitive.
+     * @param accountName The name of the storage account within the specified resource group. Storage account names must be between 3 and 24 characters in length and use numbers and lower-case letters only.
+     * @throws IllegalArgumentException thrown if parameters fail the validation
+     * @throws CloudException thrown if the request is rejected by server
+     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent
+     * @return the List&lt;PrivateEndpointConnectionInner&gt; object if successful.
+     */
+    public List<PrivateEndpointConnectionInner> list(String resourceGroupName, String accountName) {
+        return listWithServiceResponseAsync(resourceGroupName, accountName).toBlocking().single().body();
+    }
+
+    /**
+     * List all the private endpoint connections associated with the storage account.
+     *
+     * @param resourceGroupName The name of the resource group within the user's subscription. The name is case insensitive.
+     * @param accountName The name of the storage account within the specified resource group. Storage account names must be between 3 and 24 characters in length and use numbers and lower-case letters only.
+     * @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<List<PrivateEndpointConnectionInner>> listAsync(String resourceGroupName, String accountName, final ServiceCallback<List<PrivateEndpointConnectionInner>> serviceCallback) {
+        return ServiceFuture.fromResponse(listWithServiceResponseAsync(resourceGroupName, accountName), serviceCallback);
+    }
+
+    /**
+     * List all the private endpoint connections associated with the storage account.
+     *
+     * @param resourceGroupName The name of the resource group within the user's subscription. The name is case insensitive.
+     * @param accountName The name of the storage account within the specified resource group. Storage account names must be between 3 and 24 characters in length and use numbers and lower-case letters only.
+     * @throws IllegalArgumentException thrown if parameters fail the validation
+     * @return the observable to the List&lt;PrivateEndpointConnectionInner&gt; object
+     */
+    public Observable<List<PrivateEndpointConnectionInner>> listAsync(String resourceGroupName, String accountName) {
+        return listWithServiceResponseAsync(resourceGroupName, accountName).map(new Func1<ServiceResponse<List<PrivateEndpointConnectionInner>>, List<PrivateEndpointConnectionInner>>() {
+            @Override
+            public List<PrivateEndpointConnectionInner> call(ServiceResponse<List<PrivateEndpointConnectionInner>> response) {
+                return response.body();
+            }
+        });
+    }
+
+    /**
+     * List all the private endpoint connections associated with the storage account.
+     *
+     * @param resourceGroupName The name of the resource group within the user's subscription. The name is case insensitive.
+     * @param accountName The name of the storage account within the specified resource group. Storage account names must be between 3 and 24 characters in length and use numbers and lower-case letters only.
+     * @throws IllegalArgumentException thrown if parameters fail the validation
+     * @return the observable to the List&lt;PrivateEndpointConnectionInner&gt; object
+     */
+    public Observable<ServiceResponse<List<PrivateEndpointConnectionInner>>> listWithServiceResponseAsync(String resourceGroupName, String accountName) {
+        if (resourceGroupName == null) {
+            throw new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null.");
+        }
+        if (accountName == null) {
+            throw new IllegalArgumentException("Parameter accountName is required and cannot be null.");
+        }
+        if (this.client.subscriptionId() == null) {
+            throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null.");
+        }
+        if (this.client.apiVersion() == null) {
+            throw new IllegalArgumentException("Parameter this.client.apiVersion() is required and cannot be null.");
+        }
+        return service.list(resourceGroupName, accountName, this.client.subscriptionId(), this.client.apiVersion(), this.client.acceptLanguage(), this.client.userAgent())
+            .flatMap(new Func1<Response<ResponseBody>, Observable<ServiceResponse<List<PrivateEndpointConnectionInner>>>>() {
+                @Override
+                public Observable<ServiceResponse<List<PrivateEndpointConnectionInner>>> call(Response<ResponseBody> response) {
+                    try {
+                        ServiceResponse<PageImpl<PrivateEndpointConnectionInner>> result = listDelegate(response);
+                        List<PrivateEndpointConnectionInner> items = null;
+                        if (result.body() != null) {
+                            items = result.body().items();
+                        }
+                        ServiceResponse<List<PrivateEndpointConnectionInner>> clientResponse = new ServiceResponse<List<PrivateEndpointConnectionInner>>(items, result.response());
+                        return Observable.just(clientResponse);
+                    } catch (Throwable t) {
+                        return Observable.error(t);
+                    }
+                }
+            });
+    }
+
+    private ServiceResponse<PageImpl<PrivateEndpointConnectionInner>> listDelegate(Response<ResponseBody> response) throws CloudException, IOException, IllegalArgumentException {
+        return this.client.restClient().responseBuilderFactory().<PageImpl<PrivateEndpointConnectionInner>, CloudException>newInstance(this.client.serializerAdapter())
+                .register(200, new TypeToken<PageImpl<PrivateEndpointConnectionInner>>() { }.getType())
+                .registerError(CloudException.class)
+                .build(response);
+    }
+
     /**
      * Gets the specified private endpoint connection associated with the storage account.
      *