forked from Azure/azure-sdk-for-python
-
Notifications
You must be signed in to change notification settings - Fork 2
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
CodeGen from PR 14309 in Azure/azure-rest-api-specs
Adding backupUsageSummaries API in 2018-12-20 version[Passive stamp] (Azure#14309) * Adding backupUsageSummaries API in 2018-12-20 version[Passive stamp] * Adding example * Adding example * Adding default error response * Fixing operationId * Revert "Fixing operationId" This reverts commit f7327d7ebe465621808988d5fd32fda81255521d. * Fixing operationId for getbackupusageSummaries * Adding nextLink * Adding nextLink in definition * Update * Reverting nextLink
- Loading branch information
SDKAuto
committed
May 19, 2021
1 parent
fc6a51d
commit 0724236
Showing
8 changed files
with
277 additions
and
1 deletion.
There are no files selected for viewing
2 changes: 1 addition & 1 deletion
2
sdk/recoveryservices/azure-mgmt-recoveryservicesbackup/_meta.json
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
128 changes: 128 additions & 0 deletions
128
...zure/mgmt/recoveryservicesbackup/aio/operations/_backup_usage_summaries_crr_operations.py
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,128 @@ | ||
| # coding=utf-8 | ||
| # -------------------------------------------------------------------------- | ||
| # Copyright (c) Microsoft Corporation. All rights reserved. | ||
| # Licensed under the MIT License. See License.txt in the project root for license information. | ||
| # Code generated by Microsoft (R) AutoRest Code Generator. | ||
| # Changes may cause incorrect behavior and will be lost if the code is regenerated. | ||
| # -------------------------------------------------------------------------- | ||
| from typing import Any, AsyncIterable, Callable, Dict, Generic, Optional, TypeVar | ||
| import warnings | ||
|
|
||
| from azure.core.async_paging import AsyncItemPaged, AsyncList | ||
| from azure.core.exceptions import ClientAuthenticationError, HttpResponseError, ResourceExistsError, ResourceNotFoundError, map_error | ||
| from azure.core.pipeline import PipelineResponse | ||
| from azure.core.pipeline.transport import AsyncHttpResponse, HttpRequest | ||
| from azure.mgmt.core.exceptions import ARMErrorFormat | ||
|
|
||
| from ... import models as _models | ||
|
|
||
| T = TypeVar('T') | ||
| ClsType = Optional[Callable[[PipelineResponse[HttpRequest, AsyncHttpResponse], T, Dict[str, Any]], Any]] | ||
|
|
||
| class BackupUsageSummariesCRROperations: | ||
| """BackupUsageSummariesCRROperations async operations. | ||
| You should not instantiate this class directly. Instead, you should create a Client instance that | ||
| instantiates it for you and attaches it as an attribute. | ||
| :ivar models: Alias to model classes used in this operation group. | ||
| :type models: ~azure.mgmt.recoveryservicesbackup.models | ||
| :param client: Client for service requests. | ||
| :param config: Configuration of service client. | ||
| :param serializer: An object model serializer. | ||
| :param deserializer: An object model deserializer. | ||
| """ | ||
|
|
||
| models = _models | ||
|
|
||
| def __init__(self, client, config, serializer, deserializer) -> None: | ||
| self._client = client | ||
| self._serialize = serializer | ||
| self._deserialize = deserializer | ||
| self._config = config | ||
|
|
||
| def list( | ||
| self, | ||
| vault_name: str, | ||
| resource_group_name: str, | ||
| filter: Optional[str] = None, | ||
| skip_token: Optional[str] = None, | ||
| **kwargs | ||
| ) -> AsyncIterable["_models.BackupManagementUsageList"]: | ||
| """Fetches the backup management usage summaries of the vault. | ||
| :param vault_name: The name of the recovery services vault. | ||
| :type vault_name: str | ||
| :param resource_group_name: The name of the resource group where the recovery services vault is | ||
| present. | ||
| :type resource_group_name: str | ||
| :param filter: OData filter options. | ||
| :type filter: str | ||
| :param skip_token: skipToken Filter. | ||
| :type skip_token: str | ||
| :keyword callable cls: A custom type or function that will be passed the direct response | ||
| :return: An iterator like instance of either BackupManagementUsageList or the result of cls(response) | ||
| :rtype: ~azure.core.async_paging.AsyncItemPaged[~azure.mgmt.recoveryservicesbackup.models.BackupManagementUsageList] | ||
| :raises: ~azure.core.exceptions.HttpResponseError | ||
| """ | ||
| cls = kwargs.pop('cls', None) # type: ClsType["_models.BackupManagementUsageList"] | ||
| error_map = { | ||
| 401: ClientAuthenticationError, 404: ResourceNotFoundError, 409: ResourceExistsError | ||
| } | ||
| error_map.update(kwargs.pop('error_map', {})) | ||
| api_version = "2018-12-20" | ||
| accept = "application/json" | ||
|
|
||
| def prepare_request(next_link=None): | ||
| # Construct headers | ||
| header_parameters = {} # type: Dict[str, Any] | ||
| header_parameters['Accept'] = self._serialize.header("accept", accept, 'str') | ||
|
|
||
| if not next_link: | ||
| # Construct URL | ||
| url = self.list.metadata['url'] # type: ignore | ||
| path_format_arguments = { | ||
| 'vaultName': self._serialize.url("vault_name", vault_name, 'str'), | ||
| 'resourceGroupName': self._serialize.url("resource_group_name", resource_group_name, 'str'), | ||
| 'subscriptionId': self._serialize.url("self._config.subscription_id", self._config.subscription_id, 'str'), | ||
| } | ||
| url = self._client.format_url(url, **path_format_arguments) | ||
| # Construct parameters | ||
| query_parameters = {} # type: Dict[str, Any] | ||
| query_parameters['api-version'] = self._serialize.query("api_version", api_version, 'str') | ||
| if filter is not None: | ||
| query_parameters['$filter'] = self._serialize.query("filter", filter, 'str') | ||
| if skip_token is not None: | ||
| query_parameters['$skipToken'] = self._serialize.query("skip_token", skip_token, 'str') | ||
|
|
||
| request = self._client.get(url, query_parameters, header_parameters) | ||
| else: | ||
| url = next_link | ||
| query_parameters = {} # type: Dict[str, Any] | ||
| request = self._client.get(url, query_parameters, header_parameters) | ||
| return request | ||
|
|
||
| async def extract_data(pipeline_response): | ||
| deserialized = self._deserialize('BackupManagementUsageList', pipeline_response) | ||
| list_of_elem = deserialized.value | ||
| if cls: | ||
| list_of_elem = cls(list_of_elem) | ||
| return None, AsyncList(list_of_elem) | ||
|
|
||
| async def get_next(next_link=None): | ||
| request = prepare_request(next_link) | ||
|
|
||
| pipeline_response = await self._client._pipeline.run(request, stream=False, **kwargs) | ||
| response = pipeline_response.http_response | ||
|
|
||
| if response.status_code not in [200]: | ||
| error = self._deserialize.failsafe_deserialize(_models.NewErrorResponseAutoGenerated, response) | ||
| map_error(status_code=response.status_code, response=response, error_map=error_map) | ||
| raise HttpResponseError(response=response, model=error, error_format=ARMErrorFormat) | ||
|
|
||
| return pipeline_response | ||
|
|
||
| return AsyncItemPaged( | ||
| get_next, extract_data | ||
| ) | ||
| list.metadata = {'url': '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.RecoveryServices/vaults/{vaultName}/backupUsageSummaries'} # type: ignore |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
133 changes: 133 additions & 0 deletions
133
...up/azure/mgmt/recoveryservicesbackup/operations/_backup_usage_summaries_crr_operations.py
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,133 @@ | ||
| # coding=utf-8 | ||
| # -------------------------------------------------------------------------- | ||
| # Copyright (c) Microsoft Corporation. All rights reserved. | ||
| # Licensed under the MIT License. See License.txt in the project root for license information. | ||
| # Code generated by Microsoft (R) AutoRest Code Generator. | ||
| # Changes may cause incorrect behavior and will be lost if the code is regenerated. | ||
| # -------------------------------------------------------------------------- | ||
| from typing import TYPE_CHECKING | ||
| import warnings | ||
|
|
||
| from azure.core.exceptions import ClientAuthenticationError, HttpResponseError, ResourceExistsError, ResourceNotFoundError, map_error | ||
| from azure.core.paging import ItemPaged | ||
| from azure.core.pipeline import PipelineResponse | ||
| from azure.core.pipeline.transport import HttpRequest, HttpResponse | ||
| from azure.mgmt.core.exceptions import ARMErrorFormat | ||
|
|
||
| from .. import models as _models | ||
|
|
||
| if TYPE_CHECKING: | ||
| # pylint: disable=unused-import,ungrouped-imports | ||
| from typing import Any, Callable, Dict, Generic, Iterable, Optional, TypeVar | ||
|
|
||
| T = TypeVar('T') | ||
| ClsType = Optional[Callable[[PipelineResponse[HttpRequest, HttpResponse], T, Dict[str, Any]], Any]] | ||
|
|
||
| class BackupUsageSummariesCRROperations(object): | ||
| """BackupUsageSummariesCRROperations operations. | ||
| You should not instantiate this class directly. Instead, you should create a Client instance that | ||
| instantiates it for you and attaches it as an attribute. | ||
| :ivar models: Alias to model classes used in this operation group. | ||
| :type models: ~azure.mgmt.recoveryservicesbackup.models | ||
| :param client: Client for service requests. | ||
| :param config: Configuration of service client. | ||
| :param serializer: An object model serializer. | ||
| :param deserializer: An object model deserializer. | ||
| """ | ||
|
|
||
| models = _models | ||
|
|
||
| def __init__(self, client, config, serializer, deserializer): | ||
| self._client = client | ||
| self._serialize = serializer | ||
| self._deserialize = deserializer | ||
| self._config = config | ||
|
|
||
| def list( | ||
| self, | ||
| vault_name, # type: str | ||
| resource_group_name, # type: str | ||
| filter=None, # type: Optional[str] | ||
| skip_token=None, # type: Optional[str] | ||
| **kwargs # type: Any | ||
| ): | ||
| # type: (...) -> Iterable["_models.BackupManagementUsageList"] | ||
| """Fetches the backup management usage summaries of the vault. | ||
| :param vault_name: The name of the recovery services vault. | ||
| :type vault_name: str | ||
| :param resource_group_name: The name of the resource group where the recovery services vault is | ||
| present. | ||
| :type resource_group_name: str | ||
| :param filter: OData filter options. | ||
| :type filter: str | ||
| :param skip_token: skipToken Filter. | ||
| :type skip_token: str | ||
| :keyword callable cls: A custom type or function that will be passed the direct response | ||
| :return: An iterator like instance of either BackupManagementUsageList or the result of cls(response) | ||
| :rtype: ~azure.core.paging.ItemPaged[~azure.mgmt.recoveryservicesbackup.models.BackupManagementUsageList] | ||
| :raises: ~azure.core.exceptions.HttpResponseError | ||
| """ | ||
| cls = kwargs.pop('cls', None) # type: ClsType["_models.BackupManagementUsageList"] | ||
| error_map = { | ||
| 401: ClientAuthenticationError, 404: ResourceNotFoundError, 409: ResourceExistsError | ||
| } | ||
| error_map.update(kwargs.pop('error_map', {})) | ||
| api_version = "2018-12-20" | ||
| accept = "application/json" | ||
|
|
||
| def prepare_request(next_link=None): | ||
| # Construct headers | ||
| header_parameters = {} # type: Dict[str, Any] | ||
| header_parameters['Accept'] = self._serialize.header("accept", accept, 'str') | ||
|
|
||
| if not next_link: | ||
| # Construct URL | ||
| url = self.list.metadata['url'] # type: ignore | ||
| path_format_arguments = { | ||
| 'vaultName': self._serialize.url("vault_name", vault_name, 'str'), | ||
| 'resourceGroupName': self._serialize.url("resource_group_name", resource_group_name, 'str'), | ||
| 'subscriptionId': self._serialize.url("self._config.subscription_id", self._config.subscription_id, 'str'), | ||
| } | ||
| url = self._client.format_url(url, **path_format_arguments) | ||
| # Construct parameters | ||
| query_parameters = {} # type: Dict[str, Any] | ||
| query_parameters['api-version'] = self._serialize.query("api_version", api_version, 'str') | ||
| if filter is not None: | ||
| query_parameters['$filter'] = self._serialize.query("filter", filter, 'str') | ||
| if skip_token is not None: | ||
| query_parameters['$skipToken'] = self._serialize.query("skip_token", skip_token, 'str') | ||
|
|
||
| request = self._client.get(url, query_parameters, header_parameters) | ||
| else: | ||
| url = next_link | ||
| query_parameters = {} # type: Dict[str, Any] | ||
| request = self._client.get(url, query_parameters, header_parameters) | ||
| return request | ||
|
|
||
| def extract_data(pipeline_response): | ||
| deserialized = self._deserialize('BackupManagementUsageList', pipeline_response) | ||
| list_of_elem = deserialized.value | ||
| if cls: | ||
| list_of_elem = cls(list_of_elem) | ||
| return None, iter(list_of_elem) | ||
|
|
||
| def get_next(next_link=None): | ||
| request = prepare_request(next_link) | ||
|
|
||
| pipeline_response = self._client._pipeline.run(request, stream=False, **kwargs) | ||
| response = pipeline_response.http_response | ||
|
|
||
| if response.status_code not in [200]: | ||
| error = self._deserialize.failsafe_deserialize(_models.NewErrorResponseAutoGenerated, response) | ||
| map_error(status_code=response.status_code, response=response, error_map=error_map) | ||
| raise HttpResponseError(response=response, model=error, error_format=ARMErrorFormat) | ||
|
|
||
| return pipeline_response | ||
|
|
||
| return ItemPaged( | ||
| get_next, extract_data | ||
| ) | ||
| list.metadata = {'url': '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.RecoveryServices/vaults/{vaultName}/backupUsageSummaries'} # type: ignore |