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>

sdk/eventhub/azure-mgmt-eventhub/_meta.json

@@ -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"

sdk/eventhub/azure-mgmt-eventhub/azure/mgmt/eventhub/_event_hub_management_client.py

@@ -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.).
@@ -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"
     )
@@ -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
@@ -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
@@ -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)))
@@ -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)))
@@ -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':
@@ -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)))
@@ -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':
@@ -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)))
@@ -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':
@@ -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)))
@@ -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':
@@ -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)))
@@ -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':
@@ -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)))
@@ -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':
@@ -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)))
@@ -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':
@@ -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)))
@@ -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):