+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return paged collection of AssetResource items as paginated response with {@link PagedFlux}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux listAssetResource(RequestOptions requestOptions) {
+ return this.serviceClient.listAssetResourceAsync(requestOptions);
+ }
+
+ /**
+ * Update labels on assets matching the provided filter.
+ *
+ *
+ *
+ * @param filter An expression on the resource type that selects the resources to be returned.
+ * @param assetUpdateData A request body used to update an asset.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response} on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> updateAssetsWithResponse(
+ String filter, BinaryData assetUpdateData, RequestOptions requestOptions) {
+ return this.serviceClient.updateAssetsWithResponseAsync(filter, assetUpdateData, requestOptions);
+ }
+
+ /**
+ * Retrieve an asset by assetId.
+ *
+ *
+ *
+ * @param assetId The system generated unique id for the resource.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the items in the current page of results along with {@link Response} on successful completion of {@link
+ * Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> getAssetResourceWithResponse(String assetId, RequestOptions requestOptions) {
+ return this.serviceClient.getAssetResourceWithResponseAsync(assetId, requestOptions);
+ }
+
+ /**
+ * Retrieve a list of data connections.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return paged collection of DataConnection items as paginated response with {@link PagedFlux}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux listDataConnection(RequestOptions requestOptions) {
+ return this.serviceClient.listDataConnectionAsync(requestOptions);
+ }
+
+ /**
+ * Validate a data connection with a given dataConnectionName.
+ *
+ *
+ *
+ * @param dataConnectionData The dataConnectionData parameter.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response} on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> validateDataConnectionWithResponse(
+ BinaryData dataConnectionData, RequestOptions requestOptions) {
+ return this.serviceClient.validateDataConnectionWithResponseAsync(dataConnectionData, requestOptions);
+ }
+
+ /**
+ * Retrieve a data connection with a given dataConnectionName.
+ *
+ *
+ *
+ * @param dataConnectionName The caller provided unique name for the resource.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response} on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> getDataConnectionWithResponse(
+ String dataConnectionName, RequestOptions requestOptions) {
+ return this.serviceClient.getDataConnectionWithResponseAsync(dataConnectionName, requestOptions);
+ }
+
+ /**
+ * Create or update a data connection with a given dataConnectionName.
+ *
+ *
+ *
+ * @param dataConnectionName The caller provided unique name for the resource.
+ * @param dataConnectionData The dataConnectionData parameter.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response} on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> putDataConnectionWithResponse(
+ String dataConnectionName, BinaryData dataConnectionData, RequestOptions requestOptions) {
+ return this.serviceClient.putDataConnectionWithResponseAsync(
+ dataConnectionName, dataConnectionData, requestOptions);
+ }
+
+ /**
+ * Delete a data connection with a given dataConnectionName.
+ *
+ * @param dataConnectionName The caller provided unique name for the resource.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the {@link Response} on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> deleteDataConnectionWithResponse(
+ String dataConnectionName, RequestOptions requestOptions) {
+ return this.serviceClient.deleteDataConnectionWithResponseAsync(dataConnectionName, requestOptions);
+ }
+
+ /**
+ * Retrieve a list of discovery group for the provided search parameters.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
filter
String
No
Filter the result list using the given expression.
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return paged collection of DiscoGroup items as paginated response with {@link PagedFlux}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux listDiscoGroup(RequestOptions requestOptions) {
+ return this.serviceClient.listDiscoGroupAsync(requestOptions);
+ }
+
+ /**
+ * Validate a discovery group with a given groupName.
+ *
+ *
+ *
+ * @param discoGroupData A request body used to create a discovery group.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response} on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> validateDiscoGroupWithResponse(
+ BinaryData discoGroupData, RequestOptions requestOptions) {
+ return this.serviceClient.validateDiscoGroupWithResponseAsync(discoGroupData, requestOptions);
+ }
+
+ /**
+ * Retrieve a discovery group with a given groupName.
+ *
+ *
+ *
+ * @param groupName The caller provided unique name for the resource.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response} on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> getDiscoGroupWithResponse(String groupName, RequestOptions requestOptions) {
+ return this.serviceClient.getDiscoGroupWithResponseAsync(groupName, requestOptions);
+ }
+
+ /**
+ * Create a discovery group with a given groupName.
+ *
+ *
+ *
+ * @param groupName The caller provided unique name for the resource.
+ * @param discoGroupData A request body used to create a discovery group.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response} on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> putDiscoGroupWithResponse(
+ String groupName, BinaryData discoGroupData, RequestOptions requestOptions) {
+ return this.serviceClient.putDiscoGroupWithResponseAsync(groupName, discoGroupData, requestOptions);
+ }
+
+ /**
+ * Run a discovery group with a given groupName.
+ *
+ * @param groupName The caller provided unique name for the resource.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the {@link Response} on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> runDiscoGroupWithResponse(String groupName, RequestOptions requestOptions) {
+ return this.serviceClient.runDiscoGroupWithResponseAsync(groupName, requestOptions);
+ }
+
+ /**
+ * Retrieve a collection of discovery run results for a discovery group with a given groupName.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
filter
String
No
Filter the result list using the given expression.
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param groupName The unique identifier for the discovery group.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response} on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> listRunsWithResponse(String groupName, RequestOptions requestOptions) {
+ return this.serviceClient.listRunsWithResponseAsync(groupName, requestOptions);
+ }
+
+ /**
+ * Retrieve a list of disco templates for the provided search parameters.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
filter
String
No
Filter the result list using the given expression.
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return paged collection of DiscoTemplate items as paginated response with {@link PagedFlux}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux listDiscoTemplate(RequestOptions requestOptions) {
+ return this.serviceClient.listDiscoTemplateAsync(requestOptions);
+ }
+
+ /**
+ * Retrieve a disco template with a given templateId.
+ *
+ *
+ *
+ * @param templateId The system generated unique id for the resource.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the items in the current page of results along with {@link Response} on successful completion of {@link
+ * Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> getDiscoTemplateWithResponse(String templateId, RequestOptions requestOptions) {
+ return this.serviceClient.getDiscoTemplateWithResponseAsync(templateId, requestOptions);
+ }
+
+ /**
+ * Get billable assets summary for the workspace.
+ *
+ *
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return billable assets summary for the workspace along with {@link Response} on successful completion of {@link
+ * Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> getBillableWithResponse(RequestOptions requestOptions) {
+ return this.serviceClient.getBillableWithResponseAsync(requestOptions);
+ }
+
+ /**
+ * Get the most recent snapshot of asset summary values for the snapshot request.
+ *
+ *
+ *
+ * @param reportAssetSnapshotRequest A request body used to retrieve an asset report snapshot.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the most recent snapshot of asset summary values for the snapshot request along with {@link Response} on
+ * successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> getSnapshotWithResponse(
+ BinaryData reportAssetSnapshotRequest, RequestOptions requestOptions) {
+ return this.serviceClient.getSnapshotWithResponseAsync(reportAssetSnapshotRequest, requestOptions);
+ }
+
+ /**
+ * Get asset summary details for the summary request.
+ *
+ *
+ *
+ * @param reportAssetSummaryRequest A request body used to retrieve summary asset information. One and only one
+ * collection of summary identifiers must be provided: filters, metrics, or metricCategories.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return asset summary details for the summary request along with {@link Response} on successful completion of
+ * {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> getSummaryWithResponse(
+ BinaryData reportAssetSummaryRequest, RequestOptions requestOptions) {
+ return this.serviceClient.getSummaryWithResponseAsync(reportAssetSummaryRequest, requestOptions);
+ }
+
+ /**
+ * Retrieve a list of saved filters for the provided search parameters.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
filter
String
No
Filter the result list using the given expression.
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return paged collection of SavedFilter items as paginated response with {@link PagedFlux}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux listSavedFilter(RequestOptions requestOptions) {
+ return this.serviceClient.listSavedFilterAsync(requestOptions);
+ }
+
+ /**
+ * Retrieve a saved filter by filterName.
+ *
+ *
+ *
+ * @param filterName The caller provided unique name for the resource.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response} on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> getSavedFilterWithResponse(String filterName, RequestOptions requestOptions) {
+ return this.serviceClient.getSavedFilterWithResponseAsync(filterName, requestOptions);
+ }
+
+ /**
+ * Create or update a saved filter with a given filterName.
+ *
+ *
+ *
+ * @param filterName The caller provided unique name for the resource.
+ * @param savedFilterData A request body used to create a saved filter.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response} on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> putSavedFilterWithResponse(
+ String filterName, BinaryData savedFilterData, RequestOptions requestOptions) {
+ return this.serviceClient.putSavedFilterWithResponseAsync(filterName, savedFilterData, requestOptions);
+ }
+
+ /**
+ * Delete a saved filter with a given filterName.
+ *
+ * @param filterName The caller provided unique name for the resource.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the {@link Response} on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> deleteSavedFilterWithResponse(String filterName, RequestOptions requestOptions) {
+ return this.serviceClient.deleteSavedFilterWithResponseAsync(filterName, requestOptions);
+ }
+
+ /**
+ * Retrieve a list of tasks for the provided search parameters.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
filter
String
No
Filter the result list using the given expression.
+ *
orderby
String
No
A list of expressions that specify the order of the returned resources.
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return paged collection of Task items as paginated response with {@link PagedFlux}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux listTask(RequestOptions requestOptions) {
+ return this.serviceClient.listTaskAsync(requestOptions);
+ }
+
+ /**
+ * Retrieve a task by taskId.
+ *
+ *
+ *
+ * @param taskId The unique identifier of the task.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response} on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> getTaskWithResponse(String taskId, RequestOptions requestOptions) {
+ return this.serviceClient.getTaskWithResponseAsync(taskId, requestOptions);
+ }
+
+ /**
+ * Cancel a task by taskId.
+ *
+ *
+ *
+ * @param taskId The unique identifier of the task.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response} on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> cancelTaskWithResponse(String taskId, RequestOptions requestOptions) {
+ return this.serviceClient.cancelTaskWithResponseAsync(taskId, requestOptions);
+ }
+
+ /**
+ * Retrieve a list of assets for the provided search parameters.
+ *
+ * @param filter Filter the result list using the given expression.
+ * @param orderBy A list of expressions that specify the order of the returned resources.
+ * @param skip The number of result items to skip.
+ * @param maxPageSize The maximum number of result items per page.
+ * @param mark Specify this value instead of 'skip' to use cursor-based searching. Initial value is '*' and
+ * subsequent values are returned in the response.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return paged collection of AssetResource items as paginated response with {@link PagedFlux}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux listAssetResource(
+ String filter, String orderBy, Integer skip, Integer maxPageSize, String mark) {
+ // Generated convenience method for listAssetResource
+ RequestOptions requestOptions = new RequestOptions();
+ if (filter != null) {
+ requestOptions.addQueryParam("filter", filter, false);
+ }
+ if (orderBy != null) {
+ requestOptions.addQueryParam("orderby", orderBy, false);
+ }
+ if (skip != null) {
+ requestOptions.addQueryParam("skip", String.valueOf(skip), false);
+ }
+ if (maxPageSize != null) {
+ requestOptions.addQueryParam("maxpagesize", String.valueOf(maxPageSize), false);
+ }
+ if (mark != null) {
+ requestOptions.addQueryParam("mark", mark, false);
+ }
+ PagedFlux pagedFluxResponse = listAssetResource(requestOptions);
+ return PagedFlux.create(
+ () ->
+ (continuationToken, pageSize) -> {
+ Flux> flux =
+ (continuationToken == null)
+ ? pagedFluxResponse.byPage().take(1)
+ : pagedFluxResponse.byPage(continuationToken).take(1);
+ return flux.map(
+ pagedResponse ->
+ new PagedResponseBase(
+ pagedResponse.getRequest(),
+ pagedResponse.getStatusCode(),
+ pagedResponse.getHeaders(),
+ pagedResponse.getValue().stream()
+ .map(
+ protocolMethodData ->
+ protocolMethodData.toObject(
+ AssetResource.class))
+ .collect(Collectors.toList()),
+ pagedResponse.getContinuationToken(),
+ null));
+ });
+ }
+
+ /**
+ * Retrieve a list of assets for the provided search parameters.
+ *
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return paged collection of AssetResource items as paginated response with {@link PagedFlux}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux listAssetResource() {
+ // Generated convenience method for listAssetResource
+ RequestOptions requestOptions = new RequestOptions();
+ PagedFlux pagedFluxResponse = listAssetResource(requestOptions);
+ return PagedFlux.create(
+ () ->
+ (continuationToken, pageSize) -> {
+ Flux> flux =
+ (continuationToken == null)
+ ? pagedFluxResponse.byPage().take(1)
+ : pagedFluxResponse.byPage(continuationToken).take(1);
+ return flux.map(
+ pagedResponse ->
+ new PagedResponseBase(
+ pagedResponse.getRequest(),
+ pagedResponse.getStatusCode(),
+ pagedResponse.getHeaders(),
+ pagedResponse.getValue().stream()
+ .map(
+ protocolMethodData ->
+ protocolMethodData.toObject(
+ AssetResource.class))
+ .collect(Collectors.toList()),
+ pagedResponse.getContinuationToken(),
+ null));
+ });
+ }
+
+ /**
+ * Update labels on assets matching the provided filter.
+ *
+ * @param filter An expression on the resource type that selects the resources to be returned.
+ * @param assetUpdateData A request body used to update an asset.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return the response body on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono updateAssets(String filter, AssetUpdateData assetUpdateData) {
+ // Generated convenience method for updateAssetsWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return updateAssetsWithResponse(filter, BinaryData.fromObject(assetUpdateData), requestOptions)
+ .flatMap(FluxUtil::toMono)
+ .map(protocolMethodData -> protocolMethodData.toObject(Task.class));
+ }
+
+ /**
+ * Retrieve an asset by assetId.
+ *
+ * @param assetId The system generated unique id for the resource.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return the items in the current page of results on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono getAssetResource(String assetId) {
+ // Generated convenience method for getAssetResourceWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return getAssetResourceWithResponse(assetId, requestOptions)
+ .flatMap(FluxUtil::toMono)
+ .map(protocolMethodData -> protocolMethodData.toObject(AssetResource.class));
+ }
+
+ /**
+ * Retrieve a list of data connections.
+ *
+ * @param skip The number of result items to skip.
+ * @param maxPageSize The maximum number of result items per page.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return paged collection of DataConnection items as paginated response with {@link PagedFlux}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux listDataConnection(Integer skip, Integer maxPageSize) {
+ // Generated convenience method for listDataConnection
+ RequestOptions requestOptions = new RequestOptions();
+ if (skip != null) {
+ requestOptions.addQueryParam("skip", String.valueOf(skip), false);
+ }
+ if (maxPageSize != null) {
+ requestOptions.addQueryParam("maxpagesize", String.valueOf(maxPageSize), false);
+ }
+ PagedFlux pagedFluxResponse = listDataConnection(requestOptions);
+ return PagedFlux.create(
+ () ->
+ (continuationToken, pageSize) -> {
+ Flux> flux =
+ (continuationToken == null)
+ ? pagedFluxResponse.byPage().take(1)
+ : pagedFluxResponse.byPage(continuationToken).take(1);
+ return flux.map(
+ pagedResponse ->
+ new PagedResponseBase(
+ pagedResponse.getRequest(),
+ pagedResponse.getStatusCode(),
+ pagedResponse.getHeaders(),
+ pagedResponse.getValue().stream()
+ .map(
+ protocolMethodData ->
+ protocolMethodData.toObject(
+ DataConnection.class))
+ .collect(Collectors.toList()),
+ pagedResponse.getContinuationToken(),
+ null));
+ });
+ }
+
+ /**
+ * Retrieve a list of data connections.
+ *
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return paged collection of DataConnection items as paginated response with {@link PagedFlux}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux listDataConnection() {
+ // Generated convenience method for listDataConnection
+ RequestOptions requestOptions = new RequestOptions();
+ PagedFlux pagedFluxResponse = listDataConnection(requestOptions);
+ return PagedFlux.create(
+ () ->
+ (continuationToken, pageSize) -> {
+ Flux> flux =
+ (continuationToken == null)
+ ? pagedFluxResponse.byPage().take(1)
+ : pagedFluxResponse.byPage(continuationToken).take(1);
+ return flux.map(
+ pagedResponse ->
+ new PagedResponseBase(
+ pagedResponse.getRequest(),
+ pagedResponse.getStatusCode(),
+ pagedResponse.getHeaders(),
+ pagedResponse.getValue().stream()
+ .map(
+ protocolMethodData ->
+ protocolMethodData.toObject(
+ DataConnection.class))
+ .collect(Collectors.toList()),
+ pagedResponse.getContinuationToken(),
+ null));
+ });
+ }
+
+ /**
+ * Validate a data connection with a given dataConnectionName.
+ *
+ * @param dataConnectionData The dataConnectionData parameter.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return the response body on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono validateDataConnection(DataConnectionData dataConnectionData) {
+ // Generated convenience method for validateDataConnectionWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return validateDataConnectionWithResponse(BinaryData.fromObject(dataConnectionData), requestOptions)
+ .flatMap(FluxUtil::toMono)
+ .map(protocolMethodData -> protocolMethodData.toObject(ValidateResult.class));
+ }
+
+ /**
+ * Retrieve a data connection with a given dataConnectionName.
+ *
+ * @param dataConnectionName The caller provided unique name for the resource.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return the response body on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono getDataConnection(String dataConnectionName) {
+ // Generated convenience method for getDataConnectionWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return getDataConnectionWithResponse(dataConnectionName, requestOptions)
+ .flatMap(FluxUtil::toMono)
+ .map(protocolMethodData -> protocolMethodData.toObject(DataConnection.class));
+ }
+
+ /**
+ * Create or update a data connection with a given dataConnectionName.
+ *
+ * @param dataConnectionName The caller provided unique name for the resource.
+ * @param dataConnectionData The dataConnectionData parameter.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return the response body on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono putDataConnection(String dataConnectionName, DataConnectionData dataConnectionData) {
+ // Generated convenience method for putDataConnectionWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return putDataConnectionWithResponse(
+ dataConnectionName, BinaryData.fromObject(dataConnectionData), requestOptions)
+ .flatMap(FluxUtil::toMono)
+ .map(protocolMethodData -> protocolMethodData.toObject(DataConnection.class));
+ }
+
+ /**
+ * Delete a data connection with a given dataConnectionName.
+ *
+ * @param dataConnectionName The caller provided unique name for the resource.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return A {@link Mono} that completes when a successful response is received.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono deleteDataConnection(String dataConnectionName) {
+ // Generated convenience method for deleteDataConnectionWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return deleteDataConnectionWithResponse(dataConnectionName, requestOptions).flatMap(FluxUtil::toMono);
+ }
+
+ /**
+ * Retrieve a list of discovery group for the provided search parameters.
+ *
+ * @param filter Filter the result list using the given expression.
+ * @param skip The number of result items to skip.
+ * @param maxPageSize The maximum number of result items per page.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return paged collection of DiscoGroup items as paginated response with {@link PagedFlux}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux listDiscoGroup(String filter, Integer skip, Integer maxPageSize) {
+ // Generated convenience method for listDiscoGroup
+ RequestOptions requestOptions = new RequestOptions();
+ if (filter != null) {
+ requestOptions.addQueryParam("filter", filter, false);
+ }
+ if (skip != null) {
+ requestOptions.addQueryParam("skip", String.valueOf(skip), false);
+ }
+ if (maxPageSize != null) {
+ requestOptions.addQueryParam("maxpagesize", String.valueOf(maxPageSize), false);
+ }
+ PagedFlux pagedFluxResponse = listDiscoGroup(requestOptions);
+ return PagedFlux.create(
+ () ->
+ (continuationToken, pageSize) -> {
+ Flux> flux =
+ (continuationToken == null)
+ ? pagedFluxResponse.byPage().take(1)
+ : pagedFluxResponse.byPage(continuationToken).take(1);
+ return flux.map(
+ pagedResponse ->
+ new PagedResponseBase(
+ pagedResponse.getRequest(),
+ pagedResponse.getStatusCode(),
+ pagedResponse.getHeaders(),
+ pagedResponse.getValue().stream()
+ .map(
+ protocolMethodData ->
+ protocolMethodData.toObject(
+ DiscoGroup.class))
+ .collect(Collectors.toList()),
+ pagedResponse.getContinuationToken(),
+ null));
+ });
+ }
+
+ /**
+ * Retrieve a list of discovery group for the provided search parameters.
+ *
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return paged collection of DiscoGroup items as paginated response with {@link PagedFlux}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux listDiscoGroup() {
+ // Generated convenience method for listDiscoGroup
+ RequestOptions requestOptions = new RequestOptions();
+ PagedFlux pagedFluxResponse = listDiscoGroup(requestOptions);
+ return PagedFlux.create(
+ () ->
+ (continuationToken, pageSize) -> {
+ Flux> flux =
+ (continuationToken == null)
+ ? pagedFluxResponse.byPage().take(1)
+ : pagedFluxResponse.byPage(continuationToken).take(1);
+ return flux.map(
+ pagedResponse ->
+ new PagedResponseBase(
+ pagedResponse.getRequest(),
+ pagedResponse.getStatusCode(),
+ pagedResponse.getHeaders(),
+ pagedResponse.getValue().stream()
+ .map(
+ protocolMethodData ->
+ protocolMethodData.toObject(
+ DiscoGroup.class))
+ .collect(Collectors.toList()),
+ pagedResponse.getContinuationToken(),
+ null));
+ });
+ }
+
+ /**
+ * Validate a discovery group with a given groupName.
+ *
+ * @param discoGroupData A request body used to create a discovery group.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return the response body on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono validateDiscoGroup(DiscoGroupData discoGroupData) {
+ // Generated convenience method for validateDiscoGroupWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return validateDiscoGroupWithResponse(BinaryData.fromObject(discoGroupData), requestOptions)
+ .flatMap(FluxUtil::toMono)
+ .map(protocolMethodData -> protocolMethodData.toObject(ValidateResult.class));
+ }
+
+ /**
+ * Retrieve a discovery group with a given groupName.
+ *
+ * @param groupName The caller provided unique name for the resource.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return the response body on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono getDiscoGroup(String groupName) {
+ // Generated convenience method for getDiscoGroupWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return getDiscoGroupWithResponse(groupName, requestOptions)
+ .flatMap(FluxUtil::toMono)
+ .map(protocolMethodData -> protocolMethodData.toObject(DiscoGroup.class));
+ }
+
+ /**
+ * Create a discovery group with a given groupName.
+ *
+ * @param groupName The caller provided unique name for the resource.
+ * @param discoGroupData A request body used to create a discovery group.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return the response body on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono putDiscoGroup(String groupName, DiscoGroupData discoGroupData) {
+ // Generated convenience method for putDiscoGroupWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return putDiscoGroupWithResponse(groupName, BinaryData.fromObject(discoGroupData), requestOptions)
+ .flatMap(FluxUtil::toMono)
+ .map(protocolMethodData -> protocolMethodData.toObject(DiscoGroup.class));
+ }
+
+ /**
+ * Run a discovery group with a given groupName.
+ *
+ * @param groupName The caller provided unique name for the resource.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return A {@link Mono} that completes when a successful response is received.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono runDiscoGroup(String groupName) {
+ // Generated convenience method for runDiscoGroupWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return runDiscoGroupWithResponse(groupName, requestOptions).flatMap(FluxUtil::toMono);
+ }
+
+ /**
+ * Retrieve a collection of discovery run results for a discovery group with a given groupName.
+ *
+ * @param groupName The unique identifier for the discovery group.
+ * @param filter Filter the result list using the given expression.
+ * @param skip The number of result items to skip.
+ * @param maxPageSize The maximum number of result items per page.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return the response body on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono listRuns(String groupName, String filter, Integer skip, Integer maxPageSize) {
+ // Generated convenience method for listRunsWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ if (filter != null) {
+ requestOptions.addQueryParam("filter", filter, false);
+ }
+ if (skip != null) {
+ requestOptions.addQueryParam("skip", String.valueOf(skip), false);
+ }
+ if (maxPageSize != null) {
+ requestOptions.addQueryParam("maxpagesize", String.valueOf(maxPageSize), false);
+ }
+ return listRunsWithResponse(groupName, requestOptions)
+ .flatMap(FluxUtil::toMono)
+ .map(protocolMethodData -> protocolMethodData.toObject(DiscoRunPageResult.class));
+ }
+
+ /**
+ * Retrieve a collection of discovery run results for a discovery group with a given groupName.
+ *
+ * @param groupName The unique identifier for the discovery group.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return the response body on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono listRuns(String groupName) {
+ // Generated convenience method for listRunsWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return listRunsWithResponse(groupName, requestOptions)
+ .flatMap(FluxUtil::toMono)
+ .map(protocolMethodData -> protocolMethodData.toObject(DiscoRunPageResult.class));
+ }
+
+ /**
+ * Retrieve a list of disco templates for the provided search parameters.
+ *
+ * @param filter Filter the result list using the given expression.
+ * @param skip The number of result items to skip.
+ * @param maxPageSize The maximum number of result items per page.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return paged collection of DiscoTemplate items as paginated response with {@link PagedFlux}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux listDiscoTemplate(String filter, Integer skip, Integer maxPageSize) {
+ // Generated convenience method for listDiscoTemplate
+ RequestOptions requestOptions = new RequestOptions();
+ if (filter != null) {
+ requestOptions.addQueryParam("filter", filter, false);
+ }
+ if (skip != null) {
+ requestOptions.addQueryParam("skip", String.valueOf(skip), false);
+ }
+ if (maxPageSize != null) {
+ requestOptions.addQueryParam("maxpagesize", String.valueOf(maxPageSize), false);
+ }
+ PagedFlux pagedFluxResponse = listDiscoTemplate(requestOptions);
+ return PagedFlux.create(
+ () ->
+ (continuationToken, pageSize) -> {
+ Flux> flux =
+ (continuationToken == null)
+ ? pagedFluxResponse.byPage().take(1)
+ : pagedFluxResponse.byPage(continuationToken).take(1);
+ return flux.map(
+ pagedResponse ->
+ new PagedResponseBase(
+ pagedResponse.getRequest(),
+ pagedResponse.getStatusCode(),
+ pagedResponse.getHeaders(),
+ pagedResponse.getValue().stream()
+ .map(
+ protocolMethodData ->
+ protocolMethodData.toObject(
+ DiscoTemplate.class))
+ .collect(Collectors.toList()),
+ pagedResponse.getContinuationToken(),
+ null));
+ });
+ }
+
+ /**
+ * Retrieve a list of disco templates for the provided search parameters.
+ *
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return paged collection of DiscoTemplate items as paginated response with {@link PagedFlux}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux listDiscoTemplate() {
+ // Generated convenience method for listDiscoTemplate
+ RequestOptions requestOptions = new RequestOptions();
+ PagedFlux pagedFluxResponse = listDiscoTemplate(requestOptions);
+ return PagedFlux.create(
+ () ->
+ (continuationToken, pageSize) -> {
+ Flux> flux =
+ (continuationToken == null)
+ ? pagedFluxResponse.byPage().take(1)
+ : pagedFluxResponse.byPage(continuationToken).take(1);
+ return flux.map(
+ pagedResponse ->
+ new PagedResponseBase(
+ pagedResponse.getRequest(),
+ pagedResponse.getStatusCode(),
+ pagedResponse.getHeaders(),
+ pagedResponse.getValue().stream()
+ .map(
+ protocolMethodData ->
+ protocolMethodData.toObject(
+ DiscoTemplate.class))
+ .collect(Collectors.toList()),
+ pagedResponse.getContinuationToken(),
+ null));
+ });
+ }
+
+ /**
+ * Retrieve a disco template with a given templateId.
+ *
+ * @param templateId The system generated unique id for the resource.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return the items in the current page of results on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono getDiscoTemplate(String templateId) {
+ // Generated convenience method for getDiscoTemplateWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return getDiscoTemplateWithResponse(templateId, requestOptions)
+ .flatMap(FluxUtil::toMono)
+ .map(protocolMethodData -> protocolMethodData.toObject(DiscoTemplate.class));
+ }
+
+ /**
+ * Get billable assets summary for the workspace.
+ *
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return billable assets summary for the workspace on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono getBillable() {
+ // Generated convenience method for getBillableWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return getBillableWithResponse(requestOptions)
+ .flatMap(FluxUtil::toMono)
+ .map(protocolMethodData -> protocolMethodData.toObject(ReportBillableAssetSummaryResult.class));
+ }
+
+ /**
+ * Get the most recent snapshot of asset summary values for the snapshot request.
+ *
+ * @param reportAssetSnapshotRequest A request body used to retrieve an asset report snapshot.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return the most recent snapshot of asset summary values for the snapshot request on successful completion of
+ * {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono getSnapshot(ReportAssetSnapshotRequest reportAssetSnapshotRequest) {
+ // Generated convenience method for getSnapshotWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return getSnapshotWithResponse(BinaryData.fromObject(reportAssetSnapshotRequest), requestOptions)
+ .flatMap(FluxUtil::toMono)
+ .map(protocolMethodData -> protocolMethodData.toObject(ReportAssetSnapshotResult.class));
+ }
+
+ /**
+ * Get asset summary details for the summary request.
+ *
+ * @param reportAssetSummaryRequest A request body used to retrieve summary asset information. One and only one
+ * collection of summary identifiers must be provided: filters, metrics, or metricCategories.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return asset summary details for the summary request on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono getSummary(ReportAssetSummaryRequest reportAssetSummaryRequest) {
+ // Generated convenience method for getSummaryWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return getSummaryWithResponse(BinaryData.fromObject(reportAssetSummaryRequest), requestOptions)
+ .flatMap(FluxUtil::toMono)
+ .map(protocolMethodData -> protocolMethodData.toObject(ReportAssetSummaryResult.class));
+ }
+
+ /**
+ * Retrieve a list of saved filters for the provided search parameters.
+ *
+ * @param filter Filter the result list using the given expression.
+ * @param skip The number of result items to skip.
+ * @param maxPageSize The maximum number of result items per page.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return paged collection of SavedFilter items as paginated response with {@link PagedFlux}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux listSavedFilter(String filter, Integer skip, Integer maxPageSize) {
+ // Generated convenience method for listSavedFilter
+ RequestOptions requestOptions = new RequestOptions();
+ if (filter != null) {
+ requestOptions.addQueryParam("filter", filter, false);
+ }
+ if (skip != null) {
+ requestOptions.addQueryParam("skip", String.valueOf(skip), false);
+ }
+ if (maxPageSize != null) {
+ requestOptions.addQueryParam("maxpagesize", String.valueOf(maxPageSize), false);
+ }
+ PagedFlux pagedFluxResponse = listSavedFilter(requestOptions);
+ return PagedFlux.create(
+ () ->
+ (continuationToken, pageSize) -> {
+ Flux> flux =
+ (continuationToken == null)
+ ? pagedFluxResponse.byPage().take(1)
+ : pagedFluxResponse.byPage(continuationToken).take(1);
+ return flux.map(
+ pagedResponse ->
+ new PagedResponseBase(
+ pagedResponse.getRequest(),
+ pagedResponse.getStatusCode(),
+ pagedResponse.getHeaders(),
+ pagedResponse.getValue().stream()
+ .map(
+ protocolMethodData ->
+ protocolMethodData.toObject(
+ SavedFilter.class))
+ .collect(Collectors.toList()),
+ pagedResponse.getContinuationToken(),
+ null));
+ });
+ }
+
+ /**
+ * Retrieve a list of saved filters for the provided search parameters.
+ *
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return paged collection of SavedFilter items as paginated response with {@link PagedFlux}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux listSavedFilter() {
+ // Generated convenience method for listSavedFilter
+ RequestOptions requestOptions = new RequestOptions();
+ PagedFlux pagedFluxResponse = listSavedFilter(requestOptions);
+ return PagedFlux.create(
+ () ->
+ (continuationToken, pageSize) -> {
+ Flux> flux =
+ (continuationToken == null)
+ ? pagedFluxResponse.byPage().take(1)
+ : pagedFluxResponse.byPage(continuationToken).take(1);
+ return flux.map(
+ pagedResponse ->
+ new PagedResponseBase(
+ pagedResponse.getRequest(),
+ pagedResponse.getStatusCode(),
+ pagedResponse.getHeaders(),
+ pagedResponse.getValue().stream()
+ .map(
+ protocolMethodData ->
+ protocolMethodData.toObject(
+ SavedFilter.class))
+ .collect(Collectors.toList()),
+ pagedResponse.getContinuationToken(),
+ null));
+ });
+ }
+
+ /**
+ * Retrieve a saved filter by filterName.
+ *
+ * @param filterName The caller provided unique name for the resource.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return the response body on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono getSavedFilter(String filterName) {
+ // Generated convenience method for getSavedFilterWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return getSavedFilterWithResponse(filterName, requestOptions)
+ .flatMap(FluxUtil::toMono)
+ .map(protocolMethodData -> protocolMethodData.toObject(SavedFilter.class));
+ }
+
+ /**
+ * Create or update a saved filter with a given filterName.
+ *
+ * @param filterName The caller provided unique name for the resource.
+ * @param savedFilterData A request body used to create a saved filter.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return the response body on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono putSavedFilter(String filterName, SavedFilterData savedFilterData) {
+ // Generated convenience method for putSavedFilterWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return putSavedFilterWithResponse(filterName, BinaryData.fromObject(savedFilterData), requestOptions)
+ .flatMap(FluxUtil::toMono)
+ .map(protocolMethodData -> protocolMethodData.toObject(SavedFilter.class));
+ }
+
+ /**
+ * Delete a saved filter with a given filterName.
+ *
+ * @param filterName The caller provided unique name for the resource.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return A {@link Mono} that completes when a successful response is received.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono deleteSavedFilter(String filterName) {
+ // Generated convenience method for deleteSavedFilterWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return deleteSavedFilterWithResponse(filterName, requestOptions).flatMap(FluxUtil::toMono);
+ }
+
+ /**
+ * Retrieve a list of tasks for the provided search parameters.
+ *
+ * @param filter Filter the result list using the given expression.
+ * @param orderBy A list of expressions that specify the order of the returned resources.
+ * @param skip The number of result items to skip.
+ * @param maxPageSize The maximum number of result items per page.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return paged collection of Task items as paginated response with {@link PagedFlux}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux listTask(String filter, String orderBy, Integer skip, Integer maxPageSize) {
+ // Generated convenience method for listTask
+ RequestOptions requestOptions = new RequestOptions();
+ if (filter != null) {
+ requestOptions.addQueryParam("filter", filter, false);
+ }
+ if (orderBy != null) {
+ requestOptions.addQueryParam("orderby", orderBy, false);
+ }
+ if (skip != null) {
+ requestOptions.addQueryParam("skip", String.valueOf(skip), false);
+ }
+ if (maxPageSize != null) {
+ requestOptions.addQueryParam("maxpagesize", String.valueOf(maxPageSize), false);
+ }
+ PagedFlux pagedFluxResponse = listTask(requestOptions);
+ return PagedFlux.create(
+ () ->
+ (continuationToken, pageSize) -> {
+ Flux> flux =
+ (continuationToken == null)
+ ? pagedFluxResponse.byPage().take(1)
+ : pagedFluxResponse.byPage(continuationToken).take(1);
+ return flux.map(
+ pagedResponse ->
+ new PagedResponseBase(
+ pagedResponse.getRequest(),
+ pagedResponse.getStatusCode(),
+ pagedResponse.getHeaders(),
+ pagedResponse.getValue().stream()
+ .map(
+ protocolMethodData ->
+ protocolMethodData.toObject(Task.class))
+ .collect(Collectors.toList()),
+ pagedResponse.getContinuationToken(),
+ null));
+ });
+ }
+
+ /**
+ * Retrieve a list of tasks for the provided search parameters.
+ *
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return paged collection of Task items as paginated response with {@link PagedFlux}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux listTask() {
+ // Generated convenience method for listTask
+ RequestOptions requestOptions = new RequestOptions();
+ PagedFlux pagedFluxResponse = listTask(requestOptions);
+ return PagedFlux.create(
+ () ->
+ (continuationToken, pageSize) -> {
+ Flux> flux =
+ (continuationToken == null)
+ ? pagedFluxResponse.byPage().take(1)
+ : pagedFluxResponse.byPage(continuationToken).take(1);
+ return flux.map(
+ pagedResponse ->
+ new PagedResponseBase(
+ pagedResponse.getRequest(),
+ pagedResponse.getStatusCode(),
+ pagedResponse.getHeaders(),
+ pagedResponse.getValue().stream()
+ .map(
+ protocolMethodData ->
+ protocolMethodData.toObject(Task.class))
+ .collect(Collectors.toList()),
+ pagedResponse.getContinuationToken(),
+ null));
+ });
+ }
+
+ /**
+ * Retrieve a task by taskId.
+ *
+ * @param taskId The unique identifier of the task.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return the response body on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono getTask(String taskId) {
+ // Generated convenience method for getTaskWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return getTaskWithResponse(taskId, requestOptions)
+ .flatMap(FluxUtil::toMono)
+ .map(protocolMethodData -> protocolMethodData.toObject(Task.class));
+ }
+
+ /**
+ * Cancel a task by taskId.
+ *
+ * @param taskId The unique identifier of the task.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return the response body on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono cancelTask(String taskId) {
+ // Generated convenience method for cancelTaskWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return cancelTaskWithResponse(taskId, requestOptions)
+ .flatMap(FluxUtil::toMono)
+ .map(protocolMethodData -> protocolMethodData.toObject(Task.class));
+ }
+}
diff --git a/sdk/easm/azure-analytics-defendereasm/src/main/java/com/azure/analytics/defender/easm/EasmClient.java b/sdk/easm/azure-analytics-defendereasm/src/main/java/com/azure/analytics/defender/easm/EasmClient.java
new file mode 100644
index 000000000000..0f2b2ab8838e
--- /dev/null
+++ b/sdk/easm/azure-analytics-defendereasm/src/main/java/com/azure/analytics/defender/easm/EasmClient.java
@@ -0,0 +1,2022 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) AutoRest Code Generator.
+
+package com.azure.analytics.defender.easm;
+
+import com.azure.analytics.defender.easm.implementation.EasmClientImpl;
+import com.azure.analytics.defender.easm.models.*;
+import com.azure.core.annotation.Generated;
+import com.azure.core.annotation.ReturnType;
+import com.azure.core.annotation.ServiceClient;
+import com.azure.core.annotation.ServiceMethod;
+import com.azure.core.exception.ClientAuthenticationException;
+import com.azure.core.exception.HttpResponseException;
+import com.azure.core.exception.ResourceModifiedException;
+import com.azure.core.exception.ResourceNotFoundException;
+import com.azure.core.http.rest.PagedIterable;
+import com.azure.core.http.rest.RequestOptions;
+import com.azure.core.http.rest.Response;
+import com.azure.core.util.BinaryData;
+
+import javax.xml.crypto.Data;
+
+/** Initializes a new instance of the synchronous EasmClient type. */
+@ServiceClient(builder = EasmClientBuilder.class)
+public final class EasmClient {
+ @Generated private final EasmClientImpl serviceClient;
+
+ /**
+ * Initializes an instance of EasmClient class.
+ *
+ * @param serviceClient the service client implementation.
+ */
+ @Generated
+ EasmClient(EasmClientImpl serviceClient) {
+ this.serviceClient = serviceClient;
+ }
+
+ /**
+ * Retrieve a list of assets for the provided search parameters.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
filter
String
No
Filter the result list using the given expression.
+ *
orderby
String
No
A list of expressions that specify the order of the returned resources.
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
mark
String
No
Specify this value instead of 'skip' to use cursor-based searching. Initial value is '*' and subsequent values are returned in the response.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return paged collection of AssetResource items as paginated response with {@link PagedIterable}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public CountPagedIterable listAssetResource(RequestOptions requestOptions) {
+ return this.serviceClient.listAssetResource(requestOptions);
+ }
+
+ /**
+ * Update labels on assets matching the provided filter.
+ *
+ *
+ *
+ * @param filter An expression on the resource type that selects the resources to be returned.
+ * @param assetUpdateData A request body used to update an asset.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response updateAssetsWithResponse(
+ String filter, BinaryData assetUpdateData, RequestOptions requestOptions) {
+ return this.serviceClient.updateAssetsWithResponse(filter, assetUpdateData, requestOptions);
+ }
+
+ /**
+ * Retrieve an asset by assetId.
+ *
+ *
+ *
+ * @param assetId The system generated unique id for the resource.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the items in the current page of results along with {@link Response}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response getAssetResourceWithResponse(String assetId, RequestOptions requestOptions) {
+ return this.serviceClient.getAssetResourceWithResponse(assetId, requestOptions);
+ }
+
+ /**
+ * Retrieve a list of data connections.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return paged collection of DataConnection items as paginated response with {@link PagedIterable}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public CountPagedIterable listDataConnection(RequestOptions requestOptions) {
+ return this.serviceClient.listDataConnection(requestOptions);
+ }
+
+ /**
+ * Validate a data connection with a given dataConnectionName.
+ *
+ *
+ *
+ * @param dataConnectionData The dataConnectionData parameter.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response validateDataConnectionWithResponse(
+ BinaryData dataConnectionData, RequestOptions requestOptions) {
+ return this.serviceClient.validateDataConnectionWithResponse(dataConnectionData, requestOptions);
+ }
+
+ /**
+ * Retrieve a data connection with a given dataConnectionName.
+ *
+ *
+ *
+ * @param dataConnectionName The caller provided unique name for the resource.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response getDataConnectionWithResponse(
+ String dataConnectionName, RequestOptions requestOptions) {
+ return this.serviceClient.getDataConnectionWithResponse(dataConnectionName, requestOptions);
+ }
+
+ /**
+ * Create or update a data connection with a given dataConnectionName.
+ *
+ *
+ *
+ * @param dataConnectionName The caller provided unique name for the resource.
+ * @param dataConnectionData The dataConnectionData parameter.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response putDataConnectionWithResponse(
+ String dataConnectionName, BinaryData dataConnectionData, RequestOptions requestOptions) {
+ return this.serviceClient.putDataConnectionWithResponse(dataConnectionName, dataConnectionData, requestOptions);
+ }
+
+ /**
+ * Delete a data connection with a given dataConnectionName.
+ *
+ * @param dataConnectionName The caller provided unique name for the resource.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the {@link Response}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response deleteDataConnectionWithResponse(String dataConnectionName, RequestOptions requestOptions) {
+ return this.serviceClient.deleteDataConnectionWithResponse(dataConnectionName, requestOptions);
+ }
+
+ /**
+ * Retrieve a list of discovery group for the provided search parameters.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
filter
String
No
Filter the result list using the given expression.
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return paged collection of DiscoGroup items as paginated response with {@link PagedIterable}.
+ */
+// @Generated
+// @ServiceMethod(returns = ReturnType.COLLECTION)
+// public PagedIterable listDiscoGroup(RequestOptions requestOptions) {
+// return this.serviceClient.listDiscoGroup(requestOptions);
+// }
+
+ /**
+ * Validate a discovery group with a given groupName.
+ *
+ *
+ *
+ * @param discoGroupData A request body used to create a discovery group.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response validateDiscoGroupWithResponse(
+ BinaryData discoGroupData, RequestOptions requestOptions) {
+ return this.serviceClient.validateDiscoGroupWithResponse(discoGroupData, requestOptions);
+ }
+
+ /**
+ * Retrieve a discovery group with a given groupName.
+ *
+ *
+ *
+ * @param groupName The caller provided unique name for the resource.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response getDiscoGroupWithResponse(String groupName, RequestOptions requestOptions) {
+ return this.serviceClient.getDiscoGroupWithResponse(groupName, requestOptions);
+ }
+
+ /**
+ * Create a discovery group with a given groupName.
+ *
+ *
+ *
+ * @param groupName The caller provided unique name for the resource.
+ * @param discoGroupData A request body used to create a discovery group.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response putDiscoGroupWithResponse(
+ String groupName, BinaryData discoGroupData, RequestOptions requestOptions) {
+ return this.serviceClient.putDiscoGroupWithResponse(groupName, discoGroupData, requestOptions);
+ }
+
+ /**
+ * Run a discovery group with a given groupName.
+ *
+ * @param groupName The caller provided unique name for the resource.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the {@link Response}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response runDiscoGroupWithResponse(String groupName, RequestOptions requestOptions) {
+ return this.serviceClient.runDiscoGroupWithResponse(groupName, requestOptions);
+ }
+
+ /**
+ * Retrieve a collection of discovery run results for a discovery group with a given groupName.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
filter
String
No
Filter the result list using the given expression.
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param groupName The unique identifier for the discovery group.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public CountPagedIterable listRunsWithResponse(String groupName, RequestOptions requestOptions) {
+ return this.serviceClient.listRunsWithResponse(groupName, requestOptions);
+ }
+
+ /**
+ * Retrieve a list of disco templates for the provided search parameters.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
filter
String
No
Filter the result list using the given expression.
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return paged collection of DiscoTemplate items as paginated response with {@link PagedIterable}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public CountPagedIterable listDiscoTemplate(RequestOptions requestOptions) {
+ return this.serviceClient.listDiscoTemplate(requestOptions);
+ }
+
+ /**
+ * Retrieve a disco template with a given templateId.
+ *
+ *
+ *
+ * @param templateId The system generated unique id for the resource.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the items in the current page of results along with {@link Response}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response getDiscoTemplateWithResponse(String templateId, RequestOptions requestOptions) {
+ return this.serviceClient.getDiscoTemplateWithResponse(templateId, requestOptions);
+ }
+
+ /**
+ * Get billable assets summary for the workspace.
+ *
+ *
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return billable assets summary for the workspace along with {@link Response}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response getBillableWithResponse(RequestOptions requestOptions) {
+ return this.serviceClient.getBillableWithResponse(requestOptions);
+ }
+
+ /**
+ * Get the most recent snapshot of asset summary values for the snapshot request.
+ *
+ *
+ *
+ * @param reportAssetSnapshotRequest A request body used to retrieve an asset report snapshot.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the most recent snapshot of asset summary values for the snapshot request along with {@link Response}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response getSnapshotWithResponse(
+ BinaryData reportAssetSnapshotRequest, RequestOptions requestOptions) {
+ return this.serviceClient.getSnapshotWithResponse(reportAssetSnapshotRequest, requestOptions);
+ }
+
+ /**
+ * Get asset summary details for the summary request.
+ *
+ *
+ *
+ * @param reportAssetSummaryRequest A request body used to retrieve summary asset information. One and only one
+ * collection of summary identifiers must be provided: filters, metrics, or metricCategories.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return asset summary details for the summary request along with {@link Response}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response getSummaryWithResponse(
+ BinaryData reportAssetSummaryRequest, RequestOptions requestOptions) {
+ return this.serviceClient.getSummaryWithResponse(reportAssetSummaryRequest, requestOptions);
+ }
+
+ /**
+ * Retrieve a list of saved filters for the provided search parameters.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
filter
String
No
Filter the result list using the given expression.
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return paged collection of SavedFilter items as paginated response with {@link PagedIterable}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public CountPagedIterable listSavedFilter(RequestOptions requestOptions) {
+ return this.serviceClient.listSavedFilter(requestOptions);
+ }
+
+ /**
+ * Retrieve a saved filter by filterName.
+ *
+ *
+ *
+ * @param filterName The caller provided unique name for the resource.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response getSavedFilterWithResponse(String filterName, RequestOptions requestOptions) {
+ return this.serviceClient.getSavedFilterWithResponse(filterName, requestOptions);
+ }
+
+ /**
+ * Create or update a saved filter with a given filterName.
+ *
+ *
+ *
+ * @param filterName The caller provided unique name for the resource.
+ * @param savedFilterData A request body used to create a saved filter.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response putSavedFilterWithResponse(
+ String filterName, BinaryData savedFilterData, RequestOptions requestOptions) {
+ return this.serviceClient.putSavedFilterWithResponse(filterName, savedFilterData, requestOptions);
+ }
+
+ /**
+ * Delete a saved filter with a given filterName.
+ *
+ * @param filterName The caller provided unique name for the resource.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the {@link Response}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response deleteSavedFilterWithResponse(String filterName, RequestOptions requestOptions) {
+ return this.serviceClient.deleteSavedFilterWithResponse(filterName, requestOptions);
+ }
+
+ /**
+ * Retrieve a list of tasks for the provided search parameters.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
filter
String
No
Filter the result list using the given expression.
+ *
orderby
String
No
A list of expressions that specify the order of the returned resources.
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return paged collection of Task items as paginated response with {@link PagedIterable}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public CountPagedIterable listTask(RequestOptions requestOptions) {
+ return this.serviceClient.listTask(requestOptions);
+ }
+
+ /**
+ * Retrieve a task by taskId.
+ *
+ *
+ *
+ * @param taskId The unique identifier of the task.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response getTaskWithResponse(String taskId, RequestOptions requestOptions) {
+ return this.serviceClient.getTaskWithResponse(taskId, requestOptions);
+ }
+
+ /**
+ * Cancel a task by taskId.
+ *
+ *
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return paged collection of AssetResource items along with {@link PagedResponse} on successful completion of
+ * {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private Mono> listAssetResourceSinglePageAsync(RequestOptions requestOptions) {
+ final String accept = "application/json";
+ return FluxUtil.withContext(
+ context ->
+ service.listAssetResource(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ accept,
+ requestOptions,
+ context))
+ .map(
+ res ->
+ new PagedResponseBase<>(
+ res.getRequest(),
+ res.getStatusCode(),
+ res.getHeaders(),
+ getValues(res.getValue(), "value"),
+ getNextLink(res.getValue(), "nextLink"),
+ null));
+ }
+
+ /**
+ * Retrieve a list of assets for the provided search parameters.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
filter
String
No
Filter the result list using the given expression.
+ *
orderby
String
No
A list of expressions that specify the order of the returned resources.
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
mark
String
No
Specify this value instead of 'skip' to use cursor-based searching. Initial value is '*' and subsequent values are returned in the response.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return paged collection of AssetResource items as paginated response with {@link PagedFlux}.
+ */
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux listAssetResourceAsync(RequestOptions requestOptions) {
+ RequestOptions requestOptionsForNextPage = new RequestOptions();
+ requestOptionsForNextPage.setContext(
+ requestOptions != null && requestOptions.getContext() != null
+ ? requestOptions.getContext()
+ : Context.NONE);
+ return new PagedFlux<>(
+ () -> listAssetResourceSinglePageAsync(requestOptions),
+ nextLink -> listAssetResourceNextSinglePageAsync(nextLink, requestOptionsForNextPage));
+ }
+
+ /**
+ * Retrieve a list of assets for the provided search parameters.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
filter
String
No
Filter the result list using the given expression.
+ *
orderby
String
No
A list of expressions that specify the order of the returned resources.
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
mark
String
No
Specify this value instead of 'skip' to use cursor-based searching. Initial value is '*' and subsequent values are returned in the response.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return paged collection of AssetResource items as paginated response with {@link PagedIterable}.
+ */
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public CountPagedIterable listAssetResource(RequestOptions requestOptions) {
+ RequestOptions requestOptionsForNextPage = new RequestOptions();
+ requestOptionsForNextPage.setContext(
+ requestOptions != null && requestOptions.getContext() != null
+ ? requestOptions.getContext()
+ : Context.NONE);
+ return new CountPagedIterable<>(
+ () -> listAssetResourceSinglePage(requestOptions),
+ nextLink -> listAssetResourceNextSinglePage(nextLink, requestOptionsForNextPage));
+ }
+
+ /**
+ * Update labels on assets matching the provided filter.
+ *
+ *
+ *
+ * @param filter An expression on the resource type that selects the resources to be returned.
+ * @param assetUpdateData A request body used to update an asset.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response} on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> updateAssetsWithResponseAsync(
+ String filter, BinaryData assetUpdateData, RequestOptions requestOptions) {
+ final String accept = "application/json";
+ return FluxUtil.withContext(
+ context ->
+ service.updateAssets(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ filter,
+ accept,
+ assetUpdateData,
+ requestOptions,
+ context));
+ }
+
+ /**
+ * Update labels on assets matching the provided filter.
+ *
+ *
+ *
+ * @param filter An expression on the resource type that selects the resources to be returned.
+ * @param assetUpdateData A request body used to update an asset.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response updateAssetsWithResponse(
+ String filter, BinaryData assetUpdateData, RequestOptions requestOptions) {
+ final String accept = "application/json";
+ return service.updateAssetsSync(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ filter,
+ accept,
+ assetUpdateData,
+ requestOptions,
+ Context.NONE);
+ }
+
+ /**
+ * Retrieve an asset by assetId.
+ *
+ *
+ *
+ * @param assetId The system generated unique id for the resource.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the items in the current page of results along with {@link Response} on successful completion of {@link
+ * Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> getAssetResourceWithResponseAsync(String assetId, RequestOptions requestOptions) {
+ final String accept = "application/json";
+ return FluxUtil.withContext(
+ context ->
+ service.getAssetResource(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ assetId,
+ accept,
+ requestOptions,
+ context));
+ }
+
+ /**
+ * Retrieve an asset by assetId.
+ *
+ *
+ *
+ * @param assetId The system generated unique id for the resource.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the items in the current page of results along with {@link Response}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response getAssetResourceWithResponse(String assetId, RequestOptions requestOptions) {
+ final String accept = "application/json";
+ return service.getAssetResourceSync(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ assetId,
+ accept,
+ requestOptions,
+ Context.NONE);
+ }
+
+ /**
+ * Retrieve a list of data connections.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return paged collection of DataConnection items along with {@link PagedResponse} on successful completion of
+ * {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private Mono> listDataConnectionSinglePageAsync(RequestOptions requestOptions) {
+ final String accept = "application/json";
+ return FluxUtil.withContext(
+ context ->
+ service.listDataConnection(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ accept,
+ requestOptions,
+ context))
+ .map(
+ res ->
+ new PagedResponseBase<>(
+ res.getRequest(),
+ res.getStatusCode(),
+ res.getHeaders(),
+ getValues(res.getValue(), "value"),
+ getNextLink(res.getValue(), "nextLink"),
+ null));
+ }
+
+ /**
+ * Retrieve a list of data connections.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return paged collection of DataConnection items as paginated response with {@link PagedFlux}.
+ */
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux listDataConnectionAsync(RequestOptions requestOptions) {
+ RequestOptions requestOptionsForNextPage = new RequestOptions();
+ requestOptionsForNextPage.setContext(
+ requestOptions != null && requestOptions.getContext() != null
+ ? requestOptions.getContext()
+ : Context.NONE);
+ return new PagedFlux<>(
+ () -> listDataConnectionSinglePageAsync(requestOptions),
+ nextLink -> listDataConnectionNextSinglePageAsync(nextLink, requestOptionsForNextPage));
+ }
+
+ /**
+ * Retrieve a list of data connections.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return paged collection of DataConnection items along with {@link PagedResponse}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private CountPagedResponse listDataConnectionSinglePage(RequestOptions requestOptions) {
+ final String accept = "application/json";
+ Response res =
+ service.listDataConnectionSync(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ accept,
+ requestOptions,
+ Context.NONE);
+ return new CountPagedResponse<>(
+ res.getRequest(),
+ res.getStatusCode(),
+ res.getHeaders(),
+ getValues(res.getValue(), "value").stream().map(x -> cleanUp(x).toObject(DataConnection.class)).collect(Collectors.toList()),
+ getNextLink(res.getValue(), "nextLink"),
+ null, cleanUp(res.getValue()).toObject(DataConnectionPageResult.class).getTotalElements());
+ }
+
+ /**
+ * Retrieve a list of data connections.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return paged collection of DataConnection items as paginated response with {@link PagedIterable}.
+ */
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public CountPagedIterable listDataConnection(RequestOptions requestOptions) {
+ RequestOptions requestOptionsForNextPage = new RequestOptions();
+ requestOptionsForNextPage.setContext(
+ requestOptions != null && requestOptions.getContext() != null
+ ? requestOptions.getContext()
+ : Context.NONE);
+ return new CountPagedIterable<>(
+ () -> listDataConnectionSinglePage(requestOptions),
+ nextLink -> listDataConnectionNextSinglePage(nextLink, requestOptionsForNextPage));
+ }
+
+ /**
+ * Validate a data connection with a given dataConnectionName.
+ *
+ *
+ *
+ * @param dataConnectionData The dataConnectionData parameter.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response} on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> validateDataConnectionWithResponseAsync(
+ BinaryData dataConnectionData, RequestOptions requestOptions) {
+ final String accept = "application/json";
+ return FluxUtil.withContext(
+ context ->
+ service.validateDataConnection(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ accept,
+ dataConnectionData,
+ requestOptions,
+ context));
+ }
+
+ /**
+ * Validate a data connection with a given dataConnectionName.
+ *
+ *
+ *
+ * @param dataConnectionData The dataConnectionData parameter.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response validateDataConnectionWithResponse(
+ BinaryData dataConnectionData, RequestOptions requestOptions) {
+ final String accept = "application/json";
+ return service.validateDataConnectionSync(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ accept,
+ dataConnectionData,
+ requestOptions,
+ Context.NONE);
+ }
+
+ /**
+ * Retrieve a data connection with a given dataConnectionName.
+ *
+ *
+ *
+ * @param dataConnectionName The caller provided unique name for the resource.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response} on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> getDataConnectionWithResponseAsync(
+ String dataConnectionName, RequestOptions requestOptions) {
+ final String accept = "application/json";
+ return FluxUtil.withContext(
+ context ->
+ service.getDataConnection(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ dataConnectionName,
+ accept,
+ requestOptions,
+ context));
+ }
+
+ /**
+ * Retrieve a data connection with a given dataConnectionName.
+ *
+ *
+ *
+ * @param dataConnectionName The caller provided unique name for the resource.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response getDataConnectionWithResponse(
+ String dataConnectionName, RequestOptions requestOptions) {
+ final String accept = "application/json";
+ return service.getDataConnectionSync(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ dataConnectionName,
+ accept,
+ requestOptions,
+ Context.NONE);
+ }
+
+ /**
+ * Create or update a data connection with a given dataConnectionName.
+ *
+ *
+ *
+ * @param dataConnectionName The caller provided unique name for the resource.
+ * @param dataConnectionData The dataConnectionData parameter.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response} on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> putDataConnectionWithResponseAsync(
+ String dataConnectionName, BinaryData dataConnectionData, RequestOptions requestOptions) {
+ final String accept = "application/json";
+ return FluxUtil.withContext(
+ context ->
+ service.putDataConnection(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ dataConnectionName,
+ accept,
+ dataConnectionData,
+ requestOptions,
+ context));
+ }
+
+ /**
+ * Create or update a data connection with a given dataConnectionName.
+ *
+ *
+ *
+ * @param dataConnectionName The caller provided unique name for the resource.
+ * @param dataConnectionData The dataConnectionData parameter.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response putDataConnectionWithResponse(
+ String dataConnectionName, BinaryData dataConnectionData, RequestOptions requestOptions) {
+ final String accept = "application/json";
+ return service.putDataConnectionSync(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ dataConnectionName,
+ accept,
+ dataConnectionData,
+ requestOptions,
+ Context.NONE);
+ }
+
+ /**
+ * Delete a data connection with a given dataConnectionName.
+ *
+ * @param dataConnectionName The caller provided unique name for the resource.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the {@link Response} on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> deleteDataConnectionWithResponseAsync(
+ String dataConnectionName, RequestOptions requestOptions) {
+ final String accept = "application/json";
+ return FluxUtil.withContext(
+ context ->
+ service.deleteDataConnection(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ dataConnectionName,
+ accept,
+ requestOptions,
+ context));
+ }
+
+ /**
+ * Delete a data connection with a given dataConnectionName.
+ *
+ * @param dataConnectionName The caller provided unique name for the resource.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the {@link Response}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response deleteDataConnectionWithResponse(String dataConnectionName, RequestOptions requestOptions) {
+ final String accept = "application/json";
+ return service.deleteDataConnectionSync(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ dataConnectionName,
+ accept,
+ requestOptions,
+ Context.NONE);
+ }
+
+ /**
+ * Retrieve a list of discovery group for the provided search parameters.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
filter
String
No
Filter the result list using the given expression.
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return paged collection of DiscoGroup items along with {@link PagedResponse} on successful completion of {@link
+ * Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private Mono> listDiscoGroupSinglePageAsync(RequestOptions requestOptions) {
+ final String accept = "application/json";
+ return FluxUtil.withContext(
+ context ->
+ service.listDiscoGroup(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ accept,
+ requestOptions,
+ context))
+ .map(
+ res ->
+ new PagedResponseBase<>(
+ res.getRequest(),
+ res.getStatusCode(),
+ res.getHeaders(),
+ getValues(res.getValue(), "value"),
+ getNextLink(res.getValue(), "nextLink"),
+ null));
+ }
+
+ /**
+ * Retrieve a list of discovery group for the provided search parameters.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
filter
String
No
Filter the result list using the given expression.
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return paged collection of DiscoGroup items as paginated response with {@link PagedFlux}.
+ */
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux listDiscoGroupAsync(RequestOptions requestOptions) {
+ RequestOptions requestOptionsForNextPage = new RequestOptions();
+ requestOptionsForNextPage.setContext(
+ requestOptions != null && requestOptions.getContext() != null
+ ? requestOptions.getContext()
+ : Context.NONE);
+ return new PagedFlux<>(
+ () -> listDiscoGroupSinglePageAsync(requestOptions),
+ nextLink -> listDiscoGroupNextSinglePageAsync(nextLink, requestOptionsForNextPage));
+ }
+
+ /**
+ * Retrieve a list of discovery group for the provided search parameters.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
filter
String
No
Filter the result list using the given expression.
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return paged collection of DiscoGroup items along with {@link PagedResponse}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private CountPagedResponse listDiscoGroupSinglePage(RequestOptions requestOptions) {
+ final String accept = "application/json";
+ Response res =
+ service.listDiscoGroupSync(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ accept,
+ requestOptions,
+ Context.NONE);
+
+// return new PagedResponseBase(
+// res.getRequest(),
+// res.getStatusCode(),
+// res.getHeaders(),
+// getValues(res.getValue(), "value").stream().map(x -> x.toObject(DiscoGroup.class)).collect(Collectors.toList()),
+// getNextLink(res.getValue(), "nextLink"),
+// null);
+
+ return new CountPagedResponse<>(
+ res.getRequest(),
+ res.getStatusCode(),
+ res.getHeaders(),
+ getValues(res.getValue(), "value").stream().map(x -> cleanUp(x).toObject(DiscoGroup.class)).collect(Collectors.toList()),
+ getNextLink(res.getValue(), "nextLink"),
+ null, cleanUp(res.getValue()).toObject(DiscoGroupPageResult.class).getTotalElements());
+ }
+
+ /**
+ * Retrieve a list of discovery group for the provided search parameters.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
filter
String
No
Filter the result list using the given expression.
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return paged collection of DiscoGroup items as paginated response with {@link PagedIterable}.
+ */
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public CountPagedIterable listDiscoGroup(RequestOptions requestOptions) {
+ RequestOptions requestOptionsForNextPage = new RequestOptions();
+ requestOptionsForNextPage.setContext(
+ requestOptions != null && requestOptions.getContext() != null
+ ? requestOptions.getContext()
+ : Context.NONE);
+ return new CountPagedIterable(
+ () -> listDiscoGroupSinglePage(requestOptions),
+ nextLink -> listDiscoGroupNextSinglePage(nextLink, requestOptionsForNextPage));
+// return new DiscoGroupPageIterable(
+// () -> listDiscoGroup(new RequestOptions()),
+// nextLink -> listDiscoGroup(new RequestOptions().)
+// )
+ }
+
+ /**
+ * Validate a discovery group with a given groupName.
+ *
+ *
+ *
+ * @param discoGroupData A request body used to create a discovery group.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response} on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> validateDiscoGroupWithResponseAsync(
+ BinaryData discoGroupData, RequestOptions requestOptions) {
+ final String accept = "application/json";
+ return FluxUtil.withContext(
+ context ->
+ service.validateDiscoGroup(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ accept,
+ discoGroupData,
+ requestOptions,
+ context));
+ }
+
+ /**
+ * Validate a discovery group with a given groupName.
+ *
+ *
+ *
+ * @param discoGroupData A request body used to create a discovery group.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response validateDiscoGroupWithResponse(
+ BinaryData discoGroupData, RequestOptions requestOptions) {
+ final String accept = "application/json";
+ return service.validateDiscoGroupSync(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ accept,
+ discoGroupData,
+ requestOptions,
+ Context.NONE);
+ }
+
+ /**
+ * Retrieve a discovery group with a given groupName.
+ *
+ *
+ *
+ * @param groupName The caller provided unique name for the resource.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response} on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> getDiscoGroupWithResponseAsync(String groupName, RequestOptions requestOptions) {
+ final String accept = "application/json";
+ return FluxUtil.withContext(
+ context ->
+ service.getDiscoGroup(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ groupName,
+ accept,
+ requestOptions,
+ context));
+ }
+
+ /**
+ * Retrieve a discovery group with a given groupName.
+ *
+ *
+ *
+ * @param groupName The caller provided unique name for the resource.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response getDiscoGroupWithResponse(String groupName, RequestOptions requestOptions) {
+ final String accept = "application/json";
+ return service.getDiscoGroupSync(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ groupName,
+ accept,
+ requestOptions,
+ Context.NONE);
+ }
+
+ /**
+ * Create a discovery group with a given groupName.
+ *
+ *
+ *
+ * @param groupName The caller provided unique name for the resource.
+ * @param discoGroupData A request body used to create a discovery group.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response} on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> putDiscoGroupWithResponseAsync(
+ String groupName, BinaryData discoGroupData, RequestOptions requestOptions) {
+ final String accept = "application/json";
+ return FluxUtil.withContext(
+ context ->
+ service.putDiscoGroup(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ groupName,
+ accept,
+ discoGroupData,
+ requestOptions,
+ context));
+ }
+
+ /**
+ * Create a discovery group with a given groupName.
+ *
+ *
+ *
+ * @param groupName The caller provided unique name for the resource.
+ * @param discoGroupData A request body used to create a discovery group.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response putDiscoGroupWithResponse(
+ String groupName, BinaryData discoGroupData, RequestOptions requestOptions) {
+ final String accept = "application/json";
+ return service.putDiscoGroupSync(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ groupName,
+ accept,
+ discoGroupData,
+ requestOptions,
+ Context.NONE);
+ }
+
+ /**
+ * Run a discovery group with a given groupName.
+ *
+ * @param groupName The caller provided unique name for the resource.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the {@link Response} on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> runDiscoGroupWithResponseAsync(String groupName, RequestOptions requestOptions) {
+ final String accept = "application/json";
+ return FluxUtil.withContext(
+ context ->
+ service.runDiscoGroup(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ groupName,
+ accept,
+ requestOptions,
+ context));
+ }
+
+ /**
+ * Run a discovery group with a given groupName.
+ *
+ * @param groupName The caller provided unique name for the resource.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the {@link Response}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Response runDiscoGroupWithResponse(String groupName, RequestOptions requestOptions) {
+ final String accept = "application/json";
+ return service.runDiscoGroupSync(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ groupName,
+ accept,
+ requestOptions,
+ Context.NONE);
+ }
+
+ /**
+ * Retrieve a collection of discovery run results for a discovery group with a given groupName.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
filter
String
No
Filter the result list using the given expression.
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param groupName The unique identifier for the discovery group.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response} on successful completion of {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> listRunsWithResponseAsync(String groupName, RequestOptions requestOptions) {
+ final String accept = "application/json";
+ return FluxUtil.withContext(
+ context ->
+ service.listRuns(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ groupName,
+ accept,
+ requestOptions,
+ context));
+ }
+
+ /**
+ * Retrieve a collection of discovery run results for a discovery group with a given groupName.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
filter
String
No
Filter the result list using the given expression.
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param groupName The unique identifier for the discovery group.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the response body along with {@link Response}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public CountPagedIterable listRunsWithResponse(String groupName, RequestOptions requestOptions) {
+// final String accept = "application/json";
+// return service.listRunsSync(
+// this.getEndpoint(),
+// this.getSubscriptionId(),
+// this.getResourceGroupName(),
+// this.getWorkspaceName(),
+// this.getServiceVersion().getVersion(),
+// groupName,
+// accept,
+// requestOptions,
+// Context.NONE);
+
+ RequestOptions requestOptionsForNextPage = new RequestOptions();
+ requestOptionsForNextPage.setContext(
+ requestOptions != null && requestOptions.getContext() != null
+ ? requestOptions.getContext()
+ : Context.NONE);
+ return new CountPagedIterable<>(
+ () -> listRunsSinglePage(groupName, requestOptions),
+ nextLink -> listRunsNextSinglePage(nextLink, requestOptionsForNextPage));
+ }
+
+ /**
+ * Retrieve a list of disco templates for the provided search parameters.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
filter
String
No
Filter the result list using the given expression.
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return paged collection of DiscoTemplate items along with {@link PagedResponse} on successful completion of
+ * {@link Mono}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private Mono> listDiscoTemplateSinglePageAsync(RequestOptions requestOptions) {
+ final String accept = "application/json";
+ return FluxUtil.withContext(
+ context ->
+ service.listDiscoTemplate(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ accept,
+ requestOptions,
+ context))
+ .map(
+ res ->
+ new PagedResponseBase<>(
+ res.getRequest(),
+ res.getStatusCode(),
+ res.getHeaders(),
+ getValues(res.getValue(), "value"),
+ getNextLink(res.getValue(), "nextLink"),
+ null));
+ }
+
+ /**
+ * Retrieve a list of disco templates for the provided search parameters.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
filter
String
No
Filter the result list using the given expression.
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return paged collection of DiscoTemplate items as paginated response with {@link PagedFlux}.
+ */
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux listDiscoTemplateAsync(RequestOptions requestOptions) {
+ RequestOptions requestOptionsForNextPage = new RequestOptions();
+ requestOptionsForNextPage.setContext(
+ requestOptions != null && requestOptions.getContext() != null
+ ? requestOptions.getContext()
+ : Context.NONE);
+ return new PagedFlux<>(
+ () -> listDiscoTemplateSinglePageAsync(requestOptions),
+ nextLink -> listDiscoTemplateNextSinglePageAsync(nextLink, requestOptionsForNextPage));
+ }
+
+ /**
+ * Retrieve a list of disco templates for the provided search parameters.
+ *
+ *
Query Parameters
+ *
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
filter
String
No
Filter the result list using the given expression.
+ *
skip
Integer
No
The number of result items to skip.
+ *
maxpagesize
Integer
No
The maximum number of result items per page.
+ *
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
+ *
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return paged collection of DiscoTemplate items along with {@link PagedResponse}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ private CountPagedResponse listDiscoTemplateSinglePage(RequestOptions requestOptions) {
+ final String accept = "application/json";
+ Response res =
+ service.listDiscoTemplateSync(
+ this.getEndpoint(),
+ this.getSubscriptionId(),
+ this.getResourceGroupName(),
+ this.getWorkspaceName(),
+ this.getServiceVersion().getVersion(),
+ accept,
+ requestOptions,
+ Context.NONE);
+ return new CountPagedResponse<>(
+ res.getRequest(),
+ res.getStatusCode(),
+ res.getHeaders(),
+ getValues(res.getValue(), "value").stream().map(x -> cleanUp(x).toObject(DiscoTemplate.class)).collect(Collectors.toList()),
+ getNextLink(res.getValue(), "nextLink"),
+ null, cleanUp(res.getValue()).toObject(DiscoTemplatePageResult.class).getTotalElements());
+ }
+
+ /**
+ * Retrieve a list of disco templates for the provided search parameters.
+ *
+ *