Skip to content

Commit

Permalink
CodeGen from PR 16890 in Azure/azure-rest-api-specs
Browse files Browse the repository at this point in the history
Merge 57b7de2f954574c7e5325db0693ebc87285358ea into 3c5135f
  • Loading branch information
SDKAuto committed Dec 2, 2021
1 parent 46fa4a7 commit b0dc5b0
Show file tree
Hide file tree
Showing 68 changed files with 2,314 additions and 272 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
"@autorest/[email protected]",
"@autorest/[email protected]"
],
"commit": "4cec1770664631fced06a1d83d79ebc3d2ca74db",
"commit": "ca977d765d09f981708510fae8cd6d4b1453e470",
"repository_url": "https://github.com/Azure/azure-rest-api-specs",
"autorest_command": "autorest specification/recoveryservicessiterecovery/resource-manager/readme.md --multiapi --python --python-mode=update --python-sdks-folder=/home/vsts/work/1/s/azure-sdk-for-python/sdk --track2 --use=@autorest/[email protected] --use=@autorest/[email protected] --version=3.4.5",
"readme": "specification/recoveryservicessiterecovery/resource-manager/readme.md"
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@ def __init__(
self.subscription_id = subscription_id
self.resource_group_name = resource_group_name
self.resource_name = resource_name
self.api_version = "2021-06-01"
self.api_version = "2021-11-01"
self.credential_scopes = kwargs.pop('credential_scopes', ['https://management.azure.com/.default'])
kwargs.setdefault('sdk_moniker', 'mgmt-recoveryservicessiterecovery/{}'.format(VERSION))
self._configure(**kwargs)
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"chosen_version": "2021-06-01",
"total_api_version_list": ["2021-06-01"],
"chosen_version": "2021-11-01",
"total_api_version_list": ["2021-11-01"],
"client": {
"name": "SiteRecoveryManagementClient",
"filename": "_site_recovery_management_client",
Expand Down Expand Up @@ -124,6 +124,7 @@
"operation_groups": {
"operations": "Operations",
"replication_alert_settings": "ReplicationAlertSettingsOperations",
"replication_appliances": "ReplicationAppliancesOperations",
"replication_eligibility_results": "ReplicationEligibilityResultsOperations",
"replication_events": "ReplicationEventsOperations",
"replication_fabrics": "ReplicationFabricsOperations",
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,6 +21,7 @@
from ._configuration import SiteRecoveryManagementClientConfiguration
from .operations import Operations
from .operations import ReplicationAlertSettingsOperations
from .operations import ReplicationAppliancesOperations
from .operations import ReplicationEligibilityResultsOperations
from .operations import ReplicationEventsOperations
from .operations import ReplicationFabricsOperations
Expand Down Expand Up @@ -56,6 +57,8 @@ class SiteRecoveryManagementClient(object):
:vartype operations: azure.mgmt.recoveryservicessiterecovery.operations.Operations
:ivar replication_alert_settings: ReplicationAlertSettingsOperations operations
:vartype replication_alert_settings: azure.mgmt.recoveryservicessiterecovery.operations.ReplicationAlertSettingsOperations
:ivar replication_appliances: ReplicationAppliancesOperations operations
:vartype replication_appliances: azure.mgmt.recoveryservicessiterecovery.operations.ReplicationAppliancesOperations
:ivar replication_eligibility_results: ReplicationEligibilityResultsOperations operations
:vartype replication_eligibility_results: azure.mgmt.recoveryservicessiterecovery.operations.ReplicationEligibilityResultsOperations
:ivar replication_events: ReplicationEventsOperations operations
Expand Down Expand Up @@ -142,6 +145,8 @@ def __init__(
self._client, self._config, self._serialize, self._deserialize)
self.replication_alert_settings = ReplicationAlertSettingsOperations(
self._client, self._config, self._serialize, self._deserialize)
self.replication_appliances = ReplicationAppliancesOperations(
self._client, self._config, self._serialize, self._deserialize)
self.replication_eligibility_results = ReplicationEligibilityResultsOperations(
self._client, self._config, self._serialize, self._deserialize)
self.replication_events = ReplicationEventsOperations(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@ def __init__(
self.subscription_id = subscription_id
self.resource_group_name = resource_group_name
self.resource_name = resource_name
self.api_version = "2021-06-01"
self.api_version = "2021-11-01"
self.credential_scopes = kwargs.pop('credential_scopes', ['https://management.azure.com/.default'])
kwargs.setdefault('sdk_moniker', 'mgmt-recoveryservicessiterecovery/{}'.format(VERSION))
self._configure(**kwargs)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,7 @@
from ._configuration import SiteRecoveryManagementClientConfiguration
from .operations import Operations
from .operations import ReplicationAlertSettingsOperations
from .operations import ReplicationAppliancesOperations
from .operations import ReplicationEligibilityResultsOperations
from .operations import ReplicationEventsOperations
from .operations import ReplicationFabricsOperations
Expand Down Expand Up @@ -54,6 +55,8 @@ class SiteRecoveryManagementClient(object):
:vartype operations: azure.mgmt.recoveryservicessiterecovery.aio.operations.Operations
:ivar replication_alert_settings: ReplicationAlertSettingsOperations operations
:vartype replication_alert_settings: azure.mgmt.recoveryservicessiterecovery.aio.operations.ReplicationAlertSettingsOperations
:ivar replication_appliances: ReplicationAppliancesOperations operations
:vartype replication_appliances: azure.mgmt.recoveryservicessiterecovery.aio.operations.ReplicationAppliancesOperations
:ivar replication_eligibility_results: ReplicationEligibilityResultsOperations operations
:vartype replication_eligibility_results: azure.mgmt.recoveryservicessiterecovery.aio.operations.ReplicationEligibilityResultsOperations
:ivar replication_events: ReplicationEventsOperations operations
Expand Down Expand Up @@ -139,6 +142,8 @@ def __init__(
self._client, self._config, self._serialize, self._deserialize)
self.replication_alert_settings = ReplicationAlertSettingsOperations(
self._client, self._config, self._serialize, self._deserialize)
self.replication_appliances = ReplicationAppliancesOperations(
self._client, self._config, self._serialize, self._deserialize)
self.replication_eligibility_results = ReplicationEligibilityResultsOperations(
self._client, self._config, self._serialize, self._deserialize)
self.replication_events = ReplicationEventsOperations(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@

from ._operations import Operations
from ._replication_alert_settings_operations import ReplicationAlertSettingsOperations
from ._replication_appliances_operations import ReplicationAppliancesOperations
from ._replication_eligibility_results_operations import ReplicationEligibilityResultsOperations
from ._replication_events_operations import ReplicationEventsOperations
from ._replication_fabrics_operations import ReplicationFabricsOperations
Expand Down Expand Up @@ -37,6 +38,7 @@
__all__ = [
'Operations',
'ReplicationAlertSettingsOperations',
'ReplicationAppliancesOperations',
'ReplicationEligibilityResultsOperations',
'ReplicationEventsOperations',
'ReplicationFabricsOperations',
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,7 @@ def list_by_replication_migration_items(
401: ClientAuthenticationError, 404: ResourceNotFoundError, 409: ResourceExistsError
}
error_map.update(kwargs.pop('error_map', {}))
api_version = "2021-06-01"
api_version = "2021-11-01"
accept = "application/json"

def prepare_request(next_link=None):
Expand Down Expand Up @@ -153,7 +153,7 @@ async def get(
401: ClientAuthenticationError, 404: ResourceNotFoundError, 409: ResourceExistsError
}
error_map.update(kwargs.pop('error_map', {}))
api_version = "2021-06-01"
api_version = "2021-11-01"
accept = "application/json"

# Construct URL
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -59,7 +59,7 @@ def list(
401: ClientAuthenticationError, 404: ResourceNotFoundError, 409: ResourceExistsError
}
error_map.update(kwargs.pop('error_map', {}))
api_version = "2021-06-01"
api_version = "2021-11-01"
accept = "application/json"

def prepare_request(next_link=None):
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,7 @@ def list_by_replication_protected_items(
401: ClientAuthenticationError, 404: ResourceNotFoundError, 409: ResourceExistsError
}
error_map.update(kwargs.pop('error_map', {}))
api_version = "2021-06-01"
api_version = "2021-11-01"
accept = "application/json"

def prepare_request(next_link=None):
Expand Down Expand Up @@ -153,7 +153,7 @@ async def get(
401: ClientAuthenticationError, 404: ResourceNotFoundError, 409: ResourceExistsError
}
error_map.update(kwargs.pop('error_map', {}))
api_version = "2021-06-01"
api_version = "2021-11-01"
accept = "application/json"

# Construct URL
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -59,7 +59,7 @@ def list(
401: ClientAuthenticationError, 404: ResourceNotFoundError, 409: ResourceExistsError
}
error_map.update(kwargs.pop('error_map', {}))
api_version = "2021-06-01"
api_version = "2021-11-01"
accept = "application/json"

def prepare_request(next_link=None):
Expand Down Expand Up @@ -132,7 +132,7 @@ async def get(
401: ClientAuthenticationError, 404: ResourceNotFoundError, 409: ResourceExistsError
}
error_map.update(kwargs.pop('error_map', {}))
api_version = "2021-06-01"
api_version = "2021-11-01"
accept = "application/json"

# Construct URL
Expand Down Expand Up @@ -193,7 +193,7 @@ async def create(
401: ClientAuthenticationError, 404: ResourceNotFoundError, 409: ResourceExistsError
}
error_map.update(kwargs.pop('error_map', {}))
api_version = "2021-06-01"
api_version = "2021-11-01"
content_type = kwargs.pop("content_type", "application/json")
accept = "application/json"

Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,117 @@
# 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 ReplicationAppliancesOperations:
"""ReplicationAppliancesOperations 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.recoveryservicessiterecovery.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,
filter: Optional[str] = None,
**kwargs: Any
) -> AsyncIterable["_models.ApplianceCollection"]:
"""Gets the list of appliances.
Gets the list of Azure Site Recovery appliances for the vault.
:param filter: OData filter options.
:type filter: str
:keyword callable cls: A custom type or function that will be passed the direct response
:return: An iterator like instance of either ApplianceCollection or the result of cls(response)
:rtype: ~azure.core.async_paging.AsyncItemPaged[~azure.mgmt.recoveryservicessiterecovery.models.ApplianceCollection]
:raises: ~azure.core.exceptions.HttpResponseError
"""
cls = kwargs.pop('cls', None) # type: ClsType["_models.ApplianceCollection"]
error_map = {
401: ClientAuthenticationError, 404: ResourceNotFoundError, 409: ResourceExistsError
}
error_map.update(kwargs.pop('error_map', {}))
api_version = "2021-11-01"
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 = {
'resourceName': self._serialize.url("self._config.resource_name", self._config.resource_name, 'str'),
'resourceGroupName': self._serialize.url("self._config.resource_group_name", self._config.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')

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('ApplianceCollection', pipeline_response)
list_of_elem = deserialized.value
if cls:
list_of_elem = cls(list_of_elem)
return deserialized.next_link or 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]:
map_error(status_code=response.status_code, response=response, error_map=error_map)
raise HttpResponseError(response=response, error_format=ARMErrorFormat)

return pipeline_response

return AsyncItemPaged(
get_next, extract_data
)
list.metadata = {'url': '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.RecoveryServices/vaults/{resourceName}/replicationAppliances'} # type: ignore
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,7 @@ async def list(
401: ClientAuthenticationError, 404: ResourceNotFoundError, 409: ResourceExistsError
}
error_map.update(kwargs.pop('error_map', {}))
api_version = "2021-06-01"
api_version = "2021-11-01"
accept = "application/json"

# Construct URL
Expand Down Expand Up @@ -118,7 +118,7 @@ async def get(
401: ClientAuthenticationError, 404: ResourceNotFoundError, 409: ResourceExistsError
}
error_map.update(kwargs.pop('error_map', {}))
api_version = "2021-06-01"
api_version = "2021-11-01"
accept = "application/json"

# Construct URL
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,7 @@ def list(
401: ClientAuthenticationError, 404: ResourceNotFoundError, 409: ResourceExistsError
}
error_map.update(kwargs.pop('error_map', {}))
api_version = "2021-06-01"
api_version = "2021-11-01"
accept = "application/json"

def prepare_request(next_link=None):
Expand Down Expand Up @@ -137,7 +137,7 @@ async def get(
401: ClientAuthenticationError, 404: ResourceNotFoundError, 409: ResourceExistsError
}
error_map.update(kwargs.pop('error_map', {}))
api_version = "2021-06-01"
api_version = "2021-11-01"
accept = "application/json"

# Construct URL
Expand Down
Loading

0 comments on commit b0dc5b0

Please sign in to comment.