changes;
+
+ /*
+ * Skip token that encodes the skip information while executing the current request
+ */
+ @JsonProperty(value = "$skipToken")
+ private Object skipToken;
+
+ /** Creates an instance of ResourceChangeListInner class. */
+ public ResourceChangeListInner() {
+ }
+
+ /**
+ * Get the changes property: The pageable value returned by the operation, i.e. a list of changes to the resource.
+ *
+ * - The list is ordered from the most recent changes to the least recent changes. - This list will be empty if
+ * there were no changes during the requested interval. - The `Before` snapshot timestamp value of the oldest change
+ * can be outside of the specified time interval.
+ *
+ * @return the changes value.
+ */
+ public List changes() {
+ return this.changes;
+ }
+
+ /**
+ * Set the changes property: The pageable value returned by the operation, i.e. a list of changes to the resource.
+ *
+ * - The list is ordered from the most recent changes to the least recent changes. - This list will be empty if
+ * there were no changes during the requested interval. - The `Before` snapshot timestamp value of the oldest change
+ * can be outside of the specified time interval.
+ *
+ * @param changes the changes value to set.
+ * @return the ResourceChangeListInner object itself.
+ */
+ public ResourceChangeListInner withChanges(List changes) {
+ this.changes = changes;
+ return this;
+ }
+
+ /**
+ * Get the skipToken property: Skip token that encodes the skip information while executing the current request.
+ *
+ * @return the skipToken value.
+ */
+ public Object skipToken() {
+ return this.skipToken;
+ }
+
+ /**
+ * Set the skipToken property: Skip token that encodes the skip information while executing the current request.
+ *
+ * @param skipToken the skipToken value to set.
+ * @return the ResourceChangeListInner object itself.
+ */
+ public ResourceChangeListInner withSkipToken(Object skipToken) {
+ this.skipToken = skipToken;
+ return this;
+ }
+
+ /**
+ * Validates the instance.
+ *
+ * @throws IllegalArgumentException thrown if the instance is not valid.
+ */
+ public void validate() {
+ if (changes() != null) {
+ changes().forEach(e -> e.validate());
+ }
+ }
+}
diff --git a/sdk/resourcegraph/azure-resourcemanager-resourcegraph/src/main/java/com/azure/resourcemanager/resourcegraph/implementation/OperationsClientImpl.java b/sdk/resourcegraph/azure-resourcemanager-resourcegraph/src/main/java/com/azure/resourcemanager/resourcegraph/implementation/OperationsClientImpl.java
index 92e4e6c050be..1d0169fd672f 100644
--- a/sdk/resourcegraph/azure-resourcemanager-resourcegraph/src/main/java/com/azure/resourcemanager/resourcegraph/implementation/OperationsClientImpl.java
+++ b/sdk/resourcegraph/azure-resourcemanager-resourcegraph/src/main/java/com/azure/resourcemanager/resourcegraph/implementation/OperationsClientImpl.java
@@ -82,10 +82,10 @@ private Mono> listSinglePageAsync() {
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
+ final String apiVersion = "2022-10-01";
final String accept = "application/json";
return FluxUtil
- .withContext(
- context -> service.list(this.client.getEndpoint(), this.client.getApiVersion(), accept, context))
+ .withContext(context -> service.list(this.client.getEndpoint(), apiVersion, accept, context))
.>map(
res ->
new PagedResponseBase<>(
@@ -111,10 +111,11 @@ private Mono> listSinglePageAsync(Context context)
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
+ final String apiVersion = "2022-10-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
- .list(this.client.getEndpoint(), this.client.getApiVersion(), accept, context)
+ .list(this.client.getEndpoint(), apiVersion, accept, context)
.map(
res ->
new PagedResponseBase<>(
diff --git a/sdk/resourcegraph/azure-resourcemanager-resourcegraph/src/main/java/com/azure/resourcemanager/resourcegraph/implementation/ResourceChangeDataImpl.java b/sdk/resourcegraph/azure-resourcemanager-resourcegraph/src/main/java/com/azure/resourcemanager/resourcegraph/implementation/ResourceChangeDataImpl.java
new file mode 100644
index 000000000000..56cd4365f0f3
--- /dev/null
+++ b/sdk/resourcegraph/azure-resourcemanager-resourcegraph/src/main/java/com/azure/resourcemanager/resourcegraph/implementation/ResourceChangeDataImpl.java
@@ -0,0 +1,64 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) AutoRest Code Generator.
+
+package com.azure.resourcemanager.resourcegraph.implementation;
+
+import com.azure.resourcemanager.resourcegraph.fluent.models.ResourceChangeDataInner;
+import com.azure.resourcemanager.resourcegraph.models.ChangeType;
+import com.azure.resourcemanager.resourcegraph.models.ResourceChangeData;
+import com.azure.resourcemanager.resourcegraph.models.ResourceChangeDataAfterSnapshot;
+import com.azure.resourcemanager.resourcegraph.models.ResourceChangeDataBeforeSnapshot;
+import com.azure.resourcemanager.resourcegraph.models.ResourcePropertyChange;
+import java.util.Collections;
+import java.util.List;
+
+public final class ResourceChangeDataImpl implements ResourceChangeData {
+ private ResourceChangeDataInner innerObject;
+
+ private final com.azure.resourcemanager.resourcegraph.ResourceGraphManager serviceManager;
+
+ ResourceChangeDataImpl(
+ ResourceChangeDataInner innerObject,
+ com.azure.resourcemanager.resourcegraph.ResourceGraphManager serviceManager) {
+ this.innerObject = innerObject;
+ this.serviceManager = serviceManager;
+ }
+
+ public String resourceId() {
+ return this.innerModel().resourceId();
+ }
+
+ public String changeId() {
+ return this.innerModel().changeId();
+ }
+
+ public ResourceChangeDataBeforeSnapshot beforeSnapshot() {
+ return this.innerModel().beforeSnapshot();
+ }
+
+ public ResourceChangeDataAfterSnapshot afterSnapshot() {
+ return this.innerModel().afterSnapshot();
+ }
+
+ public ChangeType changeType() {
+ return this.innerModel().changeType();
+ }
+
+ public List propertyChanges() {
+ List inner = this.innerModel().propertyChanges();
+ if (inner != null) {
+ return Collections.unmodifiableList(inner);
+ } else {
+ return Collections.emptyList();
+ }
+ }
+
+ public ResourceChangeDataInner innerModel() {
+ return this.innerObject;
+ }
+
+ private com.azure.resourcemanager.resourcegraph.ResourceGraphManager manager() {
+ return this.serviceManager;
+ }
+}
diff --git a/sdk/resourcegraph/azure-resourcemanager-resourcegraph/src/main/java/com/azure/resourcemanager/resourcegraph/implementation/ResourceChangeListImpl.java b/sdk/resourcegraph/azure-resourcemanager-resourcegraph/src/main/java/com/azure/resourcemanager/resourcegraph/implementation/ResourceChangeListImpl.java
new file mode 100644
index 000000000000..e0e7c8dca71a
--- /dev/null
+++ b/sdk/resourcegraph/azure-resourcemanager-resourcegraph/src/main/java/com/azure/resourcemanager/resourcegraph/implementation/ResourceChangeListImpl.java
@@ -0,0 +1,52 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) AutoRest Code Generator.
+
+package com.azure.resourcemanager.resourcegraph.implementation;
+
+import com.azure.resourcemanager.resourcegraph.fluent.models.ResourceChangeDataInner;
+import com.azure.resourcemanager.resourcegraph.fluent.models.ResourceChangeListInner;
+import com.azure.resourcemanager.resourcegraph.models.ResourceChangeData;
+import com.azure.resourcemanager.resourcegraph.models.ResourceChangeList;
+import java.util.Collections;
+import java.util.List;
+import java.util.stream.Collectors;
+
+public final class ResourceChangeListImpl implements ResourceChangeList {
+ private ResourceChangeListInner innerObject;
+
+ private final com.azure.resourcemanager.resourcegraph.ResourceGraphManager serviceManager;
+
+ ResourceChangeListImpl(
+ ResourceChangeListInner innerObject,
+ com.azure.resourcemanager.resourcegraph.ResourceGraphManager serviceManager) {
+ this.innerObject = innerObject;
+ this.serviceManager = serviceManager;
+ }
+
+ public List changes() {
+ List inner = this.innerModel().changes();
+ if (inner != null) {
+ return Collections
+ .unmodifiableList(
+ inner
+ .stream()
+ .map(inner1 -> new ResourceChangeDataImpl(inner1, this.manager()))
+ .collect(Collectors.toList()));
+ } else {
+ return Collections.emptyList();
+ }
+ }
+
+ public Object skipToken() {
+ return this.innerModel().skipToken();
+ }
+
+ public ResourceChangeListInner innerModel() {
+ return this.innerObject;
+ }
+
+ private com.azure.resourcemanager.resourcegraph.ResourceGraphManager manager() {
+ return this.serviceManager;
+ }
+}
diff --git a/sdk/resourcegraph/azure-resourcemanager-resourcegraph/src/main/java/com/azure/resourcemanager/resourcegraph/implementation/ResourceGraphClientBuilder.java b/sdk/resourcegraph/azure-resourcemanager-resourcegraph/src/main/java/com/azure/resourcemanager/resourcegraph/implementation/ResourceGraphClientBuilder.java
index 8712af38576c..5620f7fc0065 100644
--- a/sdk/resourcegraph/azure-resourcemanager-resourcegraph/src/main/java/com/azure/resourcemanager/resourcegraph/implementation/ResourceGraphClientBuilder.java
+++ b/sdk/resourcegraph/azure-resourcemanager-resourcegraph/src/main/java/com/azure/resourcemanager/resourcegraph/implementation/ResourceGraphClientBuilder.java
@@ -103,26 +103,21 @@ public ResourceGraphClientBuilder serializerAdapter(SerializerAdapter serializer
* @return an instance of ResourceGraphClientImpl.
*/
public ResourceGraphClientImpl buildClient() {
- if (pipeline == null) {
- this.pipeline = new HttpPipelineBuilder().policies(new UserAgentPolicy(), new RetryPolicy()).build();
- }
- if (endpoint == null) {
- this.endpoint = "https://management.azure.com";
- }
- if (environment == null) {
- this.environment = AzureEnvironment.AZURE;
- }
- if (pipeline == null) {
- this.pipeline = new HttpPipelineBuilder().policies(new UserAgentPolicy(), new RetryPolicy()).build();
- }
- if (defaultPollInterval == null) {
- this.defaultPollInterval = Duration.ofSeconds(30);
- }
- if (serializerAdapter == null) {
- this.serializerAdapter = SerializerFactory.createDefaultManagementSerializerAdapter();
- }
+ String localEndpoint = (endpoint != null) ? endpoint : "https://management.azure.com";
+ AzureEnvironment localEnvironment = (environment != null) ? environment : AzureEnvironment.AZURE;
+ HttpPipeline localPipeline =
+ (pipeline != null)
+ ? pipeline
+ : new HttpPipelineBuilder().policies(new UserAgentPolicy(), new RetryPolicy()).build();
+ Duration localDefaultPollInterval =
+ (defaultPollInterval != null) ? defaultPollInterval : Duration.ofSeconds(30);
+ SerializerAdapter localSerializerAdapter =
+ (serializerAdapter != null)
+ ? serializerAdapter
+ : SerializerFactory.createDefaultManagementSerializerAdapter();
ResourceGraphClientImpl client =
- new ResourceGraphClientImpl(pipeline, serializerAdapter, defaultPollInterval, environment, endpoint);
+ new ResourceGraphClientImpl(
+ localPipeline, localSerializerAdapter, localDefaultPollInterval, localEnvironment, localEndpoint);
return client;
}
}
diff --git a/sdk/resourcegraph/azure-resourcemanager-resourcegraph/src/main/java/com/azure/resourcemanager/resourcegraph/implementation/ResourceGraphClientImpl.java b/sdk/resourcegraph/azure-resourcemanager-resourcegraph/src/main/java/com/azure/resourcemanager/resourcegraph/implementation/ResourceGraphClientImpl.java
index 334dc3c6d7a4..37f9ee5f7964 100644
--- a/sdk/resourcegraph/azure-resourcemanager-resourcegraph/src/main/java/com/azure/resourcemanager/resourcegraph/implementation/ResourceGraphClientImpl.java
+++ b/sdk/resourcegraph/azure-resourcemanager-resourcegraph/src/main/java/com/azure/resourcemanager/resourcegraph/implementation/ResourceGraphClientImpl.java
@@ -15,6 +15,7 @@
import com.azure.core.management.polling.PollResult;
import com.azure.core.management.polling.PollerFactory;
import com.azure.core.util.Context;
+import com.azure.core.util.CoreUtils;
import com.azure.core.util.logging.ClientLogger;
import com.azure.core.util.polling.AsyncPollResponse;
import com.azure.core.util.polling.LongRunningOperationStatus;
@@ -30,7 +31,6 @@
import java.nio.charset.Charset;
import java.nio.charset.StandardCharsets;
import java.time.Duration;
-import java.util.Map;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
@@ -49,18 +49,6 @@ public String getEndpoint() {
return this.endpoint;
}
- /** Api Version. */
- private final String apiVersion;
-
- /**
- * Gets Api Version.
- *
- * @return the apiVersion value.
- */
- public String getApiVersion() {
- return this.apiVersion;
- }
-
/** The HTTP pipeline to send requests through. */
private final HttpPipeline httpPipeline;
@@ -140,7 +128,6 @@ public OperationsClient getOperations() {
this.serializerAdapter = serializerAdapter;
this.defaultPollInterval = defaultPollInterval;
this.endpoint = endpoint;
- this.apiVersion = "2021-03-01";
this.resourceProviders = new ResourceProvidersClientImpl(this);
this.operations = new OperationsClientImpl(this);
}
@@ -161,10 +148,7 @@ public Context getContext() {
* @return the merged context.
*/
public Context mergeContext(Context context) {
- for (Map.Entry entry : this.getContext().getValues().entrySet()) {
- context = context.addData(entry.getKey(), entry.getValue());
- }
- return context;
+ return CoreUtils.mergeContexts(this.getContext(), context);
}
/**
diff --git a/sdk/resourcegraph/azure-resourcemanager-resourcegraph/src/main/java/com/azure/resourcemanager/resourcegraph/implementation/ResourceProvidersClientImpl.java b/sdk/resourcegraph/azure-resourcemanager-resourcegraph/src/main/java/com/azure/resourcemanager/resourcegraph/implementation/ResourceProvidersClientImpl.java
index 173159447bea..96f286522445 100644
--- a/sdk/resourcegraph/azure-resourcemanager-resourcegraph/src/main/java/com/azure/resourcemanager/resourcegraph/implementation/ResourceProvidersClientImpl.java
+++ b/sdk/resourcegraph/azure-resourcemanager-resourcegraph/src/main/java/com/azure/resourcemanager/resourcegraph/implementation/ResourceProvidersClientImpl.java
@@ -23,7 +23,13 @@
import com.azure.core.util.FluxUtil;
import com.azure.resourcemanager.resourcegraph.fluent.ResourceProvidersClient;
import com.azure.resourcemanager.resourcegraph.fluent.models.QueryResponseInner;
+import com.azure.resourcemanager.resourcegraph.fluent.models.ResourceChangeDataInner;
+import com.azure.resourcemanager.resourcegraph.fluent.models.ResourceChangeListInner;
import com.azure.resourcemanager.resourcegraph.models.QueryRequest;
+import com.azure.resourcemanager.resourcegraph.models.ResourceChangeDetailsRequestParameters;
+import com.azure.resourcemanager.resourcegraph.models.ResourceChangesRequestParameters;
+import com.azure.resourcemanager.resourcegraph.models.ResourcesHistoryRequest;
+import java.util.List;
import reactor.core.publisher.Mono;
/** An instance of this class provides access to all the operations defined in ResourceProvidersClient. */
@@ -62,6 +68,39 @@ Mono> resources(
@BodyParam("application/json") QueryRequest query,
@HeaderParam("Accept") String accept,
Context context);
+
+ @Headers({"Content-Type: application/json"})
+ @Post("/providers/Microsoft.ResourceGraph/resourcesHistory")
+ @ExpectedResponses({200})
+ @UnexpectedResponseExceptionType(ManagementException.class)
+ Mono> resourcesHistory(
+ @HostParam("$host") String endpoint,
+ @QueryParam("api-version") String apiVersion,
+ @BodyParam("application/json") ResourcesHistoryRequest request,
+ @HeaderParam("Accept") String accept,
+ Context context);
+
+ @Headers({"Content-Type: application/json"})
+ @Post("/providers/Microsoft.ResourceGraph/resourceChanges")
+ @ExpectedResponses({200})
+ @UnexpectedResponseExceptionType(ManagementException.class)
+ Mono> resourceChanges(
+ @HostParam("$host") String endpoint,
+ @QueryParam("api-version") String apiVersion,
+ @BodyParam("application/json") ResourceChangesRequestParameters parameters,
+ @HeaderParam("Accept") String accept,
+ Context context);
+
+ @Headers({"Content-Type: application/json"})
+ @Post("/providers/Microsoft.ResourceGraph/resourceChangeDetails")
+ @ExpectedResponses({200})
+ @UnexpectedResponseExceptionType(ManagementException.class)
+ Mono>> resourceChangeDetails(
+ @HostParam("$host") String endpoint,
+ @QueryParam("api-version") String apiVersion,
+ @BodyParam("application/json") ResourceChangeDetailsRequestParameters parameters,
+ @HeaderParam("Accept") String accept,
+ Context context);
}
/**
@@ -86,11 +125,10 @@ private Mono> resourcesWithResponseAsync(QueryReque
} else {
query.validate();
}
+ final String apiVersion = "2022-10-01";
final String accept = "application/json";
return FluxUtil
- .withContext(
- context ->
- service.resources(this.client.getEndpoint(), this.client.getApiVersion(), query, accept, context))
+ .withContext(context -> service.resources(this.client.getEndpoint(), apiVersion, query, accept, context))
.contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
}
@@ -117,9 +155,10 @@ private Mono> resourcesWithResponseAsync(QueryReque
} else {
query.validate();
}
+ final String apiVersion = "2022-10-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
- return service.resources(this.client.getEndpoint(), this.client.getApiVersion(), query, accept, context);
+ return service.resources(this.client.getEndpoint(), apiVersion, query, accept, context);
}
/**
@@ -133,43 +172,352 @@ private Mono> resourcesWithResponseAsync(QueryReque
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono resourcesAsync(QueryRequest query) {
- return resourcesWithResponseAsync(query)
- .flatMap(
- (Response res) -> {
- if (res.getValue() != null) {
- return Mono.just(res.getValue());
- } else {
- return Mono.empty();
- }
- });
+ return resourcesWithResponseAsync(query).flatMap(res -> Mono.justOrEmpty(res.getValue()));
}
/**
* Queries the resources managed by Azure Resource Manager for scopes specified in the request.
*
* @param query Request specifying query and its options.
+ * @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return query result.
+ * @return query result along with {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
- public QueryResponseInner resources(QueryRequest query) {
- return resourcesAsync(query).block();
+ public Response resourcesWithResponse(QueryRequest query, Context context) {
+ return resourcesWithResponseAsync(query, context).block();
}
/**
* Queries the resources managed by Azure Resource Manager for scopes specified in the request.
*
* @param query Request specifying query and its options.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws ManagementException thrown if the request is rejected by server.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return query result.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public QueryResponseInner resources(QueryRequest query) {
+ return resourcesWithResponse(query, Context.NONE).getValue();
+ }
+
+ /**
+ * List all snapshots of a resource for a given time interval.
+ *
+ * @param request Request specifying the query and its options.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws ManagementException thrown if the request is rejected by server.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return any object along with {@link Response} on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private Mono> resourcesHistoryWithResponseAsync(ResourcesHistoryRequest request) {
+ if (this.client.getEndpoint() == null) {
+ return Mono
+ .error(
+ new IllegalArgumentException(
+ "Parameter this.client.getEndpoint() is required and cannot be null."));
+ }
+ if (request == null) {
+ return Mono.error(new IllegalArgumentException("Parameter request is required and cannot be null."));
+ } else {
+ request.validate();
+ }
+ final String apiVersion = "2021-06-01-preview";
+ final String accept = "application/json";
+ return FluxUtil
+ .withContext(
+ context -> service.resourcesHistory(this.client.getEndpoint(), apiVersion, request, accept, context))
+ .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
+ }
+
+ /**
+ * List all snapshots of a resource for a given time interval.
+ *
+ * @param request Request specifying the query and its options.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return query result along with {@link Response}.
+ * @return any object along with {@link Response} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
- public Response resourcesWithResponse(QueryRequest query, Context context) {
- return resourcesWithResponseAsync(query, context).block();
+ private Mono> resourcesHistoryWithResponseAsync(ResourcesHistoryRequest request, Context context) {
+ if (this.client.getEndpoint() == null) {
+ return Mono
+ .error(
+ new IllegalArgumentException(
+ "Parameter this.client.getEndpoint() is required and cannot be null."));
+ }
+ if (request == null) {
+ return Mono.error(new IllegalArgumentException("Parameter request is required and cannot be null."));
+ } else {
+ request.validate();
+ }
+ final String apiVersion = "2021-06-01-preview";
+ final String accept = "application/json";
+ context = this.client.mergeContext(context);
+ return service.resourcesHistory(this.client.getEndpoint(), apiVersion, request, accept, context);
+ }
+
+ /**
+ * List all snapshots of a resource for a given time interval.
+ *
+ * @param request Request specifying the query and its options.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws ManagementException thrown if the request is rejected by server.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return any object on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private Mono