CodeGen from PR 15979 in Azure/azure-rest-api-specs

EventHub: Added missing Cluster API in 2021-06-01-preview (Azure#15979) * Added missing Cluster APIs to 2021-01-01-preview * added cluster API in 2021-06-01-preview * updated lint errors * update 1 * added listbysubscription * fixed ModelValidation Co-authored-by: v-ajnava <[email protected]>
AzureSDKAutomation · Sep 16, 2021 · bd1f621 · bd1f621
1 parent 03516c3
commit bd1f621
Show file tree

Hide file tree

Showing 25 changed files with 7,850 additions and 7 deletions.
diff --git a/sdk/eventhub/azure-mgmt-eventhub/_meta.json b/sdk/eventhub/azure-mgmt-eventhub/_meta.json
@@ -1,7 +1,7 @@
 {
   "autorest": "V2",
   "use": "@microsoft.azure/autorest.python@~4.0.71",
-  "commit": "243dc16d38ca0f0d251efa2d216468a670cd8beb",
+  "commit": "c9992af7235a6550087d4fed8f081ed35019f605",
   "repository_url": "https://github.com/Azure/azure-rest-api-specs",
   "autorest_command": "autorest specification/eventhub/resource-manager/readme.md --keep-version-file --multiapi --no-async --python --python-mode=update --python-sdks-folder=/home/vsts/work/1/s/azure-sdk-for-python/sdk [email protected]/autorest.python@~4.0.71 --version=V2",
   "readme": "specification/eventhub/resource-manager/readme.md"

diff --git a/sdk/eventhub/azure-mgmt-eventhub/azure/mgmt/eventhub/_event_hub_management_client.py b/sdk/eventhub/azure-mgmt-eventhub/azure/mgmt/eventhub/_event_hub_management_client.py
@@ -76,6 +76,7 @@ def models(cls, api_version=DEFAULT_API_VERSION):
            * 2017-04-01: :mod:`v2017_04_01.models<azure.mgmt.eventhub.v2017_04_01.models>`
            * 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>`
         """
         if api_version == '2015-08-01':
             from .v2015_08_01 import models
@@ -89,17 +90,23 @@ def models(cls, api_version=DEFAULT_API_VERSION):
         elif api_version == '2021-01-01-preview':
             from .v2021_01_01_preview import models
             return models
+        elif api_version == '2021-06-01-preview':
+            from .v2021_06_01_preview import models
+            return models
         raise NotImplementedError("APIVersion {} is not available".format(api_version))
 
     @property
     def clusters(self):
         """Instance depends on the API version:
 
            * 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>`
         """
         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
         else:
             raise NotImplementedError("APIVersion {} is not available".format(api_version))
         return OperationClass(self._client, self.config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
@@ -109,10 +116,13 @@ def configuration(self):
         """Instance depends on the API version:
 
            * 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>`
         """
         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
         else:
             raise NotImplementedError("APIVersion {} is not available".format(api_version))
         return OperationClass(self._client, self.config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
@@ -125,6 +135,7 @@ def consumer_groups(self):
            * 2017-04-01: :class:`ConsumerGroupsOperations<azure.mgmt.eventhub.v2017_04_01.operations.ConsumerGroupsOperations>`
            * 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>`
         """
         api_version = self._get_api_version('consumer_groups')
         if api_version == '2015-08-01':
@@ -135,6 +146,8 @@ def consumer_groups(self):
             from .v2018_01_01_preview.operations import ConsumerGroupsOperations as OperationClass
         elif api_version == '2021-01-01-preview':
             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
         else:
             raise NotImplementedError("APIVersion {} is not available".format(api_version))
         return OperationClass(self._client, self.config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
@@ -146,6 +159,7 @@ def disaster_recovery_configs(self):
            * 2017-04-01: :class:`DisasterRecoveryConfigsOperations<azure.mgmt.eventhub.v2017_04_01.operations.DisasterRecoveryConfigsOperations>`
            * 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>`
         """
         api_version = self._get_api_version('disaster_recovery_configs')
         if api_version == '2017-04-01':
@@ -154,6 +168,8 @@ def disaster_recovery_configs(self):
             from .v2018_01_01_preview.operations import DisasterRecoveryConfigsOperations as OperationClass
         elif api_version == '2021-01-01-preview':
             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
         else:
             raise NotImplementedError("APIVersion {} is not available".format(api_version))
         return OperationClass(self._client, self.config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
@@ -166,6 +182,7 @@ def event_hubs(self):
            * 2017-04-01: :class:`EventHubsOperations<azure.mgmt.eventhub.v2017_04_01.operations.EventHubsOperations>`
            * 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>`
         """
         api_version = self._get_api_version('event_hubs')
         if api_version == '2015-08-01':
@@ -176,6 +193,8 @@ def event_hubs(self):
             from .v2018_01_01_preview.operations import EventHubsOperations as OperationClass
         elif api_version == '2021-01-01-preview':
             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
         else:
             raise NotImplementedError("APIVersion {} is not available".format(api_version))
         return OperationClass(self._client, self.config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
@@ -188,6 +207,7 @@ def namespaces(self):
            * 2017-04-01: :class:`NamespacesOperations<azure.mgmt.eventhub.v2017_04_01.operations.NamespacesOperations>`
            * 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>`
         """
         api_version = self._get_api_version('namespaces')
         if api_version == '2015-08-01':
@@ -198,6 +218,8 @@ def namespaces(self):
             from .v2018_01_01_preview.operations import NamespacesOperations as OperationClass
         elif api_version == '2021-01-01-preview':
             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
         else:
             raise NotImplementedError("APIVersion {} is not available".format(api_version))
         return OperationClass(self._client, self.config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
@@ -210,6 +232,7 @@ def operations(self):
            * 2017-04-01: :class:`Operations<azure.mgmt.eventhub.v2017_04_01.operations.Operations>`
            * 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>`
         """
         api_version = self._get_api_version('operations')
         if api_version == '2015-08-01':
@@ -220,6 +243,8 @@ def operations(self):
             from .v2018_01_01_preview.operations import Operations as OperationClass
         elif api_version == '2021-01-01-preview':
             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
         else:
             raise NotImplementedError("APIVersion {} is not available".format(api_version))
         return OperationClass(self._client, self.config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
@@ -230,12 +255,15 @@ 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>`
         """
         api_version = self._get_api_version('private_endpoint_connections')
         if api_version == '2018-01-01-preview':
             from .v2018_01_01_preview.operations import PrivateEndpointConnectionsOperations as OperationClass
         elif api_version == '2021-01-01-preview':
             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
         else:
             raise NotImplementedError("APIVersion {} is not available".format(api_version))
         return OperationClass(self._client, self.config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
@@ -246,12 +274,15 @@ 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>`
         """
         api_version = self._get_api_version('private_link_resources')
         if api_version == '2018-01-01-preview':
             from .v2018_01_01_preview.operations import PrivateLinkResourcesOperations as OperationClass
         elif api_version == '2021-01-01-preview':
             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
         else:
             raise NotImplementedError("APIVersion {} is not available".format(api_version))
         return OperationClass(self._client, self.config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))

diff --git a/sdk/eventhub/azure-mgmt-eventhub/azure/mgmt/eventhub/v2018_01_01_preview/models/_models.py b/sdk/eventhub/azure-mgmt-eventhub/azure/mgmt/eventhub/v2018_01_01_preview/models/_models.py
@@ -493,7 +493,7 @@ class ClusterSku(Model):
 
     _validation = {
         'name': {'required': True, 'constant': True},
-        'capacity': {'maximum': 32, 'minimum': 1},
+        'capacity': {'minimum': 1},
     }
 
     _attribute_map = {
@@ -631,6 +631,8 @@ class EHNamespace(TrackedResource):
     :type identity: ~azure.mgmt.eventhub.v2018_01_01_preview.models.Identity
     :ivar provisioning_state: Provisioning state of the Namespace.
     :vartype provisioning_state: str
+    :ivar status: Status of the Namespace.
+    :vartype status: str
     :ivar created_at: The time the Namespace was created.
     :vartype created_at: datetime
     :ivar updated_at: The time the Namespace was updated.
@@ -665,6 +667,7 @@ class EHNamespace(TrackedResource):
         'name': {'readonly': True},
         'type': {'readonly': True},
         'provisioning_state': {'readonly': True},
+        'status': {'readonly': True},
         'created_at': {'readonly': True},
         'updated_at': {'readonly': True},
         'service_bus_endpoint': {'readonly': True},
@@ -681,6 +684,7 @@ class EHNamespace(TrackedResource):
         'sku': {'key': 'sku', 'type': 'Sku'},
         'identity': {'key': 'identity', 'type': 'Identity'},
         'provisioning_state': {'key': 'properties.provisioningState', 'type': 'str'},
+        'status': {'key': 'properties.status', 'type': 'str'},
         'created_at': {'key': 'properties.createdAt', 'type': 'iso-8601'},
         'updated_at': {'key': 'properties.updatedAt', 'type': 'iso-8601'},
         'service_bus_endpoint': {'key': 'properties.serviceBusEndpoint', 'type': 'str'},
@@ -698,6 +702,7 @@ def __init__(self, **kwargs):
         self.sku = kwargs.get('sku', None)
         self.identity = kwargs.get('identity', None)
         self.provisioning_state = None
+        self.status = None
         self.created_at = None
         self.updated_at = None
         self.service_bus_endpoint = None
@@ -1360,7 +1365,7 @@ class Sku(Model):
 
     _validation = {
         'name': {'required': True},
-        'capacity': {'maximum': 20, 'minimum': 0},
+        'capacity': {'minimum': 0},
     }
 
     _attribute_map = {

diff --git a/...venthub/azure-mgmt-eventhub/azure/mgmt/eventhub/v2018_01_01_preview/models/_models_py3.py b/...venthub/azure-mgmt-eventhub/azure/mgmt/eventhub/v2018_01_01_preview/models/_models_py3.py
@@ -493,7 +493,7 @@ class ClusterSku(Model):
 
     _validation = {
         'name': {'required': True, 'constant': True},
-        'capacity': {'maximum': 32, 'minimum': 1},
+        'capacity': {'minimum': 1},
     }
 
     _attribute_map = {
@@ -631,6 +631,8 @@ class EHNamespace(TrackedResource):
     :type identity: ~azure.mgmt.eventhub.v2018_01_01_preview.models.Identity
     :ivar provisioning_state: Provisioning state of the Namespace.
     :vartype provisioning_state: str
+    :ivar status: Status of the Namespace.
+    :vartype status: str
     :ivar created_at: The time the Namespace was created.
     :vartype created_at: datetime
     :ivar updated_at: The time the Namespace was updated.
@@ -665,6 +667,7 @@ class EHNamespace(TrackedResource):
         'name': {'readonly': True},
         'type': {'readonly': True},
         'provisioning_state': {'readonly': True},
+        'status': {'readonly': True},
         'created_at': {'readonly': True},
         'updated_at': {'readonly': True},
         'service_bus_endpoint': {'readonly': True},
@@ -681,6 +684,7 @@ class EHNamespace(TrackedResource):
         'sku': {'key': 'sku', 'type': 'Sku'},
         'identity': {'key': 'identity', 'type': 'Identity'},
         'provisioning_state': {'key': 'properties.provisioningState', 'type': 'str'},
+        'status': {'key': 'properties.status', 'type': 'str'},
         'created_at': {'key': 'properties.createdAt', 'type': 'iso-8601'},
         'updated_at': {'key': 'properties.updatedAt', 'type': 'iso-8601'},
         'service_bus_endpoint': {'key': 'properties.serviceBusEndpoint', 'type': 'str'},
@@ -698,6 +702,7 @@ def __init__(self, *, location: str=None, tags=None, sku=None, identity=None, cl
         self.sku = sku
         self.identity = identity
         self.provisioning_state = None
+        self.status = None
         self.created_at = None
         self.updated_at = None
         self.service_bus_endpoint = None
@@ -1360,7 +1365,7 @@ class Sku(Model):
 
     _validation = {
         'name': {'required': True},
-        'capacity': {'maximum': 20, 'minimum': 0},
+        'capacity': {'minimum': 0},
     }
 
     _attribute_map = {

diff --git a/sdk/eventhub/azure-mgmt-eventhub/azure/mgmt/eventhub/v2021_01_01_preview/models/_models.py b/sdk/eventhub/azure-mgmt-eventhub/azure/mgmt/eventhub/v2021_01_01_preview/models/_models.py
@@ -506,6 +506,8 @@ class EHNamespace(TrackedResource):
      ~azure.mgmt.eventhub.v2021_01_01_preview.models.SystemData
     :ivar provisioning_state: Provisioning state of the Namespace.
     :vartype provisioning_state: str
+    :ivar status: Status of the Namespace.
+    :vartype status: str
     :ivar created_at: The time the Namespace was created.
     :vartype created_at: datetime
     :ivar updated_at: The time the Namespace was updated.
@@ -544,6 +546,7 @@ class EHNamespace(TrackedResource):
         'type': {'readonly': True},
         'system_data': {'readonly': True},
         'provisioning_state': {'readonly': True},
+        'status': {'readonly': True},
         'created_at': {'readonly': True},
         'updated_at': {'readonly': True},
         'service_bus_endpoint': {'readonly': True},
@@ -561,6 +564,7 @@ class EHNamespace(TrackedResource):
         'identity': {'key': 'identity', 'type': 'Identity'},
         'system_data': {'key': 'systemData', 'type': 'SystemData'},
         'provisioning_state': {'key': 'properties.provisioningState', 'type': 'str'},
+        'status': {'key': 'properties.status', 'type': 'str'},
         'created_at': {'key': 'properties.createdAt', 'type': 'iso-8601'},
         'updated_at': {'key': 'properties.updatedAt', 'type': 'iso-8601'},
         'service_bus_endpoint': {'key': 'properties.serviceBusEndpoint', 'type': 'str'},
@@ -580,6 +584,7 @@ def __init__(self, **kwargs):
         self.identity = kwargs.get('identity', None)
         self.system_data = None
         self.provisioning_state = None
+        self.status = None
         self.created_at = None
         self.updated_at = None
         self.service_bus_endpoint = None
@@ -1167,7 +1172,7 @@ class Sku(Model):
 
     _validation = {
         'name': {'required': True},
-        'capacity': {'maximum': 20, 'minimum': 0},
+        'capacity': {'minimum': 0},
     }
 
     _attribute_map = {