Skip to content

Commit

Permalink
[AutoRelease] t2-eventhub-2021-10-25-83263 (Azure#21397)
Browse files Browse the repository at this point in the history
* CodeGen from PR 16363 in Azure/azure-rest-api-specs
EventHub : New API version 2021-11-01 (Azure#16363)

* base commit for new api version 2021-11-01

* new api version 2021-11-01 changes

* CI fixes

* CI fixes

* fix for Python SDK

* added common def v2

* avocado fix

* updated common types

* update to address S360

* S360 fix for DisasterRecoveryConfigs

* Revert "S360 fix for DisasterRecoveryConfigs"

This reverts commit 2476975abd304ee89f1382ceaee280ad3a711e15.

* Added SchemaRegistry API

* CI fixes - Schemagroup

* corrected Schemagroup group properties

* reverted the proxyresource location change

* Revert "reverted the proxyresource location change"

This reverts commit ac79e8a163198742f32adfdc40cc11aa2e039e90.

* addresing S360 swagger correctness fro operations and capture

* updated description for datalake in capture

* subscription format to uuid

Co-authored-by: Damodar Avadhani <davadhani@microsoft.com>
Co-authored-by: v-ajnava <v-ajnava@microsoft.com>

* version,CHANGELOG

* Update CHANGELOG.md

Co-authored-by: SDKAuto <sdkautomation@microsoft.com>
Co-authored-by: Damodar Avadhani <davadhani@microsoft.com>
Co-authored-by: v-ajnava <v-ajnava@microsoft.com>
Co-authored-by: PythonSdkPipelines <PythonSdkPipelines>
Co-authored-by: Jiefeng Chen <51037443+BigCat20196@users.noreply.github.com>
  • Loading branch information
5 people authored Nov 1, 2021
1 parent 4b79413 commit a644e1e
Show file tree
Hide file tree
Showing 54 changed files with 15,398 additions and 272 deletions.
29 changes: 28 additions & 1 deletion sdk/eventhub/azure-mgmt-eventhub/CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,32 @@
# Release History

## 10.0.0 (2021-11-01)

**Features**

- Model ErrorResponse has a new parameter error
- Model NetworkRuleSet has a new parameter location
- Model Eventhub has a new parameter location
- Model ConsumerGroup has a new parameter location
- Model ArmDisasterRecovery has a new parameter location
- Model Operation has a new parameter is_data_action
- Model Operation has a new parameter origin
- Model Operation has a new parameter properties
- Model PrivateEndpointConnection has a new parameter location
- Model Destination has a new parameter data_lake_account_name
- Model Destination has a new parameter data_lake_subscription_id
- Model Destination has a new parameter data_lake_folder_path
- Model EHNamespace has a new parameter alternate_name
- Model OperationDisplay has a new parameter description
- Model AuthorizationRule has a new parameter location
- Added operation NamespacesOperations.list_network_rule_set
- Added operation group SchemaRegistryOperations

**Breaking changes**

- Model ErrorResponse no longer has parameter message
- Model ErrorResponse no longer has parameter code

## 9.1.0 (2021-09-17)

**Features**
Expand Down Expand Up @@ -291,4 +318,4 @@ This wheel package is built with the azure wheel extension

## 0.1.0 (2016-10-27)

- Initial Release
- Initial Release
2 changes: 1 addition & 1 deletion sdk/eventhub/azure-mgmt-eventhub/_meta.json
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
"@autorest/python@5.8.4",
"@autorest/modelerfour@4.19.2"
],
"commit": "c9992af7235a6550087d4fed8f081ed35019f605",
"commit": "ea69fef496210478b8a9e2c3f8804f3acfb35891",
"repository_url": "https://github.com/Azure/azure-rest-api-specs",
"autorest_command": "autorest specification/eventhub/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/python@5.8.4 --use=@autorest/modelerfour@4.19.2 --version=3.4.5",
"readme": "specification/eventhub/resource-manager/readme.md"
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ def __init__(self, *args, **kwargs):
pass

class EventHubManagementClient(MultiApiClientMixin, _SDKClient):
"""Azure Event Hubs client.
"""Azure Event Hubs client for managing Event Hubs Cluster, IPFilter Rules and VirtualNetworkRules resources.
This ready contains multiple API versions, to help you deal with all of the Azure clouds
(Azure Stack, Azure Government, Azure China, etc.).
Expand All @@ -56,11 +56,12 @@ class EventHubManagementClient(MultiApiClientMixin, _SDKClient):
:keyword int polling_interval: Default waiting time between two polls for LRO operations if no Retry-After header is present.
"""

DEFAULT_API_VERSION = '2017-04-01'
DEFAULT_API_VERSION = '2021-11-01'
_PROFILE_TAG = "azure.mgmt.eventhub.EventHubManagementClient"
LATEST_PROFILE = ProfileDefinition({
_PROFILE_TAG: {
None: DEFAULT_API_VERSION,
'regions': '2017-04-01',
}},
_PROFILE_TAG + " latest"
)
Expand Down Expand Up @@ -96,6 +97,7 @@ def models(cls, api_version=DEFAULT_API_VERSION):
* 2018-01-01-preview: :mod:`v2018_01_01_preview.models<azure.mgmt.eventhub.v2018_01_01_preview.models>`
* 2021-01-01-preview: :mod:`v2021_01_01_preview.models<azure.mgmt.eventhub.v2021_01_01_preview.models>`
* 2021-06-01-preview: :mod:`v2021_06_01_preview.models<azure.mgmt.eventhub.v2021_06_01_preview.models>`
* 2021-11-01: :mod:`v2021_11_01.models<azure.mgmt.eventhub.v2021_11_01.models>`
"""
if api_version == '2015-08-01':
from .v2015_08_01 import models
Expand All @@ -112,6 +114,9 @@ def models(cls, api_version=DEFAULT_API_VERSION):
elif api_version == '2021-06-01-preview':
from .v2021_06_01_preview import models
return models
elif api_version == '2021-11-01':
from .v2021_11_01 import models
return models
raise ValueError("API version {} is not available".format(api_version))

@property
Expand All @@ -120,12 +125,15 @@ def clusters(self):
* 2018-01-01-preview: :class:`ClustersOperations<azure.mgmt.eventhub.v2018_01_01_preview.operations.ClustersOperations>`
* 2021-06-01-preview: :class:`ClustersOperations<azure.mgmt.eventhub.v2021_06_01_preview.operations.ClustersOperations>`
* 2021-11-01: :class:`ClustersOperations<azure.mgmt.eventhub.v2021_11_01.operations.ClustersOperations>`
"""
api_version = self._get_api_version('clusters')
if api_version == '2018-01-01-preview':
from .v2018_01_01_preview.operations import ClustersOperations as OperationClass
elif api_version == '2021-06-01-preview':
from .v2021_06_01_preview.operations import ClustersOperations as OperationClass
elif api_version == '2021-11-01':
from .v2021_11_01.operations import ClustersOperations as OperationClass
else:
raise ValueError("API version {} does not have operation group 'clusters'".format(api_version))
return OperationClass(self._client, self._config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
Expand All @@ -136,12 +144,15 @@ def configuration(self):
* 2018-01-01-preview: :class:`ConfigurationOperations<azure.mgmt.eventhub.v2018_01_01_preview.operations.ConfigurationOperations>`
* 2021-06-01-preview: :class:`ConfigurationOperations<azure.mgmt.eventhub.v2021_06_01_preview.operations.ConfigurationOperations>`
* 2021-11-01: :class:`ConfigurationOperations<azure.mgmt.eventhub.v2021_11_01.operations.ConfigurationOperations>`
"""
api_version = self._get_api_version('configuration')
if api_version == '2018-01-01-preview':
from .v2018_01_01_preview.operations import ConfigurationOperations as OperationClass
elif api_version == '2021-06-01-preview':
from .v2021_06_01_preview.operations import ConfigurationOperations as OperationClass
elif api_version == '2021-11-01':
from .v2021_11_01.operations import ConfigurationOperations as OperationClass
else:
raise ValueError("API version {} does not have operation group 'configuration'".format(api_version))
return OperationClass(self._client, self._config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
Expand All @@ -155,6 +166,7 @@ def consumer_groups(self):
* 2018-01-01-preview: :class:`ConsumerGroupsOperations<azure.mgmt.eventhub.v2018_01_01_preview.operations.ConsumerGroupsOperations>`
* 2021-01-01-preview: :class:`ConsumerGroupsOperations<azure.mgmt.eventhub.v2021_01_01_preview.operations.ConsumerGroupsOperations>`
* 2021-06-01-preview: :class:`ConsumerGroupsOperations<azure.mgmt.eventhub.v2021_06_01_preview.operations.ConsumerGroupsOperations>`
* 2021-11-01: :class:`ConsumerGroupsOperations<azure.mgmt.eventhub.v2021_11_01.operations.ConsumerGroupsOperations>`
"""
api_version = self._get_api_version('consumer_groups')
if api_version == '2015-08-01':
Expand All @@ -167,6 +179,8 @@ def consumer_groups(self):
from .v2021_01_01_preview.operations import ConsumerGroupsOperations as OperationClass
elif api_version == '2021-06-01-preview':
from .v2021_06_01_preview.operations import ConsumerGroupsOperations as OperationClass
elif api_version == '2021-11-01':
from .v2021_11_01.operations import ConsumerGroupsOperations as OperationClass
else:
raise ValueError("API version {} does not have operation group 'consumer_groups'".format(api_version))
return OperationClass(self._client, self._config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
Expand All @@ -179,6 +193,7 @@ def disaster_recovery_configs(self):
* 2018-01-01-preview: :class:`DisasterRecoveryConfigsOperations<azure.mgmt.eventhub.v2018_01_01_preview.operations.DisasterRecoveryConfigsOperations>`
* 2021-01-01-preview: :class:`DisasterRecoveryConfigsOperations<azure.mgmt.eventhub.v2021_01_01_preview.operations.DisasterRecoveryConfigsOperations>`
* 2021-06-01-preview: :class:`DisasterRecoveryConfigsOperations<azure.mgmt.eventhub.v2021_06_01_preview.operations.DisasterRecoveryConfigsOperations>`
* 2021-11-01: :class:`DisasterRecoveryConfigsOperations<azure.mgmt.eventhub.v2021_11_01.operations.DisasterRecoveryConfigsOperations>`
"""
api_version = self._get_api_version('disaster_recovery_configs')
if api_version == '2017-04-01':
Expand All @@ -189,6 +204,8 @@ def disaster_recovery_configs(self):
from .v2021_01_01_preview.operations import DisasterRecoveryConfigsOperations as OperationClass
elif api_version == '2021-06-01-preview':
from .v2021_06_01_preview.operations import DisasterRecoveryConfigsOperations as OperationClass
elif api_version == '2021-11-01':
from .v2021_11_01.operations import DisasterRecoveryConfigsOperations as OperationClass
else:
raise ValueError("API version {} does not have operation group 'disaster_recovery_configs'".format(api_version))
return OperationClass(self._client, self._config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
Expand All @@ -202,6 +219,7 @@ def event_hubs(self):
* 2018-01-01-preview: :class:`EventHubsOperations<azure.mgmt.eventhub.v2018_01_01_preview.operations.EventHubsOperations>`
* 2021-01-01-preview: :class:`EventHubsOperations<azure.mgmt.eventhub.v2021_01_01_preview.operations.EventHubsOperations>`
* 2021-06-01-preview: :class:`EventHubsOperations<azure.mgmt.eventhub.v2021_06_01_preview.operations.EventHubsOperations>`
* 2021-11-01: :class:`EventHubsOperations<azure.mgmt.eventhub.v2021_11_01.operations.EventHubsOperations>`
"""
api_version = self._get_api_version('event_hubs')
if api_version == '2015-08-01':
Expand All @@ -214,6 +232,8 @@ def event_hubs(self):
from .v2021_01_01_preview.operations import EventHubsOperations as OperationClass
elif api_version == '2021-06-01-preview':
from .v2021_06_01_preview.operations import EventHubsOperations as OperationClass
elif api_version == '2021-11-01':
from .v2021_11_01.operations import EventHubsOperations as OperationClass
else:
raise ValueError("API version {} does not have operation group 'event_hubs'".format(api_version))
return OperationClass(self._client, self._config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
Expand All @@ -227,6 +247,7 @@ def namespaces(self):
* 2018-01-01-preview: :class:`NamespacesOperations<azure.mgmt.eventhub.v2018_01_01_preview.operations.NamespacesOperations>`
* 2021-01-01-preview: :class:`NamespacesOperations<azure.mgmt.eventhub.v2021_01_01_preview.operations.NamespacesOperations>`
* 2021-06-01-preview: :class:`NamespacesOperations<azure.mgmt.eventhub.v2021_06_01_preview.operations.NamespacesOperations>`
* 2021-11-01: :class:`NamespacesOperations<azure.mgmt.eventhub.v2021_11_01.operations.NamespacesOperations>`
"""
api_version = self._get_api_version('namespaces')
if api_version == '2015-08-01':
Expand All @@ -239,6 +260,8 @@ def namespaces(self):
from .v2021_01_01_preview.operations import NamespacesOperations as OperationClass
elif api_version == '2021-06-01-preview':
from .v2021_06_01_preview.operations import NamespacesOperations as OperationClass
elif api_version == '2021-11-01':
from .v2021_11_01.operations import NamespacesOperations as OperationClass
else:
raise ValueError("API version {} does not have operation group 'namespaces'".format(api_version))
return OperationClass(self._client, self._config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
Expand All @@ -252,6 +275,7 @@ def operations(self):
* 2018-01-01-preview: :class:`Operations<azure.mgmt.eventhub.v2018_01_01_preview.operations.Operations>`
* 2021-01-01-preview: :class:`Operations<azure.mgmt.eventhub.v2021_01_01_preview.operations.Operations>`
* 2021-06-01-preview: :class:`Operations<azure.mgmt.eventhub.v2021_06_01_preview.operations.Operations>`
* 2021-11-01: :class:`Operations<azure.mgmt.eventhub.v2021_11_01.operations.Operations>`
"""
api_version = self._get_api_version('operations')
if api_version == '2015-08-01':
Expand All @@ -264,6 +288,8 @@ def operations(self):
from .v2021_01_01_preview.operations import Operations as OperationClass
elif api_version == '2021-06-01-preview':
from .v2021_06_01_preview.operations import Operations as OperationClass
elif api_version == '2021-11-01':
from .v2021_11_01.operations import Operations as OperationClass
else:
raise ValueError("API version {} does not have operation group 'operations'".format(api_version))
return OperationClass(self._client, self._config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
Expand All @@ -275,6 +301,7 @@ def private_endpoint_connections(self):
* 2018-01-01-preview: :class:`PrivateEndpointConnectionsOperations<azure.mgmt.eventhub.v2018_01_01_preview.operations.PrivateEndpointConnectionsOperations>`
* 2021-01-01-preview: :class:`PrivateEndpointConnectionsOperations<azure.mgmt.eventhub.v2021_01_01_preview.operations.PrivateEndpointConnectionsOperations>`
* 2021-06-01-preview: :class:`PrivateEndpointConnectionsOperations<azure.mgmt.eventhub.v2021_06_01_preview.operations.PrivateEndpointConnectionsOperations>`
* 2021-11-01: :class:`PrivateEndpointConnectionsOperations<azure.mgmt.eventhub.v2021_11_01.operations.PrivateEndpointConnectionsOperations>`
"""
api_version = self._get_api_version('private_endpoint_connections')
if api_version == '2018-01-01-preview':
Expand All @@ -283,6 +310,8 @@ def private_endpoint_connections(self):
from .v2021_01_01_preview.operations import PrivateEndpointConnectionsOperations as OperationClass
elif api_version == '2021-06-01-preview':
from .v2021_06_01_preview.operations import PrivateEndpointConnectionsOperations as OperationClass
elif api_version == '2021-11-01':
from .v2021_11_01.operations import PrivateEndpointConnectionsOperations as OperationClass
else:
raise ValueError("API version {} does not have operation group 'private_endpoint_connections'".format(api_version))
return OperationClass(self._client, self._config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
Expand All @@ -294,6 +323,7 @@ def private_link_resources(self):
* 2018-01-01-preview: :class:`PrivateLinkResourcesOperations<azure.mgmt.eventhub.v2018_01_01_preview.operations.PrivateLinkResourcesOperations>`
* 2021-01-01-preview: :class:`PrivateLinkResourcesOperations<azure.mgmt.eventhub.v2021_01_01_preview.operations.PrivateLinkResourcesOperations>`
* 2021-06-01-preview: :class:`PrivateLinkResourcesOperations<azure.mgmt.eventhub.v2021_06_01_preview.operations.PrivateLinkResourcesOperations>`
* 2021-11-01: :class:`PrivateLinkResourcesOperations<azure.mgmt.eventhub.v2021_11_01.operations.PrivateLinkResourcesOperations>`
"""
api_version = self._get_api_version('private_link_resources')
if api_version == '2018-01-01-preview':
Expand All @@ -302,6 +332,8 @@ def private_link_resources(self):
from .v2021_01_01_preview.operations import PrivateLinkResourcesOperations as OperationClass
elif api_version == '2021-06-01-preview':
from .v2021_06_01_preview.operations import PrivateLinkResourcesOperations as OperationClass
elif api_version == '2021-11-01':
from .v2021_11_01.operations import PrivateLinkResourcesOperations as OperationClass
else:
raise ValueError("API version {} does not have operation group 'private_link_resources'".format(api_version))
return OperationClass(self._client, self._config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
Expand All @@ -322,6 +354,19 @@ def regions(self):
raise ValueError("API version {} does not have operation group 'regions'".format(api_version))
return OperationClass(self._client, self._config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))

@property
def schema_registry(self):
"""Instance depends on the API version:
* 2021-11-01: :class:`SchemaRegistryOperations<azure.mgmt.eventhub.v2021_11_01.operations.SchemaRegistryOperations>`
"""
api_version = self._get_api_version('schema_registry')
if api_version == '2021-11-01':
from .v2021_11_01.operations import SchemaRegistryOperations as OperationClass
else:
raise ValueError("API version {} does not have operation group 'schema_registry'".format(api_version))
return OperationClass(self._client, self._config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))

def close(self):
self._client.close()
def __enter__(self):
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,4 +5,4 @@
# license information.
# --------------------------------------------------------------------------

VERSION = "9.1.0"
VERSION = "10.0.0"
Loading

0 comments on commit a644e1e

Please sign in to comment.