diff --git a/azure-mgmt-containerservice/src/main/java/com/microsoft/azure/management/containerservice/implementation/ManagedClusterInner.java b/azure-mgmt-containerservice/src/main/java/com/microsoft/azure/management/containerservice/implementation/ManagedClusterInner.java index 7899931b924..c9babc475ba 100644 --- a/azure-mgmt-containerservice/src/main/java/com/microsoft/azure/management/containerservice/implementation/ManagedClusterInner.java +++ b/azure-mgmt-containerservice/src/main/java/com/microsoft/azure/management/containerservice/implementation/ManagedClusterInner.java @@ -76,6 +76,12 @@ public class ManagedClusterInner extends Resource { @JsonProperty(value = "properties.addonProfiles") private Map addonProfiles; + /** + * Name of the resource group containing agent pool nodes. + */ + @JsonProperty(value = "properties.nodeResourceGroup", access = JsonProperty.Access.WRITE_ONLY) + private String nodeResourceGroup; + /** * Whether to enable Kubernetes Role-Based Access Control. */ @@ -232,6 +238,15 @@ public ManagedClusterInner withAddonProfiles(Map list() { + public List list() { return listWithServiceResponseAsync().toBlocking().single().body(); } @@ -76,7 +76,7 @@ public List list() { * @throws IllegalArgumentException thrown if parameters fail the validation * @return the {@link ServiceFuture} object */ - public ServiceFuture> listAsync(final ServiceCallback> serviceCallback) { + public ServiceFuture> listAsync(final ServiceCallback> serviceCallback) { return ServiceFuture.fromResponse(listWithServiceResponseAsync(), serviceCallback); } @@ -84,12 +84,12 @@ public ServiceFuture> listAsync(final ServiceCa * Gets a list of compute operations. * * @throws IllegalArgumentException thrown if parameters fail the validation - * @return the observable to the List<ComputeOperationValueInner> object + * @return the observable to the List<OperationValueInner> object */ - public Observable> listAsync() { - return listWithServiceResponseAsync().map(new Func1>, List>() { + public Observable> listAsync() { + return listWithServiceResponseAsync().map(new Func1>, List>() { @Override - public List call(ServiceResponse> response) { + public List call(ServiceResponse> response) { return response.body(); } }); @@ -99,21 +99,21 @@ public List call(ServiceResponse>> listWithServiceResponseAsync() { + public Observable>> listWithServiceResponseAsync() { final String apiVersion = "2018-03-31"; return service.list(apiVersion, this.client.acceptLanguage(), this.client.userAgent()) - .flatMap(new Func1, Observable>>>() { + .flatMap(new Func1, Observable>>>() { @Override - public Observable>> call(Response response) { + public Observable>> call(Response response) { try { - ServiceResponse> result = listDelegate(response); - List items = null; + ServiceResponse> result = listDelegate(response); + List items = null; if (result.body() != null) { items = result.body().items(); } - ServiceResponse> clientResponse = new ServiceResponse>(items, result.response()); + ServiceResponse> clientResponse = new ServiceResponse>(items, result.response()); return Observable.just(clientResponse); } catch (Throwable t) { return Observable.error(t); @@ -122,9 +122,9 @@ public Observable>> call(Respon }); } - private ServiceResponse> listDelegate(Response response) throws CloudException, IOException { - return this.client.restClient().responseBuilderFactory()., CloudException>newInstance(this.client.serializerAdapter()) - .register(200, new TypeToken>() { }.getType()) + private ServiceResponse> listDelegate(Response response) throws CloudException, IOException { + return this.client.restClient().responseBuilderFactory()., CloudException>newInstance(this.client.serializerAdapter()) + .register(200, new TypeToken>() { }.getType()) .registerError(CloudException.class) .build(response); }